From e5cd5597aad68f294fcfff465e0a312713804c0d Mon Sep 17 00:00:00 2001
From: shishuaikang <280848880@qq.com>
Date: 星期二, 12 十二月 2023 13:40:25 +0800
Subject: [PATCH] h5大屏伴和站样式修改
---
hd/pipe/StaffManage/src/main/java/com/thhy/staff/utils/MqUtils.java | 58 ++++++++++++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 50 insertions(+), 8 deletions(-)
diff --git a/hd/pipe/StaffManage/src/main/java/com/thhy/staff/utils/MqUtils.java b/hd/pipe/StaffManage/src/main/java/com/thhy/staff/utils/MqUtils.java
index 31f6ae0..0bc6aee 100644
--- a/hd/pipe/StaffManage/src/main/java/com/thhy/staff/utils/MqUtils.java
+++ b/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));
+ }
}
--
Gitblit v1.9.3