采用netty与protobuf进行文件传输

// Generated by the protocol buffer compiler. DO NOT EDIT! // source: w.proto package org.protob; public final class W { private W() {} public static void registerAllExtensions( com.google.protobuf.ExtensionRegistry registry) { } public interface RequestFileOrBuilder extends com.google.protobuf.MessageOrBuilder { // required string file_name = 1; /** * <code>required string file_name = 1;</code> * * <pre> * 文件名 * </pre> */ boolean hasFileName(); /** * <code>required string file_name = 1;</code> * * <pre> * 文件名 * </pre> */ java.lang.String getFileName(); /** * <code>required string file_name = 1;</code> * * <pre> * 文件名 * </pre> */ com.google.protobuf.ByteString getFileNameBytes(); // required int64 starPos = 2; /** * <code>required int64 starPos = 2;</code> * * <pre> * 开始位置 * </pre> */ boolean hasStarPos(); /** * <code>required int64 starPos = 2;</code> * * <pre> * 开始位置 * </pre> */ long getStarPos(); // required bytes bytes = 3; /** * <code>required bytes bytes = 3;</code> * * <pre> * 文件字节数组 repeated * </pre> */ boolean hasBytes(); /** * <code>required bytes bytes = 3;</code> * * <pre> * 文件字节数组 repeated * </pre> */ com.google.protobuf.ByteString getBytes(); // required int32 endPos = 4; /** * <code>required int32 endPos = 4;</code> * * <pre> * 结尾位置 * </pre> */ boolean hasEndPos(); /** * <code>required int32 endPos = 4;</code> * * <pre> * 结尾位置 * </pre> */ int getEndPos(); // required string file_md5 = 5; /** * <code>required string file_md5 = 5;</code> * * <pre> *文件的MD5值 * </pre> */ boolean hasFileMd5(); /** * <code>required string file_md5 = 5;</code> * * <pre> *文件的MD5值 * </pre> */ java.lang.String getFileMd5(); /** * <code>required string file_md5 = 5;</code> * * <pre> *文件的MD5值 * </pre> */ com.google.protobuf.ByteString getFileMd5Bytes(); // required string file_type = 6; /** * <code>required string file_type = 6;</code> * * <pre> *文件类型 * </pre> */ boolean hasFileType(); /** * <code>required string file_type = 6;</code> * * <pre> *文件类型 * </pre> */ java.lang.String getFileType(); /** * <code>required string file_type = 6;</code> * * <pre> *文件类型 * </pre> */ com.google.protobuf.ByteString getFileTypeBytes(); // required int64 file_size = 7; /** * <code>required int64 file_size = 7;</code> * * <pre> *文件总长度 * </pre> */ boolean hasFileSize(); /** * <code>required int64 file_size = 7;</code> * * <pre> *文件总长度 * </pre> */ long getFileSize(); } /** * Protobuf type {@code org.protob.RequestFile} */ public static final class RequestFile extends com.google.protobuf.GeneratedMessage implements RequestFileOrBuilder { // Use RequestFile.newBuilder() to construct. private RequestFile(com.google.protobuf.GeneratedMessage.Builder<?> builder) { super(builder); this.unknownFields = builder.getUnknownFields(); } private RequestFile(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } private static final RequestFile defaultInstance; public static RequestFile getDefaultInstance() { return defaultInstance; } public RequestFile getDefaultInstanceForType() { return defaultInstance; } private final com.google.protobuf.UnknownFieldSet unknownFields; @java.lang.Override public final com.google.protobuf.UnknownFieldSet getUnknownFields() { return this.unknownFields; } private RequestFile( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { initFields(); int mutable_bitField0_ = 0; com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder(); try { boolean done = false; while (!done) { int tag = input.readTag(); switch (tag) { case 0: done = true; break; default: { if (!parseUnknownField(input, unknownFields, extensionRegistry, tag)) { done = true; } break; } case 10: { bitField0_ |= 0x00000001; fileName_ = input.readBytes(); break; } case 16: { bitField0_ |= 0x00000002; starPos_ = input.readInt64(); break; } case 26: { bitField0_ |= 0x00000004; bytes_ = input.readBytes(); break; } case 32: { bitField0_ |= 0x00000008; endPos_ = input.readInt32(); break; } case 42: { bitField0_ |= 0x00000010; fileMd5_ = input.readBytes(); break; } case 50: { bitField0_ |= 0x00000020; fileType_ = input.readBytes(); break; } case 56: { bitField0_ |= 0x00000040; fileSize_ = input.readInt64(); break; } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { throw e.setUnfinishedMessage(this); } catch (java.io.IOException e) { throw new com.google.protobuf.InvalidProtocolBufferException( e.getMessage()).setUnfinishedMessage(this); } finally { this.unknownFields = unknownFields.build(); makeExtensionsImmutable(); } } public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { return org.protob.W.internal_static_org_protob_RequestFile_descriptor; } protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable() { return org.protob.W.internal_static_org_protob_RequestFile_fieldAccessorTable .ensureFieldAccessorsInitialized( org.protob.W.RequestFile.class, org.protob.W.RequestFile.Builder.class); } public static com.google.protobuf.Parser<RequestFile> PARSER = new com.google.protobuf.AbstractParser<RequestFile>() { public RequestFile parsePartialFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { return new RequestFile(input, extensionRegistry); } }; @java.lang.Override public com.google.protobuf.Parser<RequestFile> getParserForType() { return PARSER; } private int bitField0_; // required string file_name = 1; public static final int FILE_NAME_FIELD_NUMBER = 1; private java.lang.Object fileName_; /** * <code>required string file_name = 1;</code> * * <pre> * 文件名 * </pre> */ public boolean hasFileName() { return ((bitField0_ & 0x00000001) == 0x00000001); } /** * <code>required string file_name = 1;</code> * * <pre>