From 8f3526aee283ccb4478809f22a5c6b75000bd0de Mon Sep 17 00:00:00 2001
From: 叶松 <2217086471@qq.com>
Date: 星期二, 17 十月 2023 14:54:30 +0800
Subject: [PATCH] Merge branch 'master' of http://111.30.93.211:10101/r/supipe
---
hd/pipe/StaffManage/src/main/java/com/thhy/staff/utils/MqUtils.java | 16 +++++++++-------
1 files changed, 9 insertions(+), 7 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..f975e44 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
@@ -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);
--
Gitblit v1.9.3