完善代码

liurunyu

2024-12-11 ef469c28fa81be575229d67a75f3129311b10111

 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、消息持久策略）