1 changed files with 1 additions and 1 deletions
+ 1
- 1
tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/mqtt/MqttProviderConfig.java
View File
| try { | try { | ||||
| String ip = IpUtils.getHostIp(); | String ip = IpUtils.getHostIp(); | ||||
| //创建MQTT客户端对象 | //创建MQTT客户端对象 | ||||
| client = new MqttClient(hostUrl, ip, new MemoryPersistence()); | |||||
| client = new MqttClient(hostUrl, ip + "@" + clientId, new MemoryPersistence()); | |||||
| //连接设置 | //连接设置 | ||||
| MqttConnectOptions options = new MqttConnectOptions(); | MqttConnectOptions options = new MqttConnectOptions(); | ||||
| //是否清空session，设置false表示服务器会保留客户端的连接记录（订阅主题，qos）,客户端重连之后能获取到服务器在客户端断开连接期间推送的消息 | //是否清空session，设置false表示服务器会保留客户端的连接记录（订阅主题，qos）,客户端重连之后能获取到服务器在客户端断开连接期间推送的消息 |
Loading…