Netty（7）netty提供调试的工具类：EmbeddedChannel

今天药忘吃喽~ 2024-04-08 10:40 32阅读 0赞

可以使用这个工具类对Pipeline直接进行调试，而不需要启动客户端去调试

## 模拟入站操作 ##

import io.netty.buffer.ByteBuf;
    import io.netty.buffer.ByteBufAllocator;
    import io.netty.channel.ChannelHandlerContext;
    import io.netty.channel.ChannelInboundHandlerAdapter;
    import io.netty.channel.ChannelOutboundHandlerAdapter;
    import io.netty.channel.ChannelPromise;
    import io.netty.channel.embedded.EmbeddedChannel;
    import io.netty.handler.logging.LogLevel;
    import io.netty.handler.logging.LoggingHandler;
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.extern.slf4j.Slf4j;
    
    import java.nio.charset.Charset;
    
    @Slf4j
    public class TestEmbeddedChannel {
        
        public static void main(String[] args) {
        
            ChannelInboundHandlerAdapter h1 = new ChannelInboundHandlerAdapter() {
        
                @Override
                public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        
                    log.debug("1");
                    super.channelRead(ctx, msg);
                }
            };
            ChannelInboundHandlerAdapter h2 = new ChannelInboundHandlerAdapter() {
        
                @Override
                public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        
                    log.debug("2");
                    super.channelRead(ctx, msg);
                }
            };
            ChannelOutboundHandlerAdapter h3 = new ChannelOutboundHandlerAdapter() {
        
                @Override
                public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        
                    log.debug("3");
                    super.write(ctx, msg, promise);
                }
            };
            ChannelOutboundHandlerAdapter h4 = new ChannelOutboundHandlerAdapter() {
        
                @Override
                public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        
                    log.debug("4");
                    super.write(ctx, msg, promise);
                }
            };
            EmbeddedChannel channel = new EmbeddedChannel(h1, h2, h3, h4);
            // 模拟入站操作
            channel.writeInbound(ByteBufAllocator.DEFAULT.buffer().writeBytes("abc?in".getBytes()));
    
        }
    }

运行结果

22:56:34 [DEBUG] [main] c.i.n.c.TestEmbeddedChannel - 1
    22:56:34 [DEBUG] [main] c.i.n.c.TestEmbeddedChannel - 2

## 模拟出站操作 ##

import io.netty.buffer.ByteBuf;
    import io.netty.buffer.ByteBufAllocator;
    import io.netty.channel.ChannelHandlerContext;
    import io.netty.channel.ChannelInboundHandlerAdapter;
    import io.netty.channel.ChannelOutboundHandlerAdapter;
    import io.netty.channel.ChannelPromise;
    import io.netty.channel.embedded.EmbeddedChannel;
    import io.netty.handler.logging.LogLevel;
    import io.netty.handler.logging.LoggingHandler;
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.extern.slf4j.Slf4j;
    
    import java.nio.charset.Charset;
    
    @Slf4j
    public class TestEmbeddedChannel {
        
        public static void main(String[] args) {
        
            ChannelInboundHandlerAdapter h1 = new ChannelInboundHandlerAdapter() {
        
                @Override
                public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        
                    log.debug("1");
                    super.channelRead(ctx, msg);
                }
            };
            ChannelInboundHandlerAdapter h2 = new ChannelInboundHandlerAdapter() {
        
                @Override
                public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        
                    log.debug("2");
                    super.channelRead(ctx, msg);
                }
            };
            ChannelOutboundHandlerAdapter h3 = new ChannelOutboundHandlerAdapter() {
        
                @Override
                public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        
                    log.debug("3");
                    super.write(ctx, msg, promise);
                }
            };
            ChannelOutboundHandlerAdapter h4 = new ChannelOutboundHandlerAdapter() {
        
                @Override
                public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        
                    log.debug("4");
                    super.write(ctx, msg, promise);
                }
            };
            EmbeddedChannel channel = new EmbeddedChannel(h1, h2, h3, h4);
            // 模拟出站操作
            channel.writeOutbound(ByteBufAllocator.DEFAULT.buffer().writeBytes("abc?Out".getBytes()));
    
        }
    }

运行结果

22:57:25 [DEBUG] [main] c.i.n.c.TestEmbeddedChannel - 4
    22:57:25 [DEBUG] [main] c.i.n.c.TestEmbeddedChannel - 3