pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttClientConnectorPool.java
@@ -21,17 +21,13 @@ * 连接MQTT客户端 * @return 获取MQTT连队对象 */ public static MqttClient connectMQTT() { public static MqttClient connectMQTT(String broker, String username, String password) { if (mqttClient != null){ log.info("已存在!"); return mqttClient; } try { // broker及连接信息 String broker = "tcp://127.0.0.1:1883"; String username = "mqtt_u"; String password = "yjy"; String clientId = System.currentTimeMillis() + ""; //创建MQTT客户端(指定broker、客户端id、消息持久策略)