消息在 paho-mqtt 中丢失

Question

我正在使用 paho-mqtt 从 emqx 代理接收数据，但我丢失了数据，因为有时我的 paho-mqtt 订阅者出现故障。当我再次运行订阅者时，任何获取数据的方法都会提供所有已发布的数据。

Answer 1

如果没有订阅者，EMQ x 会丢弃该消息，这是正常的设计。

可以试试 EMQ x 企业版，使用后端进行离线数据存储。

https://docs.emqx.io/tutorial/latest/en/backend/whats_backend.html

Answer 2

我希望你得到一个解决方案。我不知道你的客户端，但是 paho-mqtt java 客户端可以自动重新连接。可以在“connectComplete(boolean reconnect, String s)”布尔参数中检查此重新连接

public class MqttautoClient implements MqttCallbackExtended {

.

.

.

    @Override

    public void connectComplete(boolean reconnect, String s) {

        Log.d(TAG, "Connection connectComplete");

    }

    @Override

    public void connectionLost(Throwable throwable) {

        Log.d(TAG, "Connection lost");

    }

    @Override

    public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception 

    {

        Log.d(TAG, "messageArrived");

    }

    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

        Log.d(TAG, "deliveryComplete ");

    }

}