From b821735241678a21ddc033aba04ebaf7ce65a3d2 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Thu, 31 Oct 2024 09:49:33 +0800
Subject: [PATCH] 优化结构

---
 ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java |    8 ++++----
 1 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java b/ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java
index f4b544a..35e8ad7 100644
--- a/ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java
+++ b/ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java
@@ -1,7 +1,7 @@
 package com.ard.tianyu.netty.handler;
 
 import com.ard.tianyu.netty.TyNettyTcpClient;
-import com.ard.tianyu.netty.command.BaseCommand;
+import com.ard.tianyu.netty.command.BaseCmd;
 import com.ard.tianyu.service.ITyService;
 import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;
@@ -18,7 +18,7 @@
 @Component
 @Slf4j
 @ChannelHandler.Sharable
-public class ClientHandler extends SimpleChannelInboundHandler<BaseCommand> {
+public class ClientHandler extends SimpleChannelInboundHandler<BaseCmd> {
 
     @Resource
     private ITyService tyService;
@@ -27,11 +27,11 @@
     private TyNettyTcpClient tyNettyTcpClient;
 
     @Override
-    public void channelRead0(ChannelHandlerContext ctx, BaseCommand command) {
+    public void channelRead0(ChannelHandlerContext ctx, BaseCmd command) {
         InetSocketAddress ipSocket = (InetSocketAddress) ctx.channel().remoteAddress();
         String host = ipSocket.getHostString();
         int port = ipSocket.getPort();
-        tyService.processMessage(host + ":" + port, command);
+        tyService.processReplyMessage(host + ":" + port, command);
     }
 
     @Override

--
Gitblit v1.9.3