Vert.x AMQP客户端连接嵌入式ActiveMQ Artemis超时问题求助

1. 核对端口一致性 #

嵌入式ActiveMQ Artemis默认端口通常和独立服务不同（比如独立服务默认61616，嵌入式可能用随机端口），务必确保JUnit测试中客户端连接的端口和嵌入式服务实际启动的端口一致。

• 通过EmbeddedActiveMQExtension的API获取实际端口：在测试类中注入EmbeddedActiveMQ实例，调用getBroker().getAcceptorInfos()拿到 acceptor 的端口，动态设置客户端连接地址，不要硬写配置文件里的固定端口。

2. 开启TCP Acceptor #

嵌入式服务默认可能仅启用VM acceptor，而Vert.x客户端用TCP连接，导致无法通信。需要显式添加TCP acceptor配置：

@RegisterExtension
static EmbeddedActiveMQExtension extension = new EmbeddedActiveMQExtension()
    .withConfiguration(config -> {
        config.addAcceptorConfiguration("tcp", "tcp://localhost:0"); // 0表示随机分配端口
    });

3. 调整Vert.x客户端连接参数 #

默认60秒超时可能不匹配嵌入式服务的启动节奏，可调整超时和重试策略：

AmqpClientOptions options = new AmqpClientOptions()
    .setConnectTimeout(10000) // 设为10秒超时
    .setReconnectAttempts(3) // 重试3次
    .setReconnectInterval(2000); // 每次重试间隔2秒
AmqpClient client = AmqpClient.create(vertx, options);

4. 异步等待服务就绪 #

JUnit测试中要确保嵌入式服务完全启动后再发起连接，用VertxTestContext处理异步逻辑：

@Test
void testMessageSend(Vertx vertx, VertxTestContext testContext) {
    EmbeddedActiveMQ broker = extension.getBroker();
    int brokerPort = broker.getAcceptorInfos().get(0).getPort();
    AmqpClient client = AmqpClient.create(vertx, new AmqpClientOptions().setPort(brokerPort));

    client.connect()
        .onSuccess(conn -> {
            conn.createSender("test-queue")
                .send(AmqpMessage.create().body("test data").build())
                .onSuccess(v -> testContext.completeNow())
                .onFailure(testContext::failNow);
        })
        .onFailure(testContext::failNow);

    await().until(testContext::succeeded);
}

5. 排查日志细节 #

• 开启嵌入式服务DEBUG日志，确认是否有AMQ221020: Started TCP acceptor日志，验证TCP acceptor正常启动。
• 查看客户端日志，确认连接请求发送到正确端口，是否存在握手失败等异常。

6. 避免配置文件冲突 #

测试时可能加载了application.yml中的独立服务配置，导致客户端连错端口。可通过@TestPropertySource覆盖配置：

@TestPropertySource(properties = {
    "activemq.broker-url=tcp://localhost:${embedded.activemq.port}"
})

再动态替换端口占位符。

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