diff --git a/neutrino-proxy-client/src/main/java/fun/asgc/neutrino/proxy/client/core/RealServerChannelHandler.java b/neutrino-proxy-client/src/main/java/fun/asgc/neutrino/proxy/client/core/RealServerChannelHandler.java index da9847f6..24ef9aa4 100755 --- a/neutrino-proxy-client/src/main/java/fun/asgc/neutrino/proxy/client/core/RealServerChannelHandler.java +++ b/neutrino-proxy-client/src/main/java/fun/asgc/neutrino/proxy/client/core/RealServerChannelHandler.java @@ -49,7 +49,7 @@ public class RealServerChannelHandler extends SimpleChannelInboundHandler } else { byte[] bytes = new byte[buf.readableBytes()]; buf.readBytes(bytes); - String userId = ProxyUtil.getVisitorChannelUserId(visitorChannel); - proxyChannel.writeAndFlush(ProxyMessage.buildTransferMessage(userId, bytes)); + String visitorId = ProxyUtil.getVisitorIdByChannel(visitorChannel); + proxyChannel.writeAndFlush(ProxyMessage.buildTransferMessage(visitorId, bytes)); } } @@ -104,7 +104,7 @@ public class VisitorChannelHandler extends SimpleChannelInboundHandler } else { // 用户连接断开,从控制连接中移除 - String userId = ProxyUtil.getVisitorChannelUserId(userChannel); + String userId = ProxyUtil.getVisitorIdByChannel(userChannel); ProxyUtil.removeVisitorChannelFromCmdChannel(cmdChannel, userId); Channel proxyChannel = userChannel.attr(Constants.NEXT_CHANNEL).get(); diff --git a/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/util/ProxyUtil.java b/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/util/ProxyUtil.java index 738f8b76..ce1fc2b5 100644 --- a/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/util/ProxyUtil.java +++ b/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/util/ProxyUtil.java @@ -217,12 +217,12 @@ public class ProxyUtil { } /** - * 获取用户编号 + * 获取访问者ID * * @param visitorChannel * @return */ - public static String getVisitorChannelUserId(Channel visitorChannel) { + public static String getVisitorIdByChannel(Channel visitorChannel) { if (null == visitorChannel || null == getAttachInfo(visitorChannel)) { return null; }