liurunyu
2024-11-26 487bed3eba27a1f6621c43b7fab5c82468fa2bc9
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、消息持久策略)