如何租用服务器做网站,关于公司建网站,旅游电商网站建设方案模板,wordpress多语言插件背景#xff1a;gRPC是一个高性能、通用的开源RPC框架#xff0c;其由Google主要面向移动应用开发并基于HTTP/2协议标准而设计#xff0c;基于ProtoBuf(Protocol Buffers)序列化协议开发#xff0c;且支持众多开发语言。gRPC提供了一种简单的方法来精确地定义服务和为iOS、…背景gRPC是一个高性能、通用的开源RPC框架其由Google主要面向移动应用开发并基于HTTP/2协议标准而设计基于ProtoBuf(Protocol Buffers)序列化协议开发且支持众多开发语言。gRPC提供了一种简单的方法来精确地定义服务和为iOS、Android和后台支持服务自动生成可靠性很强的客户端功能库。客户端充分利用高级流和链接功能从而有助于节省带宽、降低的TCP链接次数、节省CPU使用、和电池寿命。 以下初探编码过程 1、安装插件Protobuf-dt最新版本我的版本为2.2.1 2、下载protobuf 找到对应操作系统版本我的系统为OS直接解压到某个目录我的目录为/Users/peng/protoc-3.0.0-beta-2-osx-x86_64链接https://github.com/google/protobuf 3、新建maven项目过程省略 4、在pom.xml文件中添加gRPC的相关依赖 dependencygroupIdio.grpc/groupIdartifactIdgrpc-all/artifactIdversion0.13.2/version/dependency 添加maven-protobuf-plugin在pom.xml中添加以下内容 build extensions extension groupIdkr.motd.maven/groupId artifactIdos-maven-plugin/artifactId version1.4.1.Final/version /extension /extensions plugins plugin groupIdorg.xolstice.maven.plugins/groupId artifactIdprotobuf-maven-plugin/artifactId version0.5.0/version configuration !-- The version of protoc must match protobuf-java. If you dont depend on protobuf-java directly, you will be transitively depending on the protobuf-java version that grpc depends on. -- protocArtifactcom.google.protobuf:protoc:3.0.0-beta-2:exe:${os.detected.classifier}/protocArtifact pluginIdgrpc-java/pluginId pluginArtifactio.grpc:protoc-gen-grpc-java:0.13.2:exe:${os.detected.classifier}/pluginArtifact protocExecutable/Users/peng/protoc-3.0.0-beta-2-osx-x86_64/protoc/protocExecutable/configuration executions execution goals goalcompile/goal goalcompile-custom/goal /goals /execution /executions /plugin /plugins /build 注意protocExecutable节点后的目录为第2步中protobuf的安装路径 最终的pom.xml文件如下 project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.mzsg.demo/groupIdartifactIdgrpc/artifactIdversion0.0.1-SNAPSHOT/versionpackagingjar/packagingnamegrpc/nameurlhttp://maven.apache.org/urlpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncoding/propertiesdependenciesdependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion3.8.1/versionscopetest/scope/dependencydependencygroupIdio.grpc/groupIdartifactIdgrpc-all/artifactIdversion0.13.2/version/dependency/dependenciesbuild extensions extension groupIdkr.motd.maven/groupId artifactIdos-maven-plugin/artifactId version1.4.1.Final/version /extension /extensions plugins plugin groupIdorg.xolstice.maven.plugins/groupId artifactIdprotobuf-maven-plugin/artifactId version0.5.0/version configuration !-- The version of protoc must match protobuf-java. If you dont depend on protobuf-java directly, you will be transitively depending on the protobuf-java version that grpc depends on. -- protocArtifactcom.google.protobuf:protoc:3.0.0-beta-2:exe:${os.detected.classifier}/protocArtifact pluginIdgrpc-java/pluginId pluginArtifactio.grpc:protoc-gen-grpc-java:0.13.2:exe:${os.detected.classifier}/pluginArtifact protocExecutable/Users/peng/protoc-3.0.0-beta-2-osx-x86_64/protoc/protocExecutable/configuration executions execution goals goalcompile/goal goalcompile-custom/goal /goals /execution /executions /plugin /plugins /build
/project View Code 5、编写proto文件描述入参、出参及远程方法 在src/main下面建立proto目录protobuf-maven-plugin默认会扫描该目录以生成java文件 在proto目录下新建文件AccountQry.proto内容为 syntax proto3;
package accountService;
option java_package com.mzsg.demo.grpc.qryaccount;
option java_outer_classname QryAccountProto;//账户查询请求
message AccountQryRequest {//请求流水string requestId 1;//用户IDstring userId 2;
}//账户查询响应
message AccountQryResponse {//请求流水string requestId 1;//返回码1:成功; -1:失败int32 rc 2;//错误消息string msg 3;//账户余额int32 amount 4;
}/*** 账户操查询服务*/
service QryAccountService {//账户查询方法rpc Qry(AccountQryRequest) returns (AccountQryResponse);
} 注意本例用查账户查询作为demo因为涉及到后面的性能包括了序列化反序列化对比故不再简单采用Hello world来测试 6、运行maven-generate-source生成proto对应的java文件 生成文件结构 grpc-java下的为方法java下的为入参出参将这两个文件copy到com.mzsg.demo.grpc.qryaccount包下 注意QryAccountServiceGrpc.java文件会提示Override注解报错直接删除注解即可另外生成的代码也不是很简洁有点无语 QryAccountServiceGrpc.java内容 package com.mzsg.demo.grpc.qryaccount;import static io.grpc.stub.ClientCalls.asyncUnaryCall;
import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
import static io.grpc.stub.ClientCalls.blockingUnaryCall;
import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
import static io.grpc.stub.ClientCalls.futureUnaryCall;
import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ServerCalls.asyncUnaryCall;
import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;javax.annotation.Generated(by gRPC proto compiler)
public class QryAccountServiceGrpc {private QryAccountServiceGrpc() {}public static final String SERVICE_NAME accountService.QryAccountService;// Static method descriptors that strictly reflect the proto.io.grpc.ExperimentalApipublic static final io.grpc.MethodDescriptorcom.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest,com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse METHOD_QRY io.grpc.MethodDescriptor.create(io.grpc.MethodDescriptor.MethodType.UNARY,generateFullMethodName(accountService.QryAccountService, Qry),io.grpc.protobuf.ProtoUtils.marshaller(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest.getDefaultInstance()),io.grpc.protobuf.ProtoUtils.marshaller(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse.getDefaultInstance()));public static QryAccountServiceStub newStub(io.grpc.Channel channel) {return new QryAccountServiceStub(channel);}public static QryAccountServiceBlockingStub newBlockingStub(io.grpc.Channel channel) {return new QryAccountServiceBlockingStub(channel);}public static QryAccountServiceFutureStub newFutureStub(io.grpc.Channel channel) {return new QryAccountServiceFutureStub(channel);}public static interface QryAccountService {public void qry(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest request,io.grpc.stub.StreamObservercom.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse responseObserver);}public static interface QryAccountServiceBlockingClient {public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse qry(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest request);}public static interface QryAccountServiceFutureClient {public com.google.common.util.concurrent.ListenableFuturecom.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse qry(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest request);}public static class QryAccountServiceStub extends io.grpc.stub.AbstractStubQryAccountServiceStubimplements QryAccountService {private QryAccountServiceStub(io.grpc.Channel channel) {super(channel);}private QryAccountServiceStub(io.grpc.Channel channel,io.grpc.CallOptions callOptions) {super(channel, callOptions);}java.lang.Overrideprotected QryAccountServiceStub build(io.grpc.Channel channel,io.grpc.CallOptions callOptions) {return new QryAccountServiceStub(channel, callOptions);}public void qry(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest request,io.grpc.stub.StreamObservercom.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse responseObserver) {asyncUnaryCall(getChannel().newCall(METHOD_QRY, getCallOptions()), request, responseObserver);}}public static class QryAccountServiceBlockingStub extends io.grpc.stub.AbstractStubQryAccountServiceBlockingStubimplements QryAccountServiceBlockingClient {private QryAccountServiceBlockingStub(io.grpc.Channel channel) {super(channel);}private QryAccountServiceBlockingStub(io.grpc.Channel channel,io.grpc.CallOptions callOptions) {super(channel, callOptions);}java.lang.Overrideprotected QryAccountServiceBlockingStub build(io.grpc.Channel channel,io.grpc.CallOptions callOptions) {return new QryAccountServiceBlockingStub(channel, callOptions);}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse qry(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest request) {return blockingUnaryCall(getChannel(), METHOD_QRY, getCallOptions(), request);}}public static class QryAccountServiceFutureStub extends io.grpc.stub.AbstractStubQryAccountServiceFutureStubimplements QryAccountServiceFutureClient {private QryAccountServiceFutureStub(io.grpc.Channel channel) {super(channel);}private QryAccountServiceFutureStub(io.grpc.Channel channel,io.grpc.CallOptions callOptions) {super(channel, callOptions);}java.lang.Overrideprotected QryAccountServiceFutureStub build(io.grpc.Channel channel,io.grpc.CallOptions callOptions) {return new QryAccountServiceFutureStub(channel, callOptions);}public com.google.common.util.concurrent.ListenableFuturecom.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse qry(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest request) {return futureUnaryCall(getChannel().newCall(METHOD_QRY, getCallOptions()), request);}}private static final int METHODID_QRY 0;private static class MethodHandlersReq, Resp implementsio.grpc.stub.ServerCalls.UnaryMethodReq, Resp,io.grpc.stub.ServerCalls.ServerStreamingMethodReq, Resp,io.grpc.stub.ServerCalls.ClientStreamingMethodReq, Resp,io.grpc.stub.ServerCalls.BidiStreamingMethodReq, Resp {private final QryAccountService serviceImpl;private final int methodId;public MethodHandlers(QryAccountService serviceImpl, int methodId) {this.serviceImpl serviceImpl;this.methodId methodId;}java.lang.SuppressWarnings(unchecked)public void invoke(Req request, io.grpc.stub.StreamObserverResp responseObserver) {switch (methodId) {case METHODID_QRY:serviceImpl.qry((com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest) request,(io.grpc.stub.StreamObservercom.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse) responseObserver);break;default:throw new AssertionError();}}java.lang.SuppressWarnings(unchecked)public io.grpc.stub.StreamObserverReq invoke(io.grpc.stub.StreamObserverResp responseObserver) {switch (methodId) {default:throw new AssertionError();}}}public static io.grpc.ServerServiceDefinition bindService(final QryAccountService serviceImpl) {return io.grpc.ServerServiceDefinition.builder(SERVICE_NAME).addMethod(METHOD_QRY,asyncUnaryCall(new MethodHandlerscom.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest,com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse(serviceImpl, METHODID_QRY))).build();}
} View Code QryAccountProto.java文件内容 // Generated by the protocol buffer compiler. DO NOT EDIT!
// source: AccountQry.protopackage com.mzsg.demo.grpc.qryaccount;public final class QryAccountProto {private QryAccountProto() {}public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry registry) {}public interface AccountQryRequestOrBuilder extends// protoc_insertion_point(interface_extends:accountService.AccountQryRequest)com.google.protobuf.MessageOrBuilder {/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/java.lang.String getRequestId();/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/com.google.protobuf.ByteStringgetRequestIdBytes();/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/java.lang.String getUserId();/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/com.google.protobuf.ByteStringgetUserIdBytes();}/*** Protobuf type {code accountService.AccountQryRequest}** pre*账户查询请求* /pre*/public static final class AccountQryRequest extendscom.google.protobuf.GeneratedMessage implements// protoc_insertion_point(message_implements:accountService.AccountQryRequest)AccountQryRequestOrBuilder {// Use AccountQryRequest.newBuilder() to construct.private AccountQryRequest(com.google.protobuf.GeneratedMessage.Builder? builder) {super(builder);}private AccountQryRequest() {requestId_ ;userId_ ;}java.lang.Overridepublic final com.google.protobuf.UnknownFieldSetgetUnknownFields() {return com.google.protobuf.UnknownFieldSet.getDefaultInstance();}private AccountQryRequest(com.google.protobuf.CodedInputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry) {this();int mutable_bitField0_ 0;try {boolean done false;while (!done) {int tag input.readTag();switch (tag) {case 0:done true;break;default: {if (!input.skipField(tag)) {done true;}break;}case 10: {java.lang.String s input.readStringRequireUtf8();requestId_ s;break;}case 18: {java.lang.String s input.readStringRequireUtf8();userId_ s;break;}}}} catch (com.google.protobuf.InvalidProtocolBufferException e) {throw new RuntimeException(e.setUnfinishedMessage(this));} catch (java.io.IOException e) {throw new RuntimeException(new com.google.protobuf.InvalidProtocolBufferException(e.getMessage()).setUnfinishedMessage(this));} finally {makeExtensionsImmutable();}}public static final com.google.protobuf.Descriptors.DescriptorgetDescriptor() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryRequest_descriptor;}protected com.google.protobuf.GeneratedMessage.FieldAccessorTableinternalGetFieldAccessorTable() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryRequest_fieldAccessorTable.ensureFieldAccessorsInitialized(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest.class, com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest.Builder.class);}public static final int REQUESTID_FIELD_NUMBER 1;private volatile java.lang.Object requestId_;/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public java.lang.String getRequestId() {java.lang.Object ref requestId_;if (ref instanceof java.lang.String) {return (java.lang.String) ref;} else {com.google.protobuf.ByteString bs (com.google.protobuf.ByteString) ref;java.lang.String s bs.toStringUtf8();requestId_ s;return s;}}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public com.google.protobuf.ByteStringgetRequestIdBytes() {java.lang.Object ref requestId_;if (ref instanceof java.lang.String) {com.google.protobuf.ByteString b com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);requestId_ b;return b;} else {return (com.google.protobuf.ByteString) ref;}}public static final int USERID_FIELD_NUMBER 2;private volatile java.lang.Object userId_;/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/public java.lang.String getUserId() {java.lang.Object ref userId_;if (ref instanceof java.lang.String) {return (java.lang.String) ref;} else {com.google.protobuf.ByteString bs (com.google.protobuf.ByteString) ref;java.lang.String s bs.toStringUtf8();userId_ s;return s;}}/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/public com.google.protobuf.ByteStringgetUserIdBytes() {java.lang.Object ref userId_;if (ref instanceof java.lang.String) {com.google.protobuf.ByteString b com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);userId_ b;return b;} else {return (com.google.protobuf.ByteString) ref;}}private byte memoizedIsInitialized -1;public final boolean isInitialized() {byte isInitialized memoizedIsInitialized;if (isInitialized 1) return true;if (isInitialized 0) return false;memoizedIsInitialized 1;return true;}public void writeTo(com.google.protobuf.CodedOutputStream output)throws java.io.IOException {if (!getRequestIdBytes().isEmpty()) {com.google.protobuf.GeneratedMessage.writeString(output, 1, requestId_);}if (!getUserIdBytes().isEmpty()) {com.google.protobuf.GeneratedMessage.writeString(output, 2, userId_);}}public int getSerializedSize() {int size memoizedSize;if (size ! -1) return size;size 0;if (!getRequestIdBytes().isEmpty()) {size com.google.protobuf.GeneratedMessage.computeStringSize(1, requestId_);}if (!getUserIdBytes().isEmpty()) {size com.google.protobuf.GeneratedMessage.computeStringSize(2, userId_);}memoizedSize size;return size;}private static final long serialVersionUID 0L;public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseFrom(com.google.protobuf.ByteString data)throws com.google.protobuf.InvalidProtocolBufferException {return PARSER.parseFrom(data);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseFrom(com.google.protobuf.ByteString data,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws com.google.protobuf.InvalidProtocolBufferException {return PARSER.parseFrom(data, extensionRegistry);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseFrom(byte[] data)throws com.google.protobuf.InvalidProtocolBufferException {return PARSER.parseFrom(data);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseFrom(byte[] data,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws com.google.protobuf.InvalidProtocolBufferException {return PARSER.parseFrom(data, extensionRegistry);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseFrom(java.io.InputStream input)throws java.io.IOException {return PARSER.parseFrom(input);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseFrom(java.io.InputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws java.io.IOException {return PARSER.parseFrom(input, extensionRegistry);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseDelimitedFrom(java.io.InputStream input)throws java.io.IOException {return PARSER.parseDelimitedFrom(input);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseDelimitedFrom(java.io.InputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws java.io.IOException {return PARSER.parseDelimitedFrom(input, extensionRegistry);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseFrom(com.google.protobuf.CodedInputStream input)throws java.io.IOException {return PARSER.parseFrom(input);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parseFrom(com.google.protobuf.CodedInputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws java.io.IOException {return PARSER.parseFrom(input, extensionRegistry);}public Builder newBuilderForType() { return newBuilder(); }public static Builder newBuilder() {return DEFAULT_INSTANCE.toBuilder();}public static Builder newBuilder(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest prototype) {return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);}public Builder toBuilder() {return this DEFAULT_INSTANCE? new Builder() : new Builder().mergeFrom(this);}java.lang.Overrideprotected Builder newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent) {Builder builder new Builder(parent);return builder;}/*** Protobuf type {code accountService.AccountQryRequest}** pre*账户查询请求* /pre*/public static final class Builder extendscom.google.protobuf.GeneratedMessage.BuilderBuilder implements// protoc_insertion_point(builder_implements:accountService.AccountQryRequest)com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequestOrBuilder {public static final com.google.protobuf.Descriptors.DescriptorgetDescriptor() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryRequest_descriptor;}protected com.google.protobuf.GeneratedMessage.FieldAccessorTableinternalGetFieldAccessorTable() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryRequest_fieldAccessorTable.ensureFieldAccessorsInitialized(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest.class, com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest.Builder.class);}// Construct using com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest.newBuilder()private Builder() {maybeForceBuilderInitialization();}private Builder(com.google.protobuf.GeneratedMessage.BuilderParent parent) {super(parent);maybeForceBuilderInitialization();}private void maybeForceBuilderInitialization() {if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {}}public Builder clear() {super.clear();requestId_ ;userId_ ;return this;}public com.google.protobuf.Descriptors.DescriptorgetDescriptorForType() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryRequest_descriptor;}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest getDefaultInstanceForType() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest.getDefaultInstance();}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest build() {com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest result buildPartial();if (!result.isInitialized()) {throw newUninitializedMessageException(result);}return result;}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest buildPartial() {com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest result new com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest(this);result.requestId_ requestId_;result.userId_ userId_;onBuilt();return result;}public Builder mergeFrom(com.google.protobuf.Message other) {if (other instanceof com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest) {return mergeFrom((com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest)other);} else {super.mergeFrom(other);return this;}}public Builder mergeFrom(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest other) {if (other com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest.getDefaultInstance()) return this;if (!other.getRequestId().isEmpty()) {requestId_ other.requestId_;onChanged();}if (!other.getUserId().isEmpty()) {userId_ other.userId_;onChanged();}onChanged();return this;}public final boolean isInitialized() {return true;}public Builder mergeFrom(com.google.protobuf.CodedInputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws java.io.IOException {com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest parsedMessage null;try {parsedMessage PARSER.parsePartialFrom(input, extensionRegistry);} catch (com.google.protobuf.InvalidProtocolBufferException e) {parsedMessage (com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest) e.getUnfinishedMessage();throw e;} finally {if (parsedMessage ! null) {mergeFrom(parsedMessage);}}return this;}private java.lang.Object requestId_ ;/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public java.lang.String getRequestId() {java.lang.Object ref requestId_;if (!(ref instanceof java.lang.String)) {com.google.protobuf.ByteString bs (com.google.protobuf.ByteString) ref;java.lang.String s bs.toStringUtf8();requestId_ s;return s;} else {return (java.lang.String) ref;}}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public com.google.protobuf.ByteStringgetRequestIdBytes() {java.lang.Object ref requestId_;if (ref instanceof String) {com.google.protobuf.ByteString b com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);requestId_ b;return b;} else {return (com.google.protobuf.ByteString) ref;}}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public Builder setRequestId(java.lang.String value) {if (value null) {throw new NullPointerException();}requestId_ value;onChanged();return this;}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public Builder clearRequestId() {requestId_ getDefaultInstance().getRequestId();onChanged();return this;}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public Builder setRequestIdBytes(com.google.protobuf.ByteString value) {if (value null) {throw new NullPointerException();}checkByteStringIsUtf8(value);requestId_ value;onChanged();return this;}private java.lang.Object userId_ ;/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/public java.lang.String getUserId() {java.lang.Object ref userId_;if (!(ref instanceof java.lang.String)) {com.google.protobuf.ByteString bs (com.google.protobuf.ByteString) ref;java.lang.String s bs.toStringUtf8();userId_ s;return s;} else {return (java.lang.String) ref;}}/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/public com.google.protobuf.ByteStringgetUserIdBytes() {java.lang.Object ref userId_;if (ref instanceof String) {com.google.protobuf.ByteString b com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);userId_ b;return b;} else {return (com.google.protobuf.ByteString) ref;}}/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/public Builder setUserId(java.lang.String value) {if (value null) {throw new NullPointerException();}userId_ value;onChanged();return this;}/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/public Builder clearUserId() {userId_ getDefaultInstance().getUserId();onChanged();return this;}/*** codeoptional string userId 2;/code** pre*用户ID* /pre*/public Builder setUserIdBytes(com.google.protobuf.ByteString value) {if (value null) {throw new NullPointerException();}checkByteStringIsUtf8(value);userId_ value;onChanged();return this;}public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {return this;}public final Builder mergeUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {return this;}// protoc_insertion_point(builder_scope:accountService.AccountQryRequest)}// protoc_insertion_point(class_scope:accountService.AccountQryRequest)private static final com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest DEFAULT_INSTANCE;static {DEFAULT_INSTANCE new com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest();}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest getDefaultInstance() {return DEFAULT_INSTANCE;}private static final com.google.protobuf.ParserAccountQryRequestPARSER new com.google.protobuf.AbstractParserAccountQryRequest() {public AccountQryRequest parsePartialFrom(com.google.protobuf.CodedInputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws com.google.protobuf.InvalidProtocolBufferException {try {return new AccountQryRequest(input, extensionRegistry);} catch (RuntimeException e) {if (e.getCause() instanceofcom.google.protobuf.InvalidProtocolBufferException) {throw (com.google.protobuf.InvalidProtocolBufferException)e.getCause();}throw e;}}};public static com.google.protobuf.ParserAccountQryRequest parser() {return PARSER;}java.lang.Overridepublic com.google.protobuf.ParserAccountQryRequest getParserForType() {return PARSER;}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest getDefaultInstanceForType() {return DEFAULT_INSTANCE;}}public interface AccountQryResponseOrBuilder extends// protoc_insertion_point(interface_extends:accountService.AccountQryResponse)com.google.protobuf.MessageOrBuilder {/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/java.lang.String getRequestId();/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/com.google.protobuf.ByteStringgetRequestIdBytes();/*** codeoptional int32 rc 2;/code** pre*返回码1:成功; -1:失败* /pre*/int getRc();/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/java.lang.String getMsg();/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/com.google.protobuf.ByteStringgetMsgBytes();/*** codeoptional int32 amount 4;/code** pre*账户余额* /pre*/int getAmount();}/*** Protobuf type {code accountService.AccountQryResponse}** pre*账户查询响应* /pre*/public static final class AccountQryResponse extendscom.google.protobuf.GeneratedMessage implements// protoc_insertion_point(message_implements:accountService.AccountQryResponse)AccountQryResponseOrBuilder {// Use AccountQryResponse.newBuilder() to construct.private AccountQryResponse(com.google.protobuf.GeneratedMessage.Builder? builder) {super(builder);}private AccountQryResponse() {requestId_ ;rc_ 0;msg_ ;amount_ 0;}java.lang.Overridepublic final com.google.protobuf.UnknownFieldSetgetUnknownFields() {return com.google.protobuf.UnknownFieldSet.getDefaultInstance();}private AccountQryResponse(com.google.protobuf.CodedInputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry) {this();int mutable_bitField0_ 0;try {boolean done false;while (!done) {int tag input.readTag();switch (tag) {case 0:done true;break;default: {if (!input.skipField(tag)) {done true;}break;}case 10: {java.lang.String s input.readStringRequireUtf8();requestId_ s;break;}case 16: {rc_ input.readInt32();break;}case 26: {java.lang.String s input.readStringRequireUtf8();msg_ s;break;}case 32: {amount_ input.readInt32();break;}}}} catch (com.google.protobuf.InvalidProtocolBufferException e) {throw new RuntimeException(e.setUnfinishedMessage(this));} catch (java.io.IOException e) {throw new RuntimeException(new com.google.protobuf.InvalidProtocolBufferException(e.getMessage()).setUnfinishedMessage(this));} finally {makeExtensionsImmutable();}}public static final com.google.protobuf.Descriptors.DescriptorgetDescriptor() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryResponse_descriptor;}protected com.google.protobuf.GeneratedMessage.FieldAccessorTableinternalGetFieldAccessorTable() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryResponse_fieldAccessorTable.ensureFieldAccessorsInitialized(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse.class, com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse.Builder.class);}public static final int REQUESTID_FIELD_NUMBER 1;private volatile java.lang.Object requestId_;/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public java.lang.String getRequestId() {java.lang.Object ref requestId_;if (ref instanceof java.lang.String) {return (java.lang.String) ref;} else {com.google.protobuf.ByteString bs (com.google.protobuf.ByteString) ref;java.lang.String s bs.toStringUtf8();requestId_ s;return s;}}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public com.google.protobuf.ByteStringgetRequestIdBytes() {java.lang.Object ref requestId_;if (ref instanceof java.lang.String) {com.google.protobuf.ByteString b com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);requestId_ b;return b;} else {return (com.google.protobuf.ByteString) ref;}}public static final int RC_FIELD_NUMBER 2;private int rc_;/*** codeoptional int32 rc 2;/code** pre*返回码1:成功; -1:失败* /pre*/public int getRc() {return rc_;}public static final int MSG_FIELD_NUMBER 3;private volatile java.lang.Object msg_;/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/public java.lang.String getMsg() {java.lang.Object ref msg_;if (ref instanceof java.lang.String) {return (java.lang.String) ref;} else {com.google.protobuf.ByteString bs (com.google.protobuf.ByteString) ref;java.lang.String s bs.toStringUtf8();msg_ s;return s;}}/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/public com.google.protobuf.ByteStringgetMsgBytes() {java.lang.Object ref msg_;if (ref instanceof java.lang.String) {com.google.protobuf.ByteString b com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);msg_ b;return b;} else {return (com.google.protobuf.ByteString) ref;}}public static final int AMOUNT_FIELD_NUMBER 4;private int amount_;/*** codeoptional int32 amount 4;/code** pre*账户余额* /pre*/public int getAmount() {return amount_;}private byte memoizedIsInitialized -1;public final boolean isInitialized() {byte isInitialized memoizedIsInitialized;if (isInitialized 1) return true;if (isInitialized 0) return false;memoizedIsInitialized 1;return true;}public void writeTo(com.google.protobuf.CodedOutputStream output)throws java.io.IOException {if (!getRequestIdBytes().isEmpty()) {com.google.protobuf.GeneratedMessage.writeString(output, 1, requestId_);}if (rc_ ! 0) {output.writeInt32(2, rc_);}if (!getMsgBytes().isEmpty()) {com.google.protobuf.GeneratedMessage.writeString(output, 3, msg_);}if (amount_ ! 0) {output.writeInt32(4, amount_);}}public int getSerializedSize() {int size memoizedSize;if (size ! -1) return size;size 0;if (!getRequestIdBytes().isEmpty()) {size com.google.protobuf.GeneratedMessage.computeStringSize(1, requestId_);}if (rc_ ! 0) {size com.google.protobuf.CodedOutputStream.computeInt32Size(2, rc_);}if (!getMsgBytes().isEmpty()) {size com.google.protobuf.GeneratedMessage.computeStringSize(3, msg_);}if (amount_ ! 0) {size com.google.protobuf.CodedOutputStream.computeInt32Size(4, amount_);}memoizedSize size;return size;}private static final long serialVersionUID 0L;public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseFrom(com.google.protobuf.ByteString data)throws com.google.protobuf.InvalidProtocolBufferException {return PARSER.parseFrom(data);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseFrom(com.google.protobuf.ByteString data,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws com.google.protobuf.InvalidProtocolBufferException {return PARSER.parseFrom(data, extensionRegistry);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseFrom(byte[] data)throws com.google.protobuf.InvalidProtocolBufferException {return PARSER.parseFrom(data);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseFrom(byte[] data,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws com.google.protobuf.InvalidProtocolBufferException {return PARSER.parseFrom(data, extensionRegistry);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseFrom(java.io.InputStream input)throws java.io.IOException {return PARSER.parseFrom(input);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseFrom(java.io.InputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws java.io.IOException {return PARSER.parseFrom(input, extensionRegistry);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseDelimitedFrom(java.io.InputStream input)throws java.io.IOException {return PARSER.parseDelimitedFrom(input);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseDelimitedFrom(java.io.InputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws java.io.IOException {return PARSER.parseDelimitedFrom(input, extensionRegistry);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseFrom(com.google.protobuf.CodedInputStream input)throws java.io.IOException {return PARSER.parseFrom(input);}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parseFrom(com.google.protobuf.CodedInputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws java.io.IOException {return PARSER.parseFrom(input, extensionRegistry);}public Builder newBuilderForType() { return newBuilder(); }public static Builder newBuilder() {return DEFAULT_INSTANCE.toBuilder();}public static Builder newBuilder(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse prototype) {return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);}public Builder toBuilder() {return this DEFAULT_INSTANCE? new Builder() : new Builder().mergeFrom(this);}java.lang.Overrideprotected Builder newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent) {Builder builder new Builder(parent);return builder;}/*** Protobuf type {code accountService.AccountQryResponse}** pre*账户查询响应* /pre*/public static final class Builder extendscom.google.protobuf.GeneratedMessage.BuilderBuilder implements// protoc_insertion_point(builder_implements:accountService.AccountQryResponse)com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponseOrBuilder {public static final com.google.protobuf.Descriptors.DescriptorgetDescriptor() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryResponse_descriptor;}protected com.google.protobuf.GeneratedMessage.FieldAccessorTableinternalGetFieldAccessorTable() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryResponse_fieldAccessorTable.ensureFieldAccessorsInitialized(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse.class, com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse.Builder.class);}// Construct using com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse.newBuilder()private Builder() {maybeForceBuilderInitialization();}private Builder(com.google.protobuf.GeneratedMessage.BuilderParent parent) {super(parent);maybeForceBuilderInitialization();}private void maybeForceBuilderInitialization() {if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {}}public Builder clear() {super.clear();requestId_ ;rc_ 0;msg_ ;amount_ 0;return this;}public com.google.protobuf.Descriptors.DescriptorgetDescriptorForType() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.internal_static_accountService_AccountQryResponse_descriptor;}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse getDefaultInstanceForType() {return com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse.getDefaultInstance();}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse build() {com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse result buildPartial();if (!result.isInitialized()) {throw newUninitializedMessageException(result);}return result;}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse buildPartial() {com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse result new com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse(this);result.requestId_ requestId_;result.rc_ rc_;result.msg_ msg_;result.amount_ amount_;onBuilt();return result;}public Builder mergeFrom(com.google.protobuf.Message other) {if (other instanceof com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse) {return mergeFrom((com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse)other);} else {super.mergeFrom(other);return this;}}public Builder mergeFrom(com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse other) {if (other com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse.getDefaultInstance()) return this;if (!other.getRequestId().isEmpty()) {requestId_ other.requestId_;onChanged();}if (other.getRc() ! 0) {setRc(other.getRc());}if (!other.getMsg().isEmpty()) {msg_ other.msg_;onChanged();}if (other.getAmount() ! 0) {setAmount(other.getAmount());}onChanged();return this;}public final boolean isInitialized() {return true;}public Builder mergeFrom(com.google.protobuf.CodedInputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws java.io.IOException {com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse parsedMessage null;try {parsedMessage PARSER.parsePartialFrom(input, extensionRegistry);} catch (com.google.protobuf.InvalidProtocolBufferException e) {parsedMessage (com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse) e.getUnfinishedMessage();throw e;} finally {if (parsedMessage ! null) {mergeFrom(parsedMessage);}}return this;}private java.lang.Object requestId_ ;/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public java.lang.String getRequestId() {java.lang.Object ref requestId_;if (!(ref instanceof java.lang.String)) {com.google.protobuf.ByteString bs (com.google.protobuf.ByteString) ref;java.lang.String s bs.toStringUtf8();requestId_ s;return s;} else {return (java.lang.String) ref;}}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public com.google.protobuf.ByteStringgetRequestIdBytes() {java.lang.Object ref requestId_;if (ref instanceof String) {com.google.protobuf.ByteString b com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);requestId_ b;return b;} else {return (com.google.protobuf.ByteString) ref;}}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public Builder setRequestId(java.lang.String value) {if (value null) {throw new NullPointerException();}requestId_ value;onChanged();return this;}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public Builder clearRequestId() {requestId_ getDefaultInstance().getRequestId();onChanged();return this;}/*** codeoptional string requestId 1;/code** pre*请求流水* /pre*/public Builder setRequestIdBytes(com.google.protobuf.ByteString value) {if (value null) {throw new NullPointerException();}checkByteStringIsUtf8(value);requestId_ value;onChanged();return this;}private int rc_ ;/*** codeoptional int32 rc 2;/code** pre*返回码1:成功; -1:失败* /pre*/public int getRc() {return rc_;}/*** codeoptional int32 rc 2;/code** pre*返回码1:成功; -1:失败* /pre*/public Builder setRc(int value) {rc_ value;onChanged();return this;}/*** codeoptional int32 rc 2;/code** pre*返回码1:成功; -1:失败* /pre*/public Builder clearRc() {rc_ 0;onChanged();return this;}private java.lang.Object msg_ ;/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/public java.lang.String getMsg() {java.lang.Object ref msg_;if (!(ref instanceof java.lang.String)) {com.google.protobuf.ByteString bs (com.google.protobuf.ByteString) ref;java.lang.String s bs.toStringUtf8();msg_ s;return s;} else {return (java.lang.String) ref;}}/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/public com.google.protobuf.ByteStringgetMsgBytes() {java.lang.Object ref msg_;if (ref instanceof String) {com.google.protobuf.ByteString b com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);msg_ b;return b;} else {return (com.google.protobuf.ByteString) ref;}}/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/public Builder setMsg(java.lang.String value) {if (value null) {throw new NullPointerException();}msg_ value;onChanged();return this;}/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/public Builder clearMsg() {msg_ getDefaultInstance().getMsg();onChanged();return this;}/*** codeoptional string msg 3;/code** pre*错误消息* /pre*/public Builder setMsgBytes(com.google.protobuf.ByteString value) {if (value null) {throw new NullPointerException();}checkByteStringIsUtf8(value);msg_ value;onChanged();return this;}private int amount_ ;/*** codeoptional int32 amount 4;/code** pre*账户余额* /pre*/public int getAmount() {return amount_;}/*** codeoptional int32 amount 4;/code** pre*账户余额* /pre*/public Builder setAmount(int value) {amount_ value;onChanged();return this;}/*** codeoptional int32 amount 4;/code** pre*账户余额* /pre*/public Builder clearAmount() {amount_ 0;onChanged();return this;}public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {return this;}public final Builder mergeUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {return this;}// protoc_insertion_point(builder_scope:accountService.AccountQryResponse)}// protoc_insertion_point(class_scope:accountService.AccountQryResponse)private static final com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse DEFAULT_INSTANCE;static {DEFAULT_INSTANCE new com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse();}public static com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse getDefaultInstance() {return DEFAULT_INSTANCE;}private static final com.google.protobuf.ParserAccountQryResponsePARSER new com.google.protobuf.AbstractParserAccountQryResponse() {public AccountQryResponse parsePartialFrom(com.google.protobuf.CodedInputStream input,com.google.protobuf.ExtensionRegistryLite extensionRegistry)throws com.google.protobuf.InvalidProtocolBufferException {try {return new AccountQryResponse(input, extensionRegistry);} catch (RuntimeException e) {if (e.getCause() instanceofcom.google.protobuf.InvalidProtocolBufferException) {throw (com.google.protobuf.InvalidProtocolBufferException)e.getCause();}throw e;}}};public static com.google.protobuf.ParserAccountQryResponse parser() {return PARSER;}java.lang.Overridepublic com.google.protobuf.ParserAccountQryResponse getParserForType() {return PARSER;}public com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse getDefaultInstanceForType() {return DEFAULT_INSTANCE;}}private static com.google.protobuf.Descriptors.Descriptorinternal_static_accountService_AccountQryRequest_descriptor;private staticcom.google.protobuf.GeneratedMessage.FieldAccessorTableinternal_static_accountService_AccountQryRequest_fieldAccessorTable;private static com.google.protobuf.Descriptors.Descriptorinternal_static_accountService_AccountQryResponse_descriptor;private staticcom.google.protobuf.GeneratedMessage.FieldAccessorTableinternal_static_accountService_AccountQryResponse_fieldAccessorTable;public static com.google.protobuf.Descriptors.FileDescriptorgetDescriptor() {return descriptor;}private static com.google.protobuf.Descriptors.FileDescriptordescriptor;static {java.lang.String[] descriptorData {\n\020AccountQry.proto\022\016accountService\6\n\021Ac countQryRequest\022\021\n\trequestId\030\001 \001(\t\022\016\n\006us erId\030\002 \001(\t\P\n\022AccountQryResponse\022\021\n\trequ estId\030\001 \001(\t\022\n\n\002rc\030\002 \001(\005\022\013\n\003msg\030\003 \001(\t\022\016\n\006 amount\030\004 \001(\0052a\n\021QryAccountService\022L\n\003Qry \022!.accountService.AccountQryRequest\032\.ac countService.AccountQryResponseB0\n\035com.m zsg.demo.grpc.qryaccountB\017QryAccountProt ob\006proto3};com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {public com.google.protobuf.ExtensionRegistry assignDescriptors(com.google.protobuf.Descriptors.FileDescriptor root) {descriptor root;return null;}};com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(descriptorData,new com.google.protobuf.Descriptors.FileDescriptor[] {}, assigner);internal_static_accountService_AccountQryRequest_descriptor getDescriptor().getMessageTypes().get(0);internal_static_accountService_AccountQryRequest_fieldAccessorTable newcom.google.protobuf.GeneratedMessage.FieldAccessorTable(internal_static_accountService_AccountQryRequest_descriptor,new java.lang.String[] { RequestId, UserId, });internal_static_accountService_AccountQryResponse_descriptor getDescriptor().getMessageTypes().get(1);internal_static_accountService_AccountQryResponse_fieldAccessorTable newcom.google.protobuf.GeneratedMessage.FieldAccessorTable(internal_static_accountService_AccountQryResponse_descriptor,new java.lang.String[] { RequestId, Rc, Msg, Amount, });}// protoc_insertion_point(outer_class_scope)
}7、编写接口实现类QryAccountServiceImpl.javapackage com.mzsg.demo.grpc.qryaccount.impl;import com.mzsg.demo.grpc.qryaccount.QryAccountProto;
import com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest;
import com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse;
import com.mzsg.demo.grpc.qryaccount.QryAccountServiceGrpc.QryAccountService;import io.grpc.stub.StreamObserver;public class QryAccountServiceImpl implements QryAccountService {public void qry(AccountQryRequest request, StreamObserverAccountQryResponse responseObserver) {System.out.println(qry request.getUserId());AccountQryResponse response QryAccountProto.AccountQryResponse.newBuilder().setRc(1).setAmount(666).build();responseObserver.onNext(response);responseObserver.onCompleted();}
} View Code 7、编写接口实现类QryAccountServiceImpl.java package com.mzsg.demo.grpc.qryaccount.impl;import com.mzsg.demo.grpc.qryaccount.QryAccountProto;
import com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest;
import com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse;
import com.mzsg.demo.grpc.qryaccount.QryAccountServiceGrpc.QryAccountService;import io.grpc.stub.StreamObserver;public class QryAccountServiceImpl implements QryAccountService {public void qry(AccountQryRequest request, StreamObserverAccountQryResponse responseObserver) {System.out.println(qry request.getUserId());AccountQryResponse response QryAccountProto.AccountQryResponse.newBuilder().setRc(1).setAmount(666).build();responseObserver.onNext(response);responseObserver.onCompleted();}
} 8、编码Server端代码Server.java package com.mzsg.demo.grpc;import java.io.IOException;import com.mzsg.demo.grpc.qryaccount.QryAccountServiceGrpc;
import com.mzsg.demo.grpc.qryaccount.impl.QryAccountServiceImpl;public class Server {private static int port 8883;private static io.grpc.Server server;public void run() {QryAccountServiceGrpc.QryAccountService modifyAccountServiceImpl new QryAccountServiceImpl();server io.grpc.ServerBuilder.forPort(port).addService(QryAccountServiceGrpc.bindService(modifyAccountServiceImpl)).build();try {server.start();System.out.println(Server start success on port: port);server.awaitTermination();} catch (IOException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}public static void main(String[] args) {Server server new Server();server.run();}
} 9、编码Client端代码Client.java package com.mzsg.demo.grpc;import java.io.FileNotFoundException;
import java.io.IOException;import com.mzsg.demo.grpc.qryaccount.QryAccountProto;
import com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryRequest;
import com.mzsg.demo.grpc.qryaccount.QryAccountProto.AccountQryResponse;
import com.mzsg.demo.grpc.qryaccount.QryAccountServiceGrpc;
import com.mzsg.demo.grpc.qryaccount.QryAccountServiceGrpc.QryAccountServiceBlockingStub;import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;public class Client {public static void main( String[] args ) throws FileNotFoundException, IOException{AccountQryRequest request QryAccountProto.AccountQryRequest.newBuilder().setUserId(20012).setRequestId(123).build();ManagedChannel channel ManagedChannelBuilder.forAddress(localhost, 8883).usePlaintext(true).build();QryAccountServiceBlockingStub stub QryAccountServiceGrpc.newBlockingStub(channel);for (int j 0; j 20; j) {long start System.currentTimeMillis();for(int i0; i10000; i){AccountQryResponse rsp stub.qry(request);//System.out.println(rsp);}System.out.println(System.currentTimeMillis() - start MS);}}
} 10、运行Server.java再运行Client.java 简单性能对比每万次调用消耗时间比 实现 时间毫秒 备注 HTTP接口13000 springbootjson客户端采用HttpClient Google Grpc 2100 本demo Facebook swiftThrift 1500 Thrift实现 转载于:https://www.cnblogs.com/mzsg/p/5643367.html
