From 9e5da8899bc21bb5b6b0a3c267108caa00199291 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期日, 19 五月 2024 15:46:08 +0800
Subject: [PATCH] websocket代码整理
---
smart-starter-websocket/src/main/java/com/qianwen/core/websocket/holder/WebSocketSessionHolder.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/smart-starter-websocket/src/main/java/com/qianwen/core/websocket/holder/WebSocketSessionHolder.java b/smart-starter-websocket/src/main/java/com/qianwen/core/websocket/holder/WebSocketSessionHolder.java
index 20b5a03..13b947b 100644
--- a/smart-starter-websocket/src/main/java/com/qianwen/core/websocket/holder/WebSocketSessionHolder.java
+++ b/smart-starter-websocket/src/main/java/com/qianwen/core/websocket/holder/WebSocketSessionHolder.java
@@ -7,9 +7,11 @@
import java.util.concurrent.ConcurrentHashMap;
import java.util.stream.Collectors;
import org.springframework.web.socket.WebSocketSession;
-
+/**
+ * websocketsession瀛樺彇
+ */
public class WebSocketSessionHolder {
- private static final Map<Object, Set<WebSocketSession>> USER_SESSION_MAP = new ConcurrentHashMap();
+ private static final Map<Object, Set<WebSocketSession>> USER_SESSION_MAP = new ConcurrentHashMap<>();
private WebSocketSessionHolder() {
}
@@ -32,9 +34,7 @@
}
public static Collection<WebSocketSession> getSessions() {
- return (Collection) USER_SESSION_MAP.values().stream().flatMap((v0) -> {
- return v0.stream();
- }).collect(Collectors.toList());
+ return USER_SESSION_MAP.values().stream().flatMap(Collection::stream).collect(Collectors.toList());
}
public static Set<Object> SessionKeys() {
--
Gitblit v1.9.3