diff --git a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/Constants.java b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/Constants.java index 59c5175e..472f8ce9 100644 --- a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/Constants.java +++ b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/Constants.java @@ -25,6 +25,8 @@ package org.dromara.neutrinoproxy.core; import io.netty.channel.Channel; import io.netty.util.AttributeKey; +import java.net.InetSocketAddress; + /** * * @author: aoshiguchen @@ -45,6 +47,7 @@ public interface Constants { // 临时解决 udp channel被close的问题 AttributeKey IS_UDP_KEY = AttributeKey.newInstance("isUdp"); + AttributeKey SENDER = AttributeKey.newInstance("sender"); int HEADER_SIZE = 4; diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/UdpVisitorChannelHandler.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/UdpVisitorChannelHandler.java index e3f07111..07abc014 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/UdpVisitorChannelHandler.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/UdpVisitorChannelHandler.java @@ -41,6 +41,8 @@ public class UdpVisitorChannelHandler extends SimpleChannelInboundHandler