root/longdianningxing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

日志更新

Browse Source
This commit is contained in:
ludj
2023-02-06 18:12:55 +08:00
parent 0429abc1e6
commit 230babf819
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
acs/nladmin-system/src/main/java/org/nl/modules/mnt/websocket/WebSocketServer.java
View File

@@ -77,7 +77,6 @@ public class WebSocketServer {
* @param message 客户端发送过来的消息*/ * @param message 客户端发送过来的消息*/
@OnMessage @OnMessage
public void onMessage(String message, Session session) { public void onMessage(String message, Session session) {
log.info("收到来"+sid+"的信息:"+message);
//群发消息 //群发消息
for (WebSocketServer item : webSocketSet) { for (WebSocketServer item : webSocketSet) {
try { try {
@@ -106,7 +105,6 @@ public class WebSocketServer {
* */ * */
public static void sendInfo(SocketMsg socketMsg,@PathParam("sid") String sid) throws IOException { public static void sendInfo(SocketMsg socketMsg,@PathParam("sid") String sid) throws IOException {
String message = JSONObject.toJSONString(socketMsg); String message = JSONObject.toJSONString(socketMsg);
log.info("推送消息到"+sid+"，推送内容:"+message);
for (WebSocketServer item : webSocketSet) { for (WebSocketServer item : webSocketSet) {
try { try {
//这里可以设定只推送给这个sid的，为null则全部推送 //这里可以设定只推送给这个sid的，为null则全部推送