使用Eclipse Paho Java客户端连接RabbitMQ-MQTT Broker失败报错

"Broker unavailable (3)"错误本质是客户端无法与Broker建立TCP连接，结合你的场景，按以下步骤排查解决：

1. 修正代码中的IP占位符 #

你代码里的tcp://0000.0000.0000.0000:1883是占位符，必须替换为Linux服务器的实际内网/公网IP地址，否则客户端根本不知道要连接到哪台机器。

2. 验证网络连通性 #

在Windows命令行执行以下命令，确认网络可达：

• 测试服务器连通性：ping <你的Linux服务器IP>
• 测试1883端口开放情况：telnet <你的Linux服务器IP> 1883（如果telnet未启用，可改用nc -zv <你的Linux服务器IP> 1883，需先安装nmap工具）

如果以上命令失败，说明网络存在阻断，优先解决网络问题。

3. 确认RabbitMQ的MQTT插件已启用 #

在Linux服务器上执行命令，检查MQTT插件状态：

rabbitmq-plugins list

找到rabbitmq_mqtt插件，确保其状态为[E]（已启用）。如果未启用，执行以下命令开启：

rabbitmq-plugins enable rabbitmq_mqtt

4. 检查用户权限配置 #

确保mqtt-publisher-client用户拥有访问MQTT资源的权限，在Linux服务器上执行：

rabbitmqctl set_permissions -p / mqtt-publisher-client ".*" ".*" ".*"

这条命令会给默认vhost(/)下的用户授予发布、订阅、创建队列/交换器的全权限，测试通过后可根据实际需求缩小权限范围。

5. 检查防火墙与安全组 #

• Linux本地防火墙：确保firewalld/iptables允许1883端口的入站连接，以firewalld为例：

  firewall-cmd --add-port=1883/tcp --permanent
  firewall-cmd --reload
  

• 云服务器安全组：如果你的RabbitMQ部署在云服务器上，需在云平台控制台的安全组规则中，添加允许Windows机器IP访问1883端口的入站规则。

6. 优化代码的错误排查能力 #

添加异常捕获与超时配置，方便定位更详细的错误：

try {
    MqttClient client = new MqttClient("tcp://<实际服务器IP>:1883", "mqtt-publisher-client123", new MemoryPersistence());
    MqttConnectOptions options = new MqttConnectOptions();
    options.setCleanSession(false);
    options.setUserName("mqtt-publisher-client");
    options.setPassword("publisher".toCharArray());
    options.setConnectionTimeout(30); // 设置30秒连接超时
    client.connect(options);
    System.out.println("Broker连接成功");
} catch (MqttException e) {
    System.out.println("连接失败，错误码：" + e.getReasonCode());
    e.printStackTrace();
}

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