From eabac85e4edbd131ee87e781d0f6bd7b89ce3ced Mon Sep 17 00:00:00 2001
From: Lemon <ziao4956@gmail.com>
Date: Tue, 22 Jul 2025 17:23:02 +0800
Subject: [PATCH] =?UTF-8?q?update=20=20netty=E4=BC=98=E5=8C=96=E4=B8=9A?=
 =?UTF-8?q?=E5=8A=A1=E7=BA=BF=E7=A8=8B=E6=B1=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../server/yunkuaichong/NettyServerChannelInitializer.java  | 5 ++++-
 .../netty/server/yunkuaichong/NettyServerHandler.java       | 6 +++---
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerChannelInitializer.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerChannelInitializer.java
index cb713237d..770820279 100644
--- a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerChannelInitializer.java
+++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerChannelInitializer.java
@@ -16,6 +16,9 @@ import java.util.concurrent.TimeUnit;
 @Component
 public class NettyServerChannelInitializer extends ChannelInitializer<SocketChannel> {
 
+	@Resource
+	private NettyServerHandler nettyServerHandler;
+
 	// 引入业务线程池
 	final EventExecutorGroup businessGroup = new DefaultEventExecutorGroup(16);
 
@@ -31,7 +34,7 @@ public class NettyServerChannelInitializer extends ChannelInitializer<SocketChan
 		// 读超时时间设置为30s，0表示不监控
 		pipeline.addLast(new IdleStateHandler(30, 0, 0, TimeUnit.SECONDS));
 		// pipeline.addLast("handler", nettyServerHandler);
-		pipeline.addLast(businessGroup,  new NettyServerHandler()); // 消息先进入业务线程池
+		pipeline.addLast(businessGroup, nettyServerHandler); // 消息先进入业务线程池
 		pipeline.addLast(new EchoServerHandler());
 	}
 
diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java
index 724c37983..f68c01d81 100644
--- a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java
+++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java
@@ -34,8 +34,8 @@ import java.util.concurrent.ConcurrentHashMap;
 @Component
 public class NettyServerHandler extends ChannelInboundHandlerAdapter {
 
-	// @Resource
-	// private YKCBusinessService ykcService;
+	@Resource
+	private YKCBusinessService ykcService;
 
 	/**
 	 * 管理一个全局map，保存连接进服务端的通道数量
@@ -44,7 +44,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
 
 	protected static final List<String> notPrintFrameTypeList = Lists.newArrayList(); // "0x03"
 
-	private final YKCBusinessService ykcService = new YKCBusinessServiceImpl();
+	// private final YKCBusinessService ykcService = new YKCBusinessServiceImpl();
 
 	/**
 	 * 有客户端连接服务器会触发此函数