怎么使用java Netty实现传输文件、分片发送、断点续传

itstack-demo-netty-2-04└── src    ├── main    │   └── java    │       └── org.itstack.demo.netty    │           ├── client    │           │   ├── MyChannelInitializer.java    │           │   ├── MyClientHandler.java    │           │   └── NettyClient.java    │           ├── codec    │           │   ├── ObjDecoder.java    │           │   └── ObjEncoder.java    │           ├── domain    │           │   ├── Constants.java    │           │   ├── FileBurstData.java    │           │   ├── FileBurstInstruct.java    │           │   ├── FileDescInfo.java    │           │   └── FileTransferProtocol.java    │           ├── server    │           │   ├── MyChannelInitializer.java    │           │   ├── MyServerHandler.java    │           │   └── NettyServer.java    │           └── util    │               ├── CacheUtil.java    │               ├── FileUtil.java    │               ├── MsgUtil.java    │               └── SerializationUtil.java    │    └── test         └── java             └── org.itstack.demo.test                 ├── ApiTest.java                 ├── NettyClientTest.java                 └── NettyServerTest.java

@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {    //数据格式验证    if (!(msg instanceof FileTransferProtocol)) return;    FileTransferProtocol fileTransferProtocol = (FileTransferProtocol) msg;    //0传输文件'请求'、1文件传输'指令'、2文件传输'数据'    switch (fileTransferProtocol.getTransferType()) {        case 1:            FileBurstInstruct fileBurstInstruct = (FileBurstInstruct) fileTransferProtocol.getTransferObj();            //Constants.FileStatus ｛0开始、1中间、2结尾、3完成｝            if (Constants.FileStatus.COMPLETE == fileBurstInstruct.getStatus()) {                ctx.flush();                ctx.close();                System.exit(-1);                return;            }            FileBurstData fileBurstData = FileUtil.readFile(fileBurstInstruct.getClientFileUrl(), fileBurstInstruct.getReadPosition());            ctx.writeAndFlush(MsgUtil.buildTransferData(fileBurstData));            System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " bugstack虫洞栈客户端传输文件信息。FILE：" + fileBurstData.getFileName() + " SIZE(byte)：" + (fileBurstData.getEndPos() - fileBurstData.getBeginPos()));            break;        default:            break;    }    /**模拟传输过程中断，场景测试可以注释掉     *     */    System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " bugstack虫洞栈客户端传输文件信息[主动断开链接，模拟断点续传]");    ctx.flush();    ctx.close();    System.exit(-1);}

/** * 文件分片数据 * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈  ｛获取学习源码｝ * 虫洞群：①群5398358 ②群5360692 * Create by fuzhengwei on 2019 */public class FileBurstData {    private String fileUrl;     //客户端文件地址    private String fileName;    //文件名称    private Integer beginPos;   //开始位置    private Integer endPos;     //结束位置    private byte[] bytes;       //文件字节；再实际应用中可以使用非对称加密，以保证传输信息安全    private Integer status;     //Constants.FileStatus ｛0开始、1中间、2结尾、3完成｝    ... get/set}

/** * 文件分片指令 * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈  ｛获取学习源码｝ * 虫洞群：①群5398358 ②群5360692 * Create by fuzhengwei on @2019 */public class FileBurstInstruct {    private Integer status;       //Constants.FileStatus ｛0开始、1中间、2结尾、3完成｝    private String clientFileUrl; //客户端文件URL    private Integer readPosition; //读取位置    ... get/set}

/** * 文件描述信息 * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈  ｛获取学习源码｝ * 虫洞群：①群5398358 ②群5360692 * Create by fuzhengwei on @2019 */public class FileDescInfo {    private String fileUrl;    private String fileName;    private Long fileSize;    ... get/set}

/** * 文件传输协议 * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈  ｛获取学习源码｝ * 虫洞群：5360692 * Create by fuzhengwei on @2019 */public class FileTransferProtocol {    private Integer transferType; //0请求传输文件、1文件传输指令、2文件传输数据    private Object transferObj;   //数据对象；(0)FileDescInfo、(1)FileBurstInstruct、(2)FileBurstData    ... get/set}

@Overridepublic 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;    }}

/** * 文件读写工具 * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈  ｛获取学习源码｝ * 虫洞群：5360692 * Create by fuzhengwei on @2019 */public class FileUtil {    public static FileBurstData readFile(String fileUrl, Integer readPosition) throws IOException {        File file = new File(fileUrl);        RandomAccessFile randomAccessFile = new RandomAccessFile(file, "r");//r: 只读模式 rw:读写模式        randomAccessFile.seek(readPosition);        byte[] bytes = new byte[1024];        int readSize = randomAccessFile.read(bytes);        if (readSize <= 0) {            randomAccessFile.close();            return new FileBurstData(Constants.FileStatus.COMPLETE);//Constants.FileStatus ｛0开始、1中间、2结尾、3完成｝        }        FileBurstData fileInfo = new FileBurstData();        fileInfo.setFileUrl(fileUrl);        fileInfo.setFileName(file.getName());        fileInfo.setBeginPos(readPosition);        fileInfo.setEndPos(readPosition + readSize);        //不足1024需要拷贝去掉空字节        if (readSize < 1024) {            byte[] copy = new byte[readSize];            System.arraycopy(bytes, 0, copy, 0, readSize);            fileInfo.setBytes(copy);            fileInfo.setStatus(Constants.FileStatus.END);        } else {            fileInfo.setBytes(bytes);            fileInfo.setStatus(Constants.FileStatus.CENTER);        }        randomAccessFile.close();        return fileInfo;    }    public static FileBurstInstruct writeFile(String baseUrl, FileBurstData fileBurstData) throws IOException {        if (Constants.FileStatus.COMPLETE == fileBurstData.getStatus()) {            return new FileBurstInstruct(Constants.FileStatus.COMPLETE); //Constants.FileStatus ｛0开始、1中间、2结尾、3完成｝        }        File file = new File(baseUrl + "/" + fileBurstData.getFileName());        RandomAccessFile randomAccessFile = new RandomAccessFile(file, "rw");//r: 只读模式 rw:读写模式        randomAccessFile.seek(fileBurstData.getBeginPos());      //移动文件记录指针的位置,        randomAccessFile.write(fileBurstData.getBytes());        //调用了seek（start）方法，是指把文件的记录指针定位到start字节的位置。也就是说程序将从start字节开始写数据        randomAccessFile.close();        if (Constants.FileStatus.END == fileBurstData.getStatus()) {            return new FileBurstInstruct(Constants.FileStatus.COMPLETE); //Constants.FileStatus ｛0开始、1中间、2结尾、3完成｝        }        //文件分片传输指令        FileBurstInstruct fileBurstInstruct = new FileBurstInstruct();        fileBurstInstruct.setStatus(Constants.FileStatus.CENTER);            //Constants.FileStatus ｛0开始、1中间、2结尾、3完成｝        fileBurstInstruct.setClientFileUrl(fileBurstData.getFileUrl());      //客户端文件URL        fileBurstInstruct.setReadPosition(fileBurstData.getEndPos() + 1);    //读取位置        return fileBurstInstruct;    }}

/** * 消息构建工具 * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈  ｛获取学习源码｝ * 虫洞群：5360692 * Create by fuzhengwei on @2019 */public class MsgUtil {    /**     * 构建对象；请求传输文件(客户端)     *     * @param fileUrl  客户端文件地址     * @param fileName 文件名称     * @param fileSize 文件大小     * @return 传输协议     */    public static FileTransferProtocol buildRequestTransferFile(String fileUrl, String fileName, Long fileSize) {        FileDescInfo fileDescInfo = new FileDescInfo();        fileDescInfo.setFileUrl(fileUrl);        fileDescInfo.setFileName(fileName);        fileDescInfo.setFileSize(fileSize);        FileTransferProtocol fileTransferProtocol = new FileTransferProtocol();        fileTransferProtocol.setTransferType(0);//0请求传输文件、1文件传输指令、2文件传输数据        fileTransferProtocol.setTransferObj(fileDescInfo);        return fileTransferProtocol;    }    /**     * 构建对象；文件传输指令(服务端)     * @param status          0请求传输文件、1文件传输指令、2文件传输数据     * @param clientFileUrl   客户端文件地址     * @param readPosition    读取位置     * @return                传输协议     */    public static FileTransferProtocol buildTransferInstruct(Integer status, String clientFileUrl, Integer readPosition) {        FileBurstInstruct fileBurstInstruct = new FileBurstInstruct();        fileBurstInstruct.setStatus(status);        fileBurstInstruct.setClientFileUrl(clientFileUrl);        fileBurstInstruct.setReadPosition(readPosition);        FileTransferProtocol fileTransferProtocol = new FileTransferProtocol();        fileTransferProtocol.setTransferType(Constants.TransferType.INSTRUCT); //0传输文件'请求'、1文件传输'指令'、2文件传输'数据'        fileTransferProtocol.setTransferObj(fileBurstInstruct);        return fileTransferProtocol;    }    /**     * 构建对象；文件传输指令(服务端)     *     * @return 传输协议     */    public static FileTransferProtocol buildTransferInstruct(FileBurstInstruct fileBurstInstruct) {        FileTransferProtocol fileTransferProtocol = new FileTransferProtocol();        fileTransferProtocol.setTransferType(Constants.TransferType.INSTRUCT);  //0传输文件'请求'、1文件传输'指令'、2文件传输'数据'        fileTransferProtocol.setTransferObj(fileBurstInstruct);        return fileTransferProtocol;    }    /**     * 构建对象；文件传输数据(客户端)     *     * @return 传输协议     */    public static FileTransferProtocol buildTransferData(FileBurstData fileBurstData) {        FileTransferProtocol fileTransferProtocol = new FileTransferProtocol();        fileTransferProtocol.setTransferType(Constants.TransferType.DATA); //0传输文件'请求'、1文件传输'指令'、2文件传输'数据'        fileTransferProtocol.setTransferObj(fileBurstData);        return fileTransferProtocol;    }}

/** * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈  ｛获取学习源码｝ * 虫洞群：①群5398358 ②群5360692 * Create by fuzhengwei on 2019 */public class NettyServerTest {    public static void main(String[] args) {        //启动服务        new NettyServer().bing(7397);    }}

/** * 虫洞栈：https://bugstack.cn * 公众号：bugstack虫洞栈  ｛获取学习源码｝ * 虫洞群：①群5398358 ②群5360692 * Create by fuzhengwei on 2019 */public class NettyClientTest {    public static void main(String[] args) {        //启动客户端        ChannelFuture channelFuture = new NettyClient().connect("127.0.0.1", 7397);        //文件信息{文件大于1024kb方便测试断点续传}        File file = new File("C:\\Users\\fuzhengwei\\Desktop\\测试传输文件.rar");        FileTransferProtocol fileTransferProtocol = MsgUtil.buildRequestTransferFile(file.getAbsolutePath(), file.getName(), file.length());        //发送信息；请求传输文件        channelFuture.channel().writeAndFlush(fileTransferProtocol);    }}

itstack-demo-netty server start done. {关注公众号：bugstack虫洞栈，获取源码}链接报告开始链接报告信息：有一客户端链接到本服务端。channelId：3a1df8c1链接报告IP:127.0.0.1链接报告Port:7397链接报告完毕2019-08-04 19:46:46 bugstack虫洞栈服务端，接收客户端传输文件请求。{"fileName":"测试传输文件.rar","fileSize":1400,"fileUrl":"C:\\Users\\fuzhengwei1\\Desktop\\测试传输文件.rar"}2019-08-04 19:46:46 bugstack虫洞栈服务端，接收客户端传输文件数据。{"beginPos":0,"bytes":"UmFyIRoHAM+QcwAADQAAAAAAAAC4C3SgkkkAFAUAAIjDEQACJRsHe0WECE8dMyQAIAAAALLiytS0q8rkzsS8/i50eHQAbWpL1YsgT5OPoIdl9k4udAB4dACwS2heCZgVEQzPzUEXfAnhs2R75rhNbCQhNE3uMY4EBkBqQJ45izS4lFGujEk08xLGuhp4sSUSbzEscRICakGyOdARhIE6GEPucySJpY5kQ/Cq28ur4XdfH/j1V8UVoo5X5V+B3dl2f8qvvoxd3t6GPv8HZ7dXs+98XT6uJ0Oj8GZ4c6tvV6vzV865ka375utod+9i+pX/O1Uu1tT76tT38TE+Hq+tzud6Of9Xo9T0/S/xytLm12v4NWztfhnda3lbevs7dnXsWL1vT3Kte91triqYuHW/9bf3WPnjq5r5savbHd67V8Nu6r5+lmZtrP0eO63Ba+upVuWtf7bvByg2/0w+5hz8ru14ND5ex/Odw4F7uRWrYedwU2tXmw5m1u+S7lWdjvTq5e/Kv+1apZxrdjT2dHizdHDrlrH1cvkbrWe5k97u6WRnXdviw6zkvc3cD9TOt7+7W9z2/Ys+Sx9VTPwGeYLmrz+h8fQt5u5v8/3fZ5sXKnc4MOT1+n0upicmOVDT86GfY4bPf5vN7XSxMT5Mnsdry8e84///+quHp9l19fRz8vkds+O7qb+9pWe1WvXdb7NWza3vNO3V3cZZ2rPDr1svHwO3Nq14sBuZu3P1zOvuWP++s8ex9O95e5U/vW9/F7Jtb+p+PGeRtzlg8VfG5t5TyAAAAAAAAAAAAAAAARu1PHU9QX3wAAAAAAAAAAAAAAAiiXyXwAAAAAAAAAAAAAAAiiXyXwAAAAAAAAAAAAAAAiiXyXwAAAAAAAAAAAAAAAiiXyXwAEbDTyAAAAAAAAAAAAAEctTx1PUF98AAAAAAAAAAAAAAAIol8l8AAAAAAAAAAAAAAAIol8l8AAAAAAAAAAAAAAAIol8l8AAAAAAAAAAAAAAAIol8l8AAAABHx08gAAAAAAAAAAj108dT1BffAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAAAAAAgankAAAAAAAEZGnjqeoL74AAAAAAAAAAAAAAARRL5L4AAAAAAAAAAAAAAARRL5L4AAAAAAAAAAAAAAARRL5L4AAAAAAAAAAAAAAARRL5L4AAAAAAAAAAEYinkAAAAEH08dT1BffAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAA==","endPos":1024,"fileName":"测试传输文件.rar","fileUrl":"C:\\Users\\fuzhengwei1\\Desktop\\测试传输文件.rar","status":1}2019-08-04 19:46:46 bugstack虫洞栈服务端，接收客户端传输文件数据。{"beginPos":1025,"bytes":"AAI8VPIAEfZTx1PUF98AAAAAAAAAAAAAAAIol8l8AAAAAAAAAAAAAAAIol8l8AAAAAAAAAAAAAAAIol8l8AAAAAAAAAAAAAAAIol8l8AAAAAAAAAAAAAAAIol8l8R+dPIAAAAAAAAAAAAAAAjt08dT1BffAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAAAAAAAAAAAAACKJfJfAAAIWp5AAAAAAAAAAAAEYGnjqeoL74AAAAAAAAAAAAAAARRL5L4AAAAAAAAAAAAAAARRL5L4AAAAAAAAAAAAAAARRL5L4AAAAAAAAAAAAAAARRL5L4AAAAABGYp5AAAAAAAAAEc/Tx1PUF98AAAAAAAAIyFPIAAAAAACB6eOp6gvvgAAAAAAAAAARiKeQAAAAQfTx1PUF98AAAAAAAAAAAAAjAU8gACF6eOp6gvvgAAAAAAAAAAAAAABFH9IDEPXsAQAcA","endPos":1400,"fileName":"测试传输文件.rar","fileUrl":"C:\\Users\\fuzhengwei1\\Desktop\\测试传输文件.rar","status":2}客户端断开链接/127.0.0.1:7397Process finished with exit code -1

itstack-demo-netty client start done. {关注公众号：bugstack虫洞栈，获取源码}链接报告开始链接报告信息：本客户端链接到服务端。channelId：71399d8c链接报告IP:127.0.0.1链接报告Port:54974链接报告完毕2019-08-04 19:46:46 bugstack虫洞栈客户端传输文件信息。FILE：测试传输文件.rar SIZE(byte)：10242019-08-04 19:46:46 bugstack虫洞栈客户端传输文件信息。FILE：测试传输文件.rar SIZE(byte)：375Process finished with exit code -1