From de31e91aa2f38a717f2d4640a3197580ec1807a7 Mon Sep 17 00:00:00 2001
From: 钟日健 <5689795+arsn@user.noreply.gitee.com>
Date: Thu, 19 May 2022 11:23:51 +0800
Subject: [PATCH] 关闭websckot
---
src/main/java/org/springblade/modules/webscoket/ChannelSupervise.java | 76 +++++++++++++++++++-------------------
1 files changed, 38 insertions(+), 38 deletions(-)
diff --git a/src/main/java/org/springblade/modules/webscoket/ChannelSupervise.java b/src/main/java/org/springblade/modules/webscoket/ChannelSupervise.java
index 392ea34..866abc1 100644
--- a/src/main/java/org/springblade/modules/webscoket/ChannelSupervise.java
+++ b/src/main/java/org/springblade/modules/webscoket/ChannelSupervise.java
@@ -1,38 +1,38 @@
-package org.springblade.modules.webscoket;
-import io.netty.channel.Channel;
-import io.netty.channel.ChannelId;
-import io.netty.channel.group.ChannelGroup;
-import io.netty.channel.group.DefaultChannelGroup;
-import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
-import io.netty.util.concurrent.GlobalEventExecutor;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ConcurrentMap;
-
-public class ChannelSupervise {
- private static ChannelGroup GlobalGroup=new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
- private static ConcurrentMap<String, ChannelId> ChannelMap=new ConcurrentHashMap();
- private static Map<String, String> map = new HashMap<String, String>();;
- public static void addChannel(Channel channel, String name){
- GlobalGroup.add(channel);
- ChannelMap.put(channel.id().asShortText(),channel.id());
- map.put(channel.id().asShortText(),name);
- }
- public static void removeChannel(Channel channel){
- GlobalGroup.remove(channel);
- ChannelMap.remove(channel.id().asShortText());
- map.remove(channel.id().asShortText());
- }
- public static Channel findChannel(String id){
- return GlobalGroup.find(ChannelMap.get(id));
- }
- public static String findName(String id){
- return map.get(id);
- }
- public static void send2All(TextWebSocketFrame tws){
- GlobalGroup.writeAndFlush(tws);
- }
-
-}
+//package org.springblade.modules.webscoket;
+//import io.netty.channel.Channel;
+//import io.netty.channel.ChannelId;
+//import io.netty.channel.group.ChannelGroup;
+//import io.netty.channel.group.DefaultChannelGroup;
+//import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
+//import io.netty.util.concurrent.GlobalEventExecutor;
+//
+//import java.util.HashMap;
+//import java.util.Map;
+//import java.util.concurrent.ConcurrentHashMap;
+//import java.util.concurrent.ConcurrentMap;
+//
+//public class ChannelSupervise {
+// private static ChannelGroup GlobalGroup=new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
+// private static ConcurrentMap<String, ChannelId> ChannelMap=new ConcurrentHashMap();
+// private static Map<String, String> map = new HashMap<String, String>();;
+// public static void addChannel(Channel channel, String name){
+// GlobalGroup.add(channel);
+// ChannelMap.put(channel.id().asShortText(),channel.id());
+// map.put(channel.id().asShortText(),name);
+// }
+// public static void removeChannel(Channel channel){
+// GlobalGroup.remove(channel);
+// ChannelMap.remove(channel.id().asShortText());
+// map.remove(channel.id().asShortText());
+// }
+// public static Channel findChannel(String id){
+// return GlobalGroup.find(ChannelMap.get(id));
+// }
+// public static String findName(String id){
+// return map.get(id);
+// }
+// public static void send2All(TextWebSocketFrame tws){
+// GlobalGroup.writeAndFlush(tws);
+// }
+//
+//}
--
Gitblit v1.9.3