苏州配置文件简化

张晓波

2023-10-18 61e3629c7ab2f8b15636614399bfa9300d2f2f29

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

@@ -1,26 +1,31 @@
package com.thhy.staff.utils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.thhy.general.utils.UUIDUtils;
import com.thhy.staff.config.EmqxConfig;
import com.thhy.staff.modules.biz.face.entity.MqContent;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import java.util.ArrayList;
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);

            // MQTT 连接选项
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setUserName(emqxConfig.getUsername());
            connOpts.setUserName(emqxConfig.getLogin());
            connOpts.setPassword(emqxConfig.getPassword().toCharArray());
            // 保留会话
            connOpts.setCleanSession(true);
@@ -39,14 +44,51 @@
            //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);
        }
    }

    public static void main(String[] args) {
        EmqxConfig emqxConfig = new EmqxConfig();
        emqxConfig.setHost("111.30.93.215");
        emqxConfig.setPort("1883");
        emqxConfig.setQos(1);
        emqxConfig.setLogin("thhy");
        emqxConfig.setPassword("Thhy@123");

        System.out.println(JSON.toJSONString(emqxConfig));
        System.out.println(emqxConfig.toString());

        List<String> list = new ArrayList<>();
        list.add("0A:0C:E1:25:75:2C");

        String prefix = "http://111.30.93.212:15002/staff/face/";
        String notify = "/sp/notify";

        MqContent mqContent = new MqContent("sync_person", prefix+notify);

        JSONObject jsonObject = new JSONObject();
        jsonObject.put("path",prefix+"syncPersonSingle");
        JSONObject pathParamJson = new JSONObject();
        pathParamJson.put("dev_sno","");
        pathParamJson.put("limit",10);
        pathParamJson.put("offset",0);
        pathParamJson.put("total",1);
        List<String> userIds = new ArrayList<>();
        userIds.add("02e6d1c4ded41512d0ca3622");
        pathParamJson.put("person_list",userIds);
        pathParamJson.put("person_type","4");
        jsonObject.put("path_params",pathParamJson);
        mqContent.setData(jsonObject);

        System.out.println(JSON.toJSONString(mqContent));
    }
}