wuzeyu
2024-12-19 e86db806e1dcde94b1aa38230138a3fa3895572a
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、消息持久策略)