Netty 5 傳送大文件的方法

Netty 5 提供了 一個ChunkedWriterHandler 來傳送大文件，發送端如下：

添加chunedwriterhandler：

 ChannelPipeline p = ...;
 p.addLast("streamer", new ChunkedWriteHandler());
 p.addLast("handler", new MyHandler());

直接發送文件

 Channel ch = ...;
 ch.write(new ChunkedFile(new File("video.mkv"));

需要注意的是 ChunkedWriterHandler 必須添加在 發送文件的handler的前面。 也就是先添加了handler，才能調用channel write chunedfile。

接收端的代碼如下，關鍵點是發送端需要提前告知文件大小（File.length)，將一個handler添加到所有的handler前面，這樣攔截到文件內容，寫完文件將handler移除。

ctx.pipeline().addFirst(new ChunkedReadHandler(size));

class ChunkedReadHandler extends ChannelHandlerAdapter{
    private long fileSize;
    private File file;
    private FileOutputStream ofs;
    private long readedSize=0;
    public ChunkedReadHandler(long size) throws FileNotFoundException{
        this.fileSize=size;
        this.file = new File("C:/2.zip");        
        ofs=new FileOutputStream(this.file);
    }
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        
        ByteBuf buf= (ByteBuf) msg;
        
        readedSize +=buf.readableBytes();
        if(buf.isReadable()){
            byte[] bytes=new byte[buf.readableBytes()];
            buf.readBytes(bytes);
            ofs.write(bytes);
        }
        
        System.out.println(fileSize + "   " + readedSize);
        
        if(readedSize >= fileSize){
            ctx.pipeline().remove(this);
            ofs.close();
        }
        buf.release();
    }
}

 

netty5文檔里channelpipeline的doc給了一幅圖比較清楚的描述了handler的關系，像tcp/ip協議一樣是層次關系

 

一般的handler添加順序為：

1. Protocol Decoder - translates binary data (e.g. ByteBuf) into a Java object.
2. Protocol Encoder - translates a Java object into binary data.
3. Business Logic Handler - performs the actual business logic (e.g. database access).

對應的輸入輸出層先添加，再添加下一層的handler。

因此，我們的邏輯層就工作在最高層，抽象度最高也最方便。