苏州配置文件简化

张晓波

2023-10-17 f366507862db332da6c75e6d2f09b7d299292a2a

 hd/pipe/StaffManage/src/main/java/com/thhy/staff/utils/MqUtils.java

@@ -8,13 +8,14 @@
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import java.util.List;

public class MqUtils {

    public static void createClient(EmqxConfig emqxConfig){
    public static void createClient(EmqxConfig emqxConfig, List<String> topics, String content){
        String broker = "tcp://"+emqxConfig.getHost()+":"+emqxConfig.getPort();
        String clientId = UUIDUtils.create();
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient client = new MqttClient(broker, clientId, persistence);

@@ -39,11 +40,12 @@
            //client.subscribe(subTopic);

            // 消息发布所需参数
           /* MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(qos);
            client.publish(pubTopic, message);
            System.out.println("Message published");*/

            MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(emqxConfig.getQos());
            for(String pubTopic : topics){
                client.publish(pubTopic, message);
            }
            System.out.println("Message published");
            client.disconnect();
        } catch (MqttException e) {
            throw new RuntimeException(e);