国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

netty使用EmbeddedChannel對channel的出入站進行單元測試

妤鋒シ / 2115人閱讀

摘要：一種特殊的實現，它是專門為改進針對的單元測試而提供的。名稱職責將入站消息寫到中。如果沒有任何可供讀取的，則返回將標記為完成，如果有可讀取的入站或出站數據，則返回。這個方法還將會調用上的方法測試入站消息測試出站消息測試異常處理

一種特殊的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();
    }
}
           
               
                                           
                       
                 
            
                     
             
               

                   
 文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

                 
                   
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/75743.html

               

                      
               
              
              

                
相關文章

                
    
                             
                                                                                                    
  • 
                                                
    
                          
    Netty學習筆記（二）
    
                                                     
    摘要：支持很多協議，并且提供用于數據處理的容器。我們已經知道由特定事件觸發?？蓪Ｓ糜趲缀跛械膭幼?，包括將一個對象轉為字節或相反，執行過程中拋出的異常處理。提供了一個容器給鏈并提供了一個用于管理沿著鏈入站和出站事件的流動。子類通過進行注冊。

前兩天寫了一點netty相關的知識，并寫了一個demo，但是對其原理還是沒有深入，今天我們來做一次研究吧
首先讓我們來認識一下netty的幾個核心人物吧...
    
                                                   
                          
    
                                
    
                                    0x584a
                                    
                                    評論0 
                                    收藏0 
                                
    
                          
    
                      
    
                    
    •  
                                                                                       
  • 
                                                
    
                          
    Netty組件入門學習
    
                                                     
    摘要：可以用來接收入站事件和數據，隨后使用應用程序的業務邏輯進行處理。因為用戶并不是關心所有的事件，因此提供了抽象類和。抽象類最常見的一個情況，你的應用程序會利用一個來接受解碼消息，并對該數據應用業務邏輯。

Channel、EventLoop和ChannelFuture

Channel——Socket;
EventLoop——控制流、多線程處理、并發
ChannelFuture異步通知

...
    
                                                   
                          
    
                                
    
                                    qpal
                                    
                                    評論0 
                                    收藏0 
                                
    
                          
    
                      
    
                    
    •  
                                                                                       
  • 
                                                
    
                          
    Netty ByteBuf 誰負責誰釋放
    
                                                     
    摘要：轉發自

轉發自 http://netty.io/wiki/referenc...
Since Netty version 4, the life cycle of certain objects are managed by their reference counts, so that Netty can return them (or their shared resources)...
    
                                                   
                          
    
                                
    
                                    Lyux
                                    
                                    評論0 
                                    收藏0 
                                
    
                          
    
                      
    
                    
    •  
                                                                                       
  • 
                                                
    
                          
    Netty-ChannelHandler-ChannelPipeline
    
                                                     
    摘要：只有在詳盡的測試之后才應設置為這值使用的默認采樣率檢測并報告任何發現的泄漏。這是默認級別，適合絕大部分情況使用默認的采樣率，報告所發現的任何的泄漏以及對應的消息被訪問的位置類似于但是其將會對每次對消息的訪問都進行采樣。

ChannelHandler
Channel生命周期


狀態
描述



ChannelUnregistered
Channel已經被創建，但未注冊到EventLoo...
    
                                                   
                          
    
                                
    
                                    warkiz
                                    
                                    評論0 
                                    收藏0 
                                
    
                          
    
                      
    
                    
    •  
                                                                                       
  • 
                                                
    
                          
    Netty學習-Echo服務器客戶端
    
                                                     
    摘要：服務器構成至少一個該組件實現了服務器對從客戶端接受的數據的處理，即它的業務邏輯引導配置服務器的啟動代碼。至少，它會將服務器綁定到它要監聽連接請求的端口上。需要注意的是，由服務器發送的消息可能會被分塊接受。

Netty服務器構成


至少一個ChannelHandler——該組件實現了服務器對從客戶端接受的數據的處理，即它的業務邏輯

引導——配置服務器的啟動代碼。至少，它會將服務器綁定...
    
                                                   
                          
    
                                
    
                                    dreamGong
                                    
                                    評論0 
                                    收藏0 
                                
    
                          
    
                      
    
                    
    •  
                                                                           
                

              

              
               

                  
                  
發表評論

                   
               

              

                

                  
0條評論
   
                
 
                      

              

           
           

              
 
                

                    
                    
妤鋒シ

                    
男|高級講師

                    
                    

                          
TA的文章

                          閱讀更多
                    

                      
                


                   
              
  

                  
最新活動
 
           
                             
              





                                
              

           

        
       
    
    
     

      
    

    
    

    
       
       

         
閱讀需要支付1元查看
  
         
     
       

      
  
    
    








        

            

              
              
            

             
        

    







<