diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/base/proxy/ProxyConfiguration.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/base/proxy/ProxyConfiguration.java index 3188e182..0976afa6 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/base/proxy/ProxyConfiguration.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/base/proxy/ProxyConfiguration.java @@ -77,17 +77,17 @@ public class ProxyConfiguration implements LifecycleBean { } @Bean("udpServerBossGroup") - private NioEventLoopGroup udpBossGroup(@Inject ProxyConfig proxyConfig) { + private NioEventLoopGroup udpServerBossGroup(@Inject ProxyConfig proxyConfig) { return new NioEventLoopGroup(proxyConfig.getServer().getUdp().getBossThreadCount()); } @Bean("udpServerWorkerGroup") - private NioEventLoopGroup udpWorkerGroup(@Inject ProxyConfig proxyConfig) { + private NioEventLoopGroup udpServerWorkerGroup(@Inject ProxyConfig proxyConfig) { return new NioEventLoopGroup(proxyConfig.getServer().getUdp().getWorkThreadCount()); } @Bean("udpServerBootstrap") - public Bootstrap udpBootstrap(@Inject("udpServerBossGroup") NioEventLoopGroup udpServerBossGroup, + public Bootstrap udpServerBootstrap(@Inject("udpServerBossGroup") NioEventLoopGroup udpServerBossGroup, @Inject("udpServerWorkerGroup") NioEventLoopGroup udpServerWorkerGroup, @Inject ProxyConfig proxyConfig) { Bootstrap bootstrap = new Bootstrap(); 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 26492d10..6c07bf00 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 @@ -4,6 +4,8 @@ import io.netty.channel.ChannelHandlerContext; import io.netty.channel.SimpleChannelInboundHandler; import io.netty.channel.socket.DatagramPacket; +import java.nio.charset.StandardCharsets; + /** * @author: aoshiguchen * @date: 2023/9/16 @@ -12,7 +14,7 @@ public class UdpVisitorChannelHandler extends SimpleChannelInboundHandler