netty案例，netty4.1中级拓展篇四《Netty传输文件、分片发送、断点续传》源码

package org.itstack.demo.netty.server; import com.alibaba.fastjson.JSON; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.channel.socket.SocketChannel; import org.itstack.demo.netty.domain.*; import org.itstack.demo.netty.util.CacheUtil; import org.itstack.demo.netty.util.FileUtil; import org.itstack.demo.netty.util.MsgUtil; import java.text.SimpleDateFormat; import java.util.Date; /** * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈 ｛获取学习源码｝ * 虫洞群：5360692 * Create by fuzhengwei on @2019 */ public class MyServerHandler extends ChannelInboundHandlerAdapter { /** * 当客户端主动链接服务端的链接后，这个通道就是活跃的了。也就是客户端与服务端建立了通信通道并且可以传输数据 */ @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { SocketChannel channel = (SocketChannel) ctx.channel(); System.out.println("链接报告开始"); System.out.println("链接报告信息：有一客户端链接到本服务端。channelId：" + channel.id()); System.out.println("链接报告IP:" + channel.localAddress().getHostString()); System.out.println("链接报告Port:" + channel.localAddress().getPort()); System.out.println("链接报告完毕"); } /** * 当客户端主动断开服务端的链接后，这个通道就是不活跃的。也就是说客户端与服务端的关闭了通信通道并且不可以传输数据 */ @Override public void channelInactive(ChannelHandlerContext ctx) throws Exception { System.out.println("客户端断开链接" + ctx.channel().localAddress().toString()); } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //数据格式验证 if (!(msg instanceof FileTransferProtocol)) return; FileTransferProtocol fileTransferProtocol = (FileTransferProtocol) msg; //0传输文件'请求'、1文件传输'指令'、2文件传输'数据' switch (fileTransferProtocol.getTransferType()) { case 0: FileDescInfo fileDescInfo = (FileDescInfo) fileTransferProtocol.getTransferObj(); //断点续传信息，实际应用中需要将断点续传信息保存到数据库中 FileBurstInstruct fileBurstInstructOld = CacheUtil.burstDataMap.get(fileDescInfo.getFileName()); if (null != fileBurstInstructOld) { if (fileBurstInstructOld.getStatus() == Constants.FileStatus.COMPLETE) { CacheUtil.burstDataMap.remove(fileDescInfo.getFileName()); } //传输完成删除断点信息 System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " bugstack虫洞栈服务端，接收客户端传输文件请求[断点续传]。" + JSON.toJSONString(fileBurstInstructOld)); ctx.writeAndFlush(MsgUtil.buildTransferInstruct(fileBurstInstructOld)); return; } //发送信息 FileTransferProtocol sendFileTransferProtocol = MsgUtil.buildTransferInstruct(Constants.FileStatus.BEGIN, fileDescInfo.getFileUrl(), 0); ctx.writeAndFlush(sendFileTransferProtocol); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " bugstack虫洞栈服务端，接收客户端传输文件请求。" + JSON.toJSONString(fileDescInfo)); break; case 2: FileBurstData fileBurstData = (FileBurstData) fileTransferProtocol.getTransferObj(); FileBurstInstruct fileBurstInstruct = FileUtil.writeFile("E://", fileBurstData); //保存断点续传信息 CacheUtil.burstDataMap.put(fileBurstData.getFileName(), fileBurstInstruct); ctx.writeAndFlush(MsgUtil.buildTransferInstruct(fileBurstInstruct)); System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " bugstack虫洞栈服务端，接收客户端传输文件数据。" + JSON.toJSONString(fileBurstData)); //传输完成删除断点信息 if (fileBurstInstruct.getStatus() == Constants.FileStatus.COMPLETE) { CacheUtil.burstDataMap.remove(fileBurstData.getFileName()); } break; default: break; } } /** * 抓住异常，当发生异常的时候，可以做一些相应的处理，比如打印日志、关闭链接 */ @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { ctx.close(); System.out.println("异常信息：\r\n" + cause.getMessage()); } }