From c35b8fcda79a017e7aca156f0ee2e24e3dd5416e Mon Sep 17 00:00:00 2001 From: qi Date: Mon, 16 Mar 2020 17:20:18 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=B3=A8=E9=87=8A=EF=BC=8C?= =?UTF-8?q?=E6=96=B9=E4=BE=BF=E7=90=86=E8=A7=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lanproxy/client/ClientChannelMannager.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/proxy-client/src/main/java/org/fengfei/lanproxy/client/ClientChannelMannager.java b/proxy-client/src/main/java/org/fengfei/lanproxy/client/ClientChannelMannager.java index c6859d7..73b43dc 100644 --- a/proxy-client/src/main/java/org/fengfei/lanproxy/client/ClientChannelMannager.java +++ b/proxy-client/src/main/java/org/fengfei/lanproxy/client/ClientChannelMannager.java @@ -28,12 +28,14 @@ import io.netty.util.AttributeKey; */ public class ClientChannelMannager { - private static Logger logger = LoggerFactory.getLogger(ClientChannelMannager.class); + private static Logger LOGGER = LoggerFactory.getLogger(ClientChannelMannager.class); private static final AttributeKey USER_CHANNEL_WRITEABLE = AttributeKey.newInstance("user_channel_writeable"); private static final AttributeKey CLIENT_CHANNEL_WRITEABLE = AttributeKey.newInstance("client_channel_writeable"); - + /** + * 最大连接数 + */ private static final int MAX_POOL_SIZE = 100; private static Map realServerChannels = new ConcurrentHashMap(); @@ -58,7 +60,7 @@ public class ClientChannelMannager { if (future.isSuccess()) { borrowListener.success(future.channel()); } else { - logger.warn("connect proxy server failed", future.cause()); + LOGGER.warn("connect proxy server failed", future.cause()); borrowListener.error(future.cause()); } } @@ -72,7 +74,7 @@ public class ClientChannelMannager { proxyChanel.config().setOption(ChannelOption.AUTO_READ, true); proxyChanel.attr(Constants.NEXT_CHANNEL).set(null); proxyChannelPool.offer(proxyChanel); - logger.debug("return ProxyChanel to the pool, channel is {}, pool size is {} ", proxyChanel, proxyChannelPool.size()); + LOGGER.debug("return ProxyChanel to the pool, channel is {}, pool size is {} ", proxyChanel, proxyChannelPool.size()); } } @@ -113,7 +115,7 @@ public class ClientChannelMannager { } public static void clearRealServerChannels() { - logger.warn("channel closed, clear real server channels"); + LOGGER.warn("channel closed, clear real server channels"); Iterator> ite = realServerChannels.entrySet().iterator(); while (ite.hasNext()) {