寻求适用于JUnit/Spock的通用JMS端到端测试客户端

基于你的端到端测试需求（独立JVM运行、禁止Mock/Bean代理、无法访问目标系统JVM、通用兼容各类消息代理、支持Topic和Queue收发），标准JMS 2.0 API的原生客户端是最贴合的选择——JMS本身就是Java消息服务的通用规范，几乎所有主流消息代理（ActiveMQ、RabbitMQ、IBM MQ、Solace等）都支持它，完全能满足你的测试要求。

1. 选一个通用的JMS客户端库 #

优先推荐 Apache Qpid JMS Client：

• 完全兼容JMS 2.0规范，支持AMQP 1.0协议（这是现代消息代理通用的底层协议），能无缝对接绝大多数主流消息代理；
• 轻量级、无冗余依赖，打包后可以在任何Java环境独立运行；
• 社区活跃，文档完善，遇到问题容易找到解决方案。

如果你的测试环境主要用ActiveMQ Classic，也可以用它官方的JMS客户端，但Qpid的通用性更强，更符合你“与代理无关”的要求。

2. 核心代码示例（支持Topic/Queue收发） #

下面是可以直接复用的代码，所有连接参数都可以外部传入（环境变量或命令行参数），完全不需要依赖目标系统的任何类，打包后就能在独立JVM或机器上运行。

消息发送工具（支持Queue/Topic） #

import javax.jms.*;
import org.apache.qpid.jms.JmsConnectionFactory;

public class JmsE2ESender {
    public static void main(String[] args) throws JMSException {
        // 从环境变量获取代理连接信息（避免硬编码，方便适配不同环境）
        String brokerUrl = System.getenv("JMS_BROKER_URL");
        String username = System.getenv("JMS_USERNAME");
        String password = System.getenv("JMS_PASSWORD");
        
        // 命令行参数：目标名称、是否是Topic（true/false）、消息内容
        String destName = args[0];
        boolean isTopic = Boolean.parseBoolean(args[1]);
        String msgContent = args[2];

        // 创建Qpid连接工厂（兼容AMQP协议的代理）
        ConnectionFactory factory = new JmsConnectionFactory(username, password, brokerUrl);
        
        // 用try-with-resources自动关闭资源
        try (Connection conn = factory.createConnection();
             Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE)) {
            
            // 创建目标（Queue或Topic）
            Destination dest = isTopic ? session.createTopic(destName) : session.createQueue(destName);
            
            // 发送消息
            MessageProducer producer = session.createProducer(dest);
            TextMessage msg = session.createTextMessage(msgContent);
            producer.send(msg);
            
            System.out.printf("✅ 成功发送消息到%s: %s\n", isTopic ? "Topic" : "Queue", destName);
        }
    }
}

消息接收工具（支持Queue/Topic） #

import javax.jms.*;
import org.apache.qpid.jms.JmsConnectionFactory;

public class JmsE2EReceiver {
    public static void main(String[] args) throws JMSException {
        String brokerUrl = System.getenv("JMS_BROKER_URL");
        String username = System.getenv("JMS_USERNAME");
        String password = System.getenv("JMS_PASSWORD");
        
        // 命令行参数：目标名称、是否是Topic（true/false）、接收消息数量
        String destName = args[0];
        boolean isTopic = Boolean.parseBoolean(args[1]);
        int msgCount = Integer.parseInt(args[2]);

        ConnectionFactory factory = new JmsConnectionFactory(username, password, brokerUrl);
        
        try (Connection conn = factory.createConnection();
             Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE)) {
            
            Destination dest;
            if (isTopic) {
                dest = session.createTopic(destName);
                // 如果需要持久订阅，必须设置客户端ID（可选，按需开启）
                conn.setClientID("e2e-test-subscriber");
            } else {
                dest = session.createQueue(destName);
            }

            MessageConsumer consumer = session.createConsumer(dest);
            conn.start(); // 启动连接开始接收消息

            System.out.printf("🔍 开始从%s接收消息...\n", isTopic ? "Topic" : "Queue");
            for (int i = 0; i < msgCount; i++) {
                TextMessage msg = (TextMessage) consumer.receive(5000); // 5秒超时
                if (msg != null) {
                    System.out.printf("Received message: %s\n", msg.getText());
                } else {
                    System.out.println("⚠️ 超时未收到消息");
                    break;
                }
            }
        }
    }
}

3. 关键注意事项（完全满足你的测试约束） #

• 完全独立运行：把代码打包成可执行JAR后，不需要依赖目标系统的任何资源，直接在独立JVM或机器上运行，只需要传入代理的连接参数即可；
• 无Mock/代理类：直接连接真实的消息代理，发送/接收真实的消息，完全符合端到端测试的要求；
• 通用性：更换消息代理只需要修改JMS_BROKER_URL（比如ActiveMQ Artemis是amqp://localhost:5672，RabbitMQ开启AMQP后也是这个端口，IBM MQ可能是amqp://localhost:5671带SSL），代码完全不需要改动；
• 支持Topic和Queue：通过命令行参数控制创建Topic还是Queue，轻松适配两种消息模型的测试场景。

4. 打包与运行示例 #

用Maven打包的话，在pom.xml里添加依赖和打包插件：

<dependencies>
    <dependency>
        <groupId>org.apache.qpid</groupId>
        <artifactId>qpid-jms-client</artifactId>
        <version>2.3.0</version> <!-- 建议用最新稳定版 -->
    </dependency>
</dependencies>

<build>
    <plugins>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-shade-plugin</artifactId>
            <version>3.4.1</version>
            <executions>
                <execution>
                    <phase>package</phase>
                    <goals>
                        <goal>shade</goal>
                    </goals>
                    <configuration>
                        <transformers>
                            <!-- 这里可以分别打包Sender和Receiver，或者写一个统一入口类 -->
                            <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
                                <mainClass>com.yourpackage.JmsE2ESender</mainClass>
                            </transformer>
                        </transformers>
                    </configuration>
                </execution>
            </executions>
        </plugin>
    </plugins>
</build>

运行示例（Linux/macOS）：

# 设置代理连接参数（Windows用set命令）
export JMS_BROKER_URL=amqp://localhost:5672
export JMS_USERNAME=admin
export JMS_PASSWORD=admin

# 发送消息到Queue
java -jar jms-e2e-client.jar test-queue false "Hello E2E Test"

# 发送消息到Topic
java -jar jms-e2e-client.jar test-topic true "Hello Topic Subscribers"

# 从Queue接收1条消息
java -jar jms-e2e-client.jar test-queue false 1

# 从Topic接收1条消息
java -jar jms-e2e-client.jar test-topic true 1

内容的提问来源于stack exchange，提问作者mohamnag