From a4e99a6a39284643fdf2b04dbe55212e5954973c Mon Sep 17 00:00:00 2001
From: leutu <leutu@qq.com>
Date: 星期一, 20 五月 2024 17:37:25 +0800
Subject: [PATCH] firsh
---
src/main/java/com/skyline/electricity/controller/WebSocketServer.java | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/skyline/electricity/controller/WebSocketServer.java b/src/main/java/com/skyline/electricity/controller/WebSocketServer.java
index 178c1c2..ce00c2c 100644
--- a/src/main/java/com/skyline/electricity/controller/WebSocketServer.java
+++ b/src/main/java/com/skyline/electricity/controller/WebSocketServer.java
@@ -17,12 +17,12 @@
private static Logger log;
private static final AtomicInteger OnlineCount;
private static CopyOnWriteArraySet<Session> SessionSet;
-
+
@PostConstruct
public void init() {
- System.out.println("websocket 鍔犺浇");
+ // System.out.println("websocket 鍔犺浇");
}
-
+
@OnOpen
public void onOpen(final Session session) {
WebSocketServer.SessionSet.add(session);
@@ -30,26 +30,26 @@
WebSocketServer.log.info("鏈夎繛鎺ュ姞鍏ワ紝褰撳墠杩炴帴鏁颁负锛歿}", (Object)cnt);
SendMessage(session, "杩炴帴鎴愬姛");
}
-
+
@OnClose
public void onClose(final Session session) {
WebSocketServer.SessionSet.remove(session);
final int cnt = WebSocketServer.OnlineCount.decrementAndGet();
WebSocketServer.log.info("鏈夎繛鎺ュ叧闂紝褰撳墠杩炴帴鏁颁负锛歿}", (Object)cnt);
}
-
+
@OnMessage
public void onMessage(final String message, final Session session) {
WebSocketServer.log.info("鏉ヨ嚜瀹㈡埛绔殑娑堟伅锛歿}", (Object)message);
SendMessage(session, "鏀跺埌娑堟伅锛屾秷鎭唴瀹癸細" + message);
}
-
+
@OnError
public void onError(final Session session, final Throwable error) {
WebSocketServer.log.error("鍙戠敓閿欒锛歿}锛孲ession ID锛� {}", (Object)error.getMessage(), (Object)session.getId());
error.printStackTrace();
}
-
+
public static void SendMessage(final Session session, final String message) {
try {
session.getBasicRemote().sendText(String.format("%s", message));
@@ -59,7 +59,7 @@
e.printStackTrace();
}
}
-
+
public static void BroadCastInfo(final String message) throws IOException {
for (final Session session : WebSocketServer.SessionSet) {
@@ -68,7 +68,7 @@
}
}
}
-
+
public static void SendMessage(final String message, final String sessionId) throws IOException {
Session session = null;
@@ -85,7 +85,7 @@
WebSocketServer.log.warn("娌℃湁鎵惧埌浣犳寚瀹欼D鐨勪細璇濓細{}", (Object)sessionId);
}
}
-
+
static {
WebSocketServer.log = LoggerFactory.getLogger((Class)WebSocketServer.class);
OnlineCount = new AtomicInteger(0);
--
Gitblit v1.9.3