AWS环境下VertX EventBus无法接收消息问题排查求助

我有一个部署在3台不同EC2实例上的Java服务，使用Hazelcast组成集群。以下是cluster.xml配置片段：

<join>
    <multicast enabled="false"></multicast>
    <tcp-ip enabled="false"></tcp-ip>
    <aws enabled="${AWS_ENABLED}">
        <iam-role>DEFAULT</iam-role>
        <region>us-east-1</region>
        <security-group-name>sec-group-name</security-group-name>
        <hz-port>6100-6110</hz-port>
    </aws>
</join>

集群发现成功，日志如下：

[3.12.2] (This is the hazelcast version)
Members {size:3, ver:31} [
    Member [10.0.3.117]:6100 - f5a9d579-ae9c-4c3d-8126-0e8d3a1ecdb9
    Member [10.0.1.32]:6100 - 5799f451-f122-4886-92de-e351704e6980
    Member [10.0.1.193]:6100 - 626de40a-197a-446e-a44f-ac456a52d118 this
]

vertxInstance.sharedData()功能正常，实例间可共享缓存数据。但使用VertX EventBus发布消息时，消费者无法接收消息：
发布代码：

this.vertx.eventBus().publish(EventBusService.TOPIC, memberId);

监听器代码：

eventBus.consumer(TOPIC, event -> {
   logger.warn("Captured message: {}", event.body());
});

该配置在本地环境可正常运行，但部署到AWS后失效。曾尝试显式设置主机，仍无法解决：

VertxOptions options = new VertxOptions();
options.setHAEnabled(true);
options.getEventBusOptions().setClustered(true);
options.getEventBusOptions().setHost("10.0.1.0"); 

请问哪里配置有误？还有哪些进一步的调试方案？

1. EventBus绑定主机地址错误 #

你设置的setHost("10.0.1.0")是子网地址，不是实例的实际私有IP，会导致其他节点无法正确连接到该实例的EventBus。正确做法：

• 绑定到实例自身的私有IP，可通过AWS元数据服务动态获取：

  // 获取EC2实例私有IP
  String privateIp = new String(new URL("http://169.254.169.254/latest/meta-data/local-ipv4").openStream().readAllBytes());
  options.getEventBusOptions().setHost(privateIp);
  

• 或者直接设置为0.0.0.0，允许绑定到所有可用网卡，避免指定错误IP：

  options.getEventBusOptions().setHost("0.0.0.0");
  

2. Vert.x与Hazelcast集群端口/配置不匹配 #

你的Hazelcast配置使用了6100-6110端口，但Vert.x默认会使用Hazelcast的默认端口5701，且需要确保两者使用同一套集群配置：

• 显式指定Vert.x使用你的cluster.xml配置：

  Config hazelcastConfig = new XmlConfigBuilder("cluster.xml").build();
  options.setClusterManager(new HazelcastClusterManager(hazelcastConfig));
  

• 检查EC2安全组，允许集群实例间6100-6110（Hazelcast）和5701（Vert.x EventBus默认端口）的TCP通信，若自定义了EventBus端口，同步开放对应端口。

3. HA模式与集群模式的冗余配置 #

setHAEnabled(true)是Vert.x的高可用模式，并非集群通信的必要条件，反而可能引入额外复杂度。先关闭HA模式测试：

VertxOptions options = new VertxOptions();
// options.setHAEnabled(true); // 先注释掉
options.getEventBusOptions().setClustered(true);
options.getEventBusOptions().setHost("0.0.0.0");

• 开启调试日志：
  在日志配置中添加以下规则，查看EventBus节点发现、消息发送的细节：

  logger.io.vertx.eventbus=DEBUG
  logger.com.hazelcast=DEBUG
  

  重点关注是否有连接超时、节点发现失败或消息丢弃的日志。

• 测试端口连通性：
  在EC2实例上用nc命令测试其他实例的EventBus端口是否可达：

  nc -zv 10.0.3.117 5701
  

  若不通，检查安全组规则或实例内部防火墙配置。

• 监听集群节点状态：
  在代码中添加集群节点变更监听，确认EventBus集群是否成功组建：

  vertx.eventBus().registerClusterNodeListener(event -> {
      logger.info("Cluster node updated: {}", event);
  });
  

  或通过Hazelcast API查看成员属性，验证EventBus端点是否正确注册：

  HazelcastInstance hzInstance = ((HazelcastClusterManager) vertx.getClusterManager()).getHazelcastInstance();
  hzInstance.getCluster().getMembers().forEach(member -> {
      logger.info("Member attributes: {}", member.getAttributes());
  });
  

• 本地模拟AWS环境：
  用Docker创建多节点私有网络，复现AWS的网络环境，测试配置是否能正常运行，排除云环境特定问题。

内容的提问来源于stack exchange，提问作者Костадин Поп-Кочев