这非常适合启动连接并发布第一条消息:
MemoryPersistence persistence = new MemoryPersistence();
client = new MqttClient("tcp://" + IrisProperties.MQTT_SERVER_ADDRESS,
IrisProperties.MQTT_USERNAME,persistence);
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setConnectionTimeout(1);
connOpts.setUserName(IrisProperties.MQTT_USERNAME);
connOpts.setPassword(IrisProperties.MQTT_PASSWORD.toCharArray());
connOpts.setCleanSession(true);
client.connect(connOpts);
此连接每秒发布超过 100 条消息,这行没有问题:
MqttMessage message = new MqttMessage(content.getBytes());
message.setQos(qos);
client.publish(topic, message);
但是过了一会儿(几分钟后)这个方法的第三行
sampleClient.publish(topic, message);
即使我将超时设置为 1 秒,线程也会永远阻塞。
我使用 Moquette 作为带有 websockets 的 MQTT 代理。
Use
client.setTimeToWait(timeToWaitInMillis);
默认情况下,该时间为 -1,因此这将阻止当前线程,直到操作完成。超时指定它将阻止线程的最长时间。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)