netty使用EmbeddedChannel对channel
admin
2023-01-25 10:42:56
0次

一种特殊的Channel实现----EmbeddedChannel，它是Netty专门为改进针对ChannelHandler的单元测试而提供的。

名称 职责
writeInbound 将入站消息写到EmbeddedChannel中。如果可以通过readInbound方法从EmbeddedChannel中读取数据，则返回true
readInbound 从EmbeddedChannel中读取入站消息。任何返回东西都经过整个ChannelPipeline。如果没有任何可供读取的，则返回null
writeOutbound 将出站消息写到EmbeddedChannel中，如果现在可以通过readOutbound从EmbeddedChannel中读取到东西，则返回true
readOutbound 从EmbeddedChannel中读取出站消息。任何返回东西都经过整个ChannelPipeline。如果没有任何可供读取的，则返回null
finish 将EmbeddedChannel标记为完成，如果有可读取的入站或出站数据，则返回true。这个方法还将会调用EmbeddedChannel上的close方法

测试入站消息

public class FixedLengthFrameDecoder extends ByteToMessageDecoder {
    private final int frameLength;

    public FixedLengthFrameDecoder(int frameLength) {
        if (frameLength <= 0) {
            throw new IllegalArgumentException("frameLength must be positive integer: " + frameLength);
        }
        this.frameLength = frameLength;
    }

    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List out) throws Exception {
        while (in.readableBytes() >= frameLength) {
            ByteBuf buf = in.readBytes(frameLength);
            out.add(buf);
        }
    }
}

public class FixedLengthFrameDecoderTest {
    @Test
    public void testFramesDecoded() {
        ByteBuf buf = Unpooled.buffer();
        for (int i = 0; i < 9; i++) {
            buf.writeByte(i);
        }
        ByteBuf input = buf.duplicate();
        EmbeddedChannel channel = new EmbeddedChannel(new FixedLengthFrameDecoder(3));
        Assert.assertTrue(channel.writeInbound(input.retain()));
        Assert.assertTrue(channel.finish());

        ByteBuf read = channel.readInbound();
        Assert.assertEquals(buf.readSlice(3), read);
        read.release();

        read = channel.readInbound();
        Assert.assertEquals(buf.readSlice(3), read);
        read.release();

        read = channel.readInbound();
        Assert.assertEquals(buf.readSlice(3), read);
        read.release();

        Assert.assertNull(channel.readInbound());
        buf.release();
    }

    @Test
    public void testFramesDecoded2() {
        ByteBuf buf = Unpooled.buffer();
        for (int i = 0; i < 9; i++) {
            buf.writeByte(i);
        }
        ByteBuf input = buf.duplicate();
        EmbeddedChannel channel = new EmbeddedChannel(new FixedLengthFrameDecoder(3));
        Assert.assertFalse(channel.writeInbound(input.readBytes(2)));
        Assert.assertTrue(channel.writeInbound(input.readBytes(7)));
        Assert.assertTrue(channel.finish());
        ByteBuf read = channel.readInbound();
        Assert.assertEquals(buf.readSlice(3), read);
        read.release();

        read = channel.readInbound();
        Assert.assertEquals(buf.readSlice(3), read);
        read.release();

        read = channel.readInbound();
        Assert.assertEquals(buf.readSlice(3), read);
        read.release();

        Assert.assertNull(channel.readInbound());
        buf.release();
    }
}


测试出站消息


public class AbsIntegerEncoder extends MessageToMessageEncoder {
    @Override
    protected void encode(ChannelHandlerContext channelHandlerContext, ByteBuf in, List out) throws Exception {
        while (in.readableBytes() >= 4) {
            int value = Math.abs(in.readInt());
            out.add(value);
        }
    }
}

public class AbsIntegerEncoderTest {
    @Test
    public void testEncoded() {
        ByteBuf buf = Unpooled.buffer();
        for (int i = 0; i < 10; i++) {
            buf.writeInt(i * -1);
        }
        EmbeddedChannel channel = new EmbeddedChannel(new AbsIntegerEncoder());
        Assert.assertTrue(channel.writeOutbound(buf));
        Assert.assertTrue(channel.finish());

        for (int i = 0; i < 10; i++) {
            Assert.assertEquals(Integer.valueOf(i), channel.readOutbound());
        }
        Assert.assertNull(channel.readOutbound());
    }
}


测试异常处理


public class FrameChunkDecoder extends ByteToMessageDecoder {
    private final int maxFrameSize;

    public FrameChunkDecoder(int maxFrameSize) {
        this.maxFrameSize = maxFrameSize;
    }

    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List out) throws Exception {
        int readableBytes = in.readableBytes();
        if (readableBytes > maxFrameSize) {
            in.clear();
            throw new TooLongFrameException();
        }
        ByteBuf buf = in.readBytes(readableBytes);
        out.add(buf);
    }
}

public class FrameChunkDecoderTest {
    @Test
    public void testFramesDecoded() {
        ByteBuf buf = Unpooled.buffer();
        for (int i = 0; i < 9; i++) {
            buf.writeByte(i);
        }
        ByteBuf input = buf.duplicate();
        EmbeddedChannel channel = new EmbeddedChannel(new FrameChunkDecoder(3));
        Assert.assertTrue(channel.writeInbound(input.readBytes(2)));
        try {
            channel.writeInbound(input.readBytes(4));
            Assert.fail();
        } catch (TooLongFrameException e) {

        }
        Assert.assertTrue(channel.writeInbound(input.readBytes(3)));
        Assert.assertTrue(channel.finish());

        ByteBuf read = channel.readInbound();
        Assert.assertEquals(buf.readSlice(2), read);
        read.release();

        read = channel.readInbound();
        Assert.assertEquals(buf.skipBytes(4).readSlice(3), read);
        read.release();
        buf.release();
    }
}
                
            
            
            

                
                            

            

                

                    上一篇：ESXI使用记录---安装vSphere（VCSA）

                

                

                    下一篇：OpenResty--------核心执行阶段篇                

            

            
            

                
                
相关内容

                
            

            

            
            

                

            



        
        
    
    

    
    

        
        

            
            

                
                

                    
                    

                        
                        热门资讯
                        
                    

                    
                

                
            

            
            
            


                                
                

                    
                    

                        

                    

                    
                    
                    

                        德国总理：美国正在被伊朗羞辱
                        德国之声4月27日报道，德国总理默茨在访问一所学校时表示，在当前的持续冲突中，伊朗领导层正试图羞辱美...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        理响中国｜“长”歌以行，风云激...
                        光阴如梭，东方潮阔。这里是中国的长三角，世界的长三角。无论过去、现在还是未来，这片土地都因时代而生，...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        白宫：特朗普及其国安团队开会讨...
                        新华社华盛顿4月27日电 美国白宫新闻秘书莱维特27日在记者会上证实，总统特朗普及其国家安全团队当天...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        人民日报刊文：日本放开杀伤性武...
                        日本放开杀伤性武器出口推高地缘冲突风险（国际论坛）常思纯《人民日报》（2026年04月28日 第 0...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        医疗保障法草案二审：明确生育保...
                        满足多样化健康保障需求本报记者 彭 波4月27日，医疗保障法草案二审稿提请十四届全国人大常委会第二十...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        天津一景区发生自转旋翼机事故1...
                        澎湃新闻记者 吕新文中国民用航空华北地区管理局4月22日公布《豪客通航“10•1”天津长芦汉盐旅游区...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        卡塔尔埃米尔与美国总统特朗普通...
                        当地时间24日，卡塔尔埃米尔塔米姆与美国总统特朗普通电话，重点就中东地区局势以及伊朗与美国谈判问题交...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        男子30年前被扣押2859克黄...
                        澎湃新闻记者 王鑫家住辽宁省大连市的潘永嘉近日向澎湃新闻反映称，三十年前，他在大连周水子机场被盖州市...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        商务部：取消反制欧盟两家金融机...
                        中华人民共和国商务部令二〇二六年 第1号鉴于欧盟已取消对中国两家金融机构的制裁措施，现公布《关于取消...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        过去24小时共有5艘船只通过霍...
                        总台记者当地时间24日获悉，过去24小时内，共有5艘船只通过霍尔木兹海峡，其中包括一艘伊朗油轮。（总...