From 0eee8acf970b2a656b558b5e903c7bda4fb27d6a Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期一, 12 十二月 2022 20:45:56 +0800
Subject: [PATCH] 1
---
src/main/java/com/lf/server/service/all/WebSocketService.java | 20 +++++++++-----------
1 files changed, 9 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/lf/server/service/all/WebSocketService.java b/src/main/java/com/lf/server/service/all/WebSocketService.java
index 88f792c..82d0338 100644
--- a/src/main/java/com/lf/server/service/all/WebSocketService.java
+++ b/src/main/java/com/lf/server/service/all/WebSocketService.java
@@ -23,21 +23,21 @@
System.out.println("websocket 鍔犺浇");
}
- private static Logger log = LoggerFactory.getLogger(WebSocketService.class);
+ private final static Logger log = LoggerFactory.getLogger(WebSocketService.class);
private static final AtomicInteger ONLINE_COUNT = new AtomicInteger(0);
/**
* 鐢ㄦ潵瀛樻斁姣忎釜瀹㈡埛绔搴旂殑Session瀵硅薄锛堢嚎绋嬪畨鍏⊿et锛�
*/
- private static CopyOnWriteArraySet<Session> SessionSet = new CopyOnWriteArraySet<Session>();
+ private final static CopyOnWriteArraySet<Session> SESSION_SET = new CopyOnWriteArraySet<Session>();
/**
* 杩炴帴寤虹珛鎴愬姛璋冪敤鐨勬柟娉�
*/
@OnOpen
public void onOpen(Session session) {
- SessionSet.add(session);
+ SESSION_SET.add(session);
int cnt = ONLINE_COUNT.incrementAndGet();
log.info("鏈夎繛鎺ュ姞鍏ワ紝褰撳墠杩炴帴鏁颁负锛歿}", cnt);
@@ -49,7 +49,7 @@
*/
@OnClose
public void onClose(Session session) {
- SessionSet.remove(session);
+ SESSION_SET.remove(session);
int cnt = ONLINE_COUNT.decrementAndGet();
log.info("鏈夎繛鎺ュ叧闂紝褰撳墠杩炴帴鏁颁负锛歿}", cnt);
@@ -75,7 +75,6 @@
@OnError
public void onError(Session session, Throwable error) {
log.error("鍙戠敓閿欒锛歿}锛孲ession ID锛� {}", error.getMessage(), session.getId());
- error.printStackTrace();
}
/**
@@ -87,9 +86,8 @@
public static void sendMessage(Session session, String message) {
try {
session.getBasicRemote().sendText(String.format("%s", message));
- } catch (IOException e) {
- log.error("鍙戦�佹秷鎭嚭閿欙細{}", e.getMessage());
- e.printStackTrace();
+ } catch (Exception ex) {
+ log.error("鍙戦�佹秷鎭嚭閿欙細{}", ex.getMessage());
}
}
@@ -100,7 +98,7 @@
* @throws IOException
*/
public static void broadCastInfo(String message) throws IOException {
- for (Session session : SessionSet) {
+ for (Session session : SESSION_SET) {
if (session.isOpen()) {
sendMessage(session, message);
}
@@ -116,7 +114,7 @@
*/
public static void sendMessage(String message, String sessionId) throws IOException {
Session session = null;
- for (Session s : SessionSet) {
+ for (Session s : SESSION_SET) {
if (s.getId().equals(sessionId)) {
session = s;
break;
@@ -126,7 +124,7 @@
if (session != null) {
sendMessage(session, message);
} else {
- log.warn("娌℃湁鎵惧埌浣犳寚瀹欼D鐨勪細璇濓細{}", sessionId);
+ log.info("娌℃湁鎵惧埌浣犳寚瀹欼D鐨勪細璇濓細{}", sessionId);
}
}
}
--
Gitblit v1.9.3