THENG
/
a-tuoheng-device
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改共享组名称动态生成

This commit is contained in:
孙小云 2026-03-26 11:19:10 +08:00
parent eb76ef35e0
commit 26e6b95d6b
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/ruoyi/device/service/impl/DjiService.java
View File

@ -29,6 +29,7 @@ import org.springframework.util.CollectionUtils;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
import java.util.UUID;
@Service @Service
@Slf4j @Slf4j
@ -73,7 +74,7 @@ public class DjiService {
.autoReconnect(mqttProperties.getAutoReconnect()) .autoReconnect(mqttProperties.getAutoReconnect())
.cleanSession(mqttProperties.getCleanSession()) .cleanSession(mqttProperties.getCleanSession())
.useSharedSubscription(true) .useSharedSubscription(true)
.sharedGroupName("dji-server-group") .sharedGroupName("dji-server-group" + UUID.randomUUID().toString())
.build(); .build();
// 创建客户端 // 创建客户端

3
src/main/java/com/ruoyi/device/service/impl/TuohengService.java
View File

@ -37,6 +37,7 @@ import org.springframework.stereotype.Service;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.UUID;
@Service @Service
@Slf4j @Slf4j
@ -97,7 +98,7 @@ public class TuohengService {
.autoReconnect(mqttProperties.getAutoReconnect()) .autoReconnect(mqttProperties.getAutoReconnect())
.cleanSession(mqttProperties.getCleanSession()) .cleanSession(mqttProperties.getCleanSession())
.useSharedSubscription(true) .useSharedSubscription(true)
.sharedGroupName("tuoheng-server-group") .sharedGroupName("tuoheng-server-group" + UUID.randomUUID().toString())
.build(); .build();
clientManager.initClient(config); clientManager.initClient(config);