From de7cddcd9a5597ac281fbd619f4f0bba09772386 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Tue, 11 Mar 2025 16:19:35 +0800
Subject: [PATCH] 优化遥测、信道治理、状态 websocket
---
ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStreamManager.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStreamManager.java b/ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStreamManager.java
index 8f2183d..7e21147 100644
--- a/ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStreamManager.java
+++ b/ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStreamManager.java
@@ -42,7 +42,7 @@
* @param boxSn 盒子序列号
* @param userId 用户ID
*/
- public void startPullStream(String boxSn, Long userId) {
+ public void subscribe(String boxSn, Long userId) {
String webrtcUrl = "";
STREAM_USER_MAP.computeIfAbsent(boxSn, k -> ConcurrentHashMap.newKeySet()).add(userId);
//不管谁拉流都判断流媒体中是否存在
@@ -68,7 +68,7 @@
* @param boxSn 盒子序列号
* @param userId 用户ID
*/
- public void stopPullStream(String boxSn, Long userId) {
+ public void unsubscribe(String boxSn, Long userId) {
synchronized (this) {
Set<Long> users = STREAM_USER_MAP.get(boxSn);
if (users == null) {
@@ -102,7 +102,7 @@
*/
public void stopAllPullStreamByUser(Long userId) {
synchronized (this) {
- STREAM_USER_MAP.forEach((boxSn, users) -> stopPullStream(boxSn, userId));
+ STREAM_USER_MAP.forEach((boxSn, users) -> unsubscribe(boxSn, userId));
}
}
--
Gitblit v1.9.3