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--------核心执行阶段篇                

            

            
            

                
                
相关内容

                
            

            

            
            

                

            



        
        
    
    

    
    

        
        

            
            

                
                

                    
                    

                        
                        热门资讯
                        
                    

                    
                

                
            

            
            
            


                                
                

                    
                    

                        

                    

                    
                    
                    

                        【第一消息】“福建麻将.开挂神...
                        您好：福建麻将这款游戏可以开挂，确实是有挂的，需要了解加客服微信【9752949】很多玩家在这款游戏...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        车驾管服务“跑”出新速度
                        【编者按】因地制宜发展新质生产力，是江苏推动高质量发展的核心战略路径。作为全国制造业集群规模最大的省...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        2026年小程序技术公司深度洞...
                        在2026年的今天，数字化转型已不再是企业的“加分项”，而是生存与发展的“必答题”。对于广大商家而言...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        【第一消息】“阳光巴厘岛.开挂...
                        【第一消息】“阳光巴厘岛.开挂神器？”详细开挂教程您好，阳光巴厘岛这个游戏其实有挂的，确实是有挂的，...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        【第一资讯】“福星游戏.开挂器...
                        有               亲，根据资深记者爆料福星游戏是可以开挂的，确实有挂（咨询软件无需打开...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        最新引进“丫丫衡阳字牌.真的有...
                        最新引进“丫丫衡阳字牌.真的有挂吗？”太坑了果然有挂您好，丫丫衡阳字牌这个游戏其实有挂的，确实是有挂...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        【第一资讯】“中至余干麻将.有...
                        网上科普关于“中至余干麻将有没有挂”话题很是火热，小编也是针对中至余干麻将作*弊开挂的方法以及开挂对...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        终于明白“新版悟空炸金花.是不...
                        家人们！今天小编来为大家解答新版悟空炸金花透视挂怎么安装这个问题咨询软件客服徽4282891的挂在哪...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        玩家攻略科普“同乐吧.真的有挂...
                        有               亲，根据资深记者爆料同乐吧是可以开挂的，确实有挂（咨询软件无需打开直...
                    

                    
                

                                
                

                    
                    

                        

                    

                    
                    
                    

                        今日重大消息“胡一把麻将.辅助...
                        网上科普关于“胡一把麻将有没有挂”话题很是火热，小编也是针对胡一把麻将作*弊开挂的方法以及开挂对应的...