From 22c308a8c1317473c7279f7bf866814c64ef36e9 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期日, 22 六月 2025 01:09:54 +0800
Subject: [PATCH] 提交推送服务
---
MessagePushTravel/src/main/java/com/sinata/push/util/echo/NettyChannelMap.java | 19 +------------------
1 files changed, 1 insertions(+), 18 deletions(-)
diff --git a/ZuulQYTTravel/src/main/java/com/sinata/zuul/util/echo/NettyChannelMap.java b/MessagePushTravel/src/main/java/com/sinata/push/util/echo/NettyChannelMap.java
similarity index 79%
rename from ZuulQYTTravel/src/main/java/com/sinata/zuul/util/echo/NettyChannelMap.java
rename to MessagePushTravel/src/main/java/com/sinata/push/util/echo/NettyChannelMap.java
index b27fd8f..acd89f0 100644
--- a/ZuulQYTTravel/src/main/java/com/sinata/zuul/util/echo/NettyChannelMap.java
+++ b/MessagePushTravel/src/main/java/com/sinata/push/util/echo/NettyChannelMap.java
@@ -1,4 +1,4 @@
-package com.sinata.zuul.util.echo;
+package com.sinata.push.util.echo;
import io.netty.channel.ChannelHandlerContext;
@@ -91,18 +91,6 @@
}
- public static synchronized void remove_(ChannelHandlerContext value) {
- Set<String> strings = ctxMap.keySet();
- for(String key : strings){
- ChannelHandlerContext channelHandlerContext = ctxMap.get(key);
- String s = channelHandlerContext.channel().remoteAddress().toString();
- String s1 = value.channel().remoteAddress().toString();
- if(s.equals(s1)){
- channelHandlerContext.close();//关闭通道
- ctxMap.remove(key);
- }
- }
- }
/**
@@ -125,9 +113,4 @@
map.put(key, value);
}
-
-
- public static synchronized void update_(String key, ChannelHandlerContext value) {
- ctxMap.put(key, value);
- }
}
--
Gitblit v1.7.1