Paho MQTT连接到MQXR broker

Question

我有一个mqtt java代码(paho)写的，当它试图连接到Mosquitto时工作良好。它能够建立、发布所有消息到一个主题。但是使用MQXR (包含在MQ中的代理)，我得到

严重:无法连接到MQTT broker，请求可能丢失。连接丢失(32109) -由以下原因引起的org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:138) at java.io.DataInputStream.readByte(DataInputStream.java:250) at java.io.EOFException (Thread.java:736)：java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java:250) at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:56) at org.eclipse.paho.client.mqttv3内部.CommsReceiver.run(CommsReceiver.java:100) ...还有1个

QoS设置为2，在MQXR中找不到失败的原因？任何想法都是非常感谢的。

谢谢

Answer 1

断开连接的可能性有两种：

1. 一些MQTT代理将不支持Azure IoT-Hub等QOS-2实现。验证您的代理是否支持QOS-2。
2. 您要连接到哪个端口？如果它是SSL/TLS加密的，那么您不能使用未加密的连接过程进行连接。您必须在连接过程中使用bouncycastle启用SSL connection。