修改bug

liurunyu

2025-08-06 1b910faabb48b3355783a612e41c5b55942c34a4

 pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttMsgSubscriber.java

@@ -3,7 +3,6 @@
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.beans.factory.annotation.Value;

/**
 * @author ZhuBaoMin
@@ -15,25 +14,20 @@
@Slf4j
public class MqttMsgSubscriber {

    @Value("${spring.mqtt.broker}")
    private String broker;

    @Value("${spring.mqtt.username}")
    private String username;

    @Value("${spring.mqtt.password}")
    private String password;

    @Value("${spring.mqtt.topic}")
    private String topic;

    @Value("${spring.mqtt.qos}")
    private Integer qos;

    private String clientId = System.currentTimeMillis() + "";

    public void readSubscribeTopicMessage(){
        try {
            //String broker = "tcp://127.0.0.1:1883";
            //String username = "mqtt_u";
            //String password = "yjy";
            //String topic = "workOrder";
            String broker = "tcp://127.0.0.1:1884";
            String username = "server";
            String password = "1234";
            String topic = "report/#";

            Integer qos = 2;
            String clientId = System.currentTimeMillis() + "";

            MqttClient client = new MqttClient(broker, clientId, new MemoryPersistence());

            // 连接参数