如何通过Eclipse Paho Java判断MQTT客户端消息发布是否失败？

核心反馈机制说明 #

Paho Java 3.1版本针对不同QoS等级的消息，提供了差异化的发送失败反馈方式：

• QoS 0消息：
  QoS 0为「最多一次」交付模式，客户端发送消息后不会跟踪代理的接收状态，因此默认无任何告警或失败通知。若需确认这类消息的交付结果，只能依赖代理端日志或额外的业务回执逻辑。

• QoS 1/QoS 2消息：
  这两类QoS要求至少一次/恰好一次交付，客户端会跟踪代理的ACK响应，发送失败时会有明确提示，主要有两种获取状态的方式：

  1. 同步发送方式：
     使用阻塞式的publish(Topic topic, MqttMessage message)方法，发送后会等待代理的ACK。若发送失败（如网络中断、代理无响应、权限被拒绝），会直接抛出MqttException，可捕获该异常触发重发逻辑。
     示例代码：

     try {
         client.publish("test/topic", new MqttMessage("payload".getBytes()));
     } catch (MqttException e) {
         System.err.println("消息发送失败，错误码：" + e.getReasonCode());
         // 执行重发逻辑
         retryFailedMessage("test/topic", "payload".getBytes());
     }
     

  2. 异步发送+回调监听：
     使用带回调的publish(topic, message, userContext, actionListener)方法，实现IMqttActionListener接口的onSuccess和onFailure方法。发送失败时onFailure会被触发，可在此处理重发。
     示例代码：

     client.publish("test/topic", new MqttMessage("payload".getBytes()), null, new IMqttActionListener() {
         @Override
         public void onSuccess(IMqttToken asyncActionToken) {
             // 发送成功处理逻辑
         }
     
         @Override
         public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
             System.err.println("消息发送失败：" + exception.getMessage());
             // 执行重发逻辑
             retryFailedMessage("test/topic", "payload".getBytes());
         }
     });
     

重发注意事项 #

1. 重发建议设置重试间隔（如指数退避），避免短时间内频繁重试给网络或代理带来压力；
2. 需保证消息的幂等性，防止多次重发导致业务逻辑重复执行；
3. 若连接断开后恢复，客户端会自动重发未完成的QoS1/QoS2消息（基于客户端持久化配置），无需手动处理该场景的重发。

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