增加：喊话器

liusuyi

2024-11-01 c5551fc0fb643f85aafeb6827687af4df88bd1f7

 ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java

@@ -1,8 +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.HeartbeatCommand;
import com.ard.tianyu.netty.command.BaseCmd;
import com.ard.tianyu.service.ITyService;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
@@ -19,7 +18,7 @@
@Component
@Slf4j
@ChannelHandler.Sharable
public class ClientHandler extends SimpleChannelInboundHandler<BaseCommand> {
public class ClientHandler extends SimpleChannelInboundHandler<BaseCmd> {

    @Resource
    private ITyService tyService;
@@ -28,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