From 51d1b5252924a27a55cb60b970a2544f852f46a7 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Wed, 08 Jun 2022 09:58:43 +0800
Subject: [PATCH] 保安员审查文件推送修改，以用户id命名，相同用户文件覆盖，防止产生过多文件
---
src/main/java/org/springblade/modules/webscoket/service/impl/PushMsgServiceImpl.java | 64 ++++++++++++++++----------------
1 files changed, 32 insertions(+), 32 deletions(-)
diff --git a/src/main/java/org/springblade/modules/webscoket/service/impl/PushMsgServiceImpl.java b/src/main/java/org/springblade/modules/webscoket/service/impl/PushMsgServiceImpl.java
index 5f046f4..498ba59 100644
--- a/src/main/java/org/springblade/modules/webscoket/service/impl/PushMsgServiceImpl.java
+++ b/src/main/java/org/springblade/modules/webscoket/service/impl/PushMsgServiceImpl.java
@@ -1,32 +1,32 @@
-package org.springblade.modules.webscoket.service.impl;
-
-import io.netty.channel.Channel;
-import io.netty.channel.group.ChannelGroup;
-import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
-import org.springblade.modules.nettyServer.NettyConfig;
-import org.springblade.modules.webscoket.service.IPushMsgService;
-import org.springframework.stereotype.Service;
-
-/**
- * @author lq
- * @date 2020/4/1 11:20
- */
-@Service
-public class PushMsgServiceImpl implements IPushMsgService {
- @Override
- public void pushMsg(String userId, String msg) {
- Channel channel = NettyConfig.getUserChannelMap().get(userId);
- if (channel != null){
- channel.writeAndFlush(new TextWebSocketFrame(msg));
- }
-
- }
-
- @Override
- public void pushMsg(String msg) {
- ChannelGroup group = NettyConfig.getChannelGroup();
- String name = group.name();
- System.out.println("空间大小："+group.size()+",名字："+name);
- group.writeAndFlush(new TextWebSocketFrame(msg));
- }
-}
+//package org.springblade.modules.webscoket.service.impl;
+//
+//import io.netty.channel.Channel;
+//import io.netty.channel.group.ChannelGroup;
+//import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
+//import org.springblade.modules.nettyServer.NettyConfig;
+//import org.springblade.modules.webscoket.service.IPushMsgService;
+//import org.springframework.stereotype.Service;
+//
+///**
+// * @author lq
+// * @date 2020/4/1 11:20
+// */
+//@Service
+//public class PushMsgServiceImpl implements IPushMsgService {
+// @Override
+// public void pushMsg(String userId, String msg) {
+// Channel channel = NettyConfig.getUserChannelMap().get(userId);
+// if (channel != null){
+// channel.writeAndFlush(new TextWebSocketFrame(msg));
+// }
+//
+// }
+//
+// @Override
+// public void pushMsg(String msg) {
+// ChannelGroup group = NettyConfig.getChannelGroup();
+// String name = group.name();
+// System.out.println("空间大小："+group.size()+",名字："+name);
+// group.writeAndFlush(new TextWebSocketFrame(msg));
+// }
+//}
--
Gitblit v1.9.3