diff --git a/pom.xml b/pom.xml index 690560b..52297f7 100644 --- a/pom.xml +++ b/pom.xml @@ -157,6 +157,29 @@ org.springframework.boot spring-boot-maven-plugin + + + org.xolstice.maven.plugins + protobuf-maven-plugin + 0.6.1 + + + ${project.basedir}/src/main/java + + false + com.google.protobuf:protoc:${protobuf.version}:exe:${os.detected.classifier} + grpc-java + io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier} + + + + + compile + compile-custom + + + + diff --git a/src/main/java/io/grpc/examples/client/GrpcClient.java b/src/main/java/io/grpc/examples/client/GrpcClient.java new file mode 100644 index 0000000..1f0dd72 --- /dev/null +++ b/src/main/java/io/grpc/examples/client/GrpcClient.java @@ -0,0 +1,68 @@ +package io.grpc.examples.client; + +import io.grpc.ManagedChannel; +import io.grpc.ManagedChannelBuilder; +import io.grpc.examples.user.*; +import io.grpc.stub.StreamObserver; + +import java.util.Iterator; +import java.util.concurrent.TimeUnit; + +/** + * @Author: zjfan + * @Description: + * @Date: Created in 21:23 2021/2/5 + */ +public class GrpcClient { + public static void main(String[] args) throws InterruptedException { + ManagedChannel managedChannel = ManagedChannelBuilder.forAddress("localhost",8888) + .usePlaintext().build(); + UserServiceGrpc.UserServiceBlockingStub blockingStub = UserServiceGrpc.newBlockingStub(managedChannel); + + // 获取单个用户 + GetUserResponse response = blockingStub.getUser(GetUserRequest.newBuilder().setId(3).build()); + System.out.println(response.getUser().getName()); + + // 获取用户列表 + Iterator allUser = blockingStub.getUserList(GetUserListRequest.newBuilder().setPage(1).setSize(5).build()); + while (allUser.hasNext()){ + User user = allUser.next(); + System.out.println("name: " + user.getName()); + } + + // 间隔一定时间获取用户 + UserServiceGrpc.UserServiceStub stub = UserServiceGrpc.newStub(managedChannel); + + StreamObserver requestStreamObserver = stub.getUserOneByOne(new StreamObserver() { + @Override + public void onNext(User value) { + // 模拟间断请求 + try { + TimeUnit.SECONDS.sleep(1); + } catch (InterruptedException e) { + e.printStackTrace(); + } + System.out.println("name: " + value.getName()); + } + + @Override + public void onError(Throwable t) { + + } + + @Override + public void onCompleted() { + System.out.println("Completed!"); + } + }); + + for(int i=5; i<=10; i++) { + requestStreamObserver.onNext(GetUserRequest.newBuilder().setId(i).build()); + } + + requestStreamObserver.onCompleted(); + + TimeUnit.SECONDS.sleep(30); + + } +} diff --git a/src/main/java/io/grpc/examples/helloworld/GreeterGrpc.java b/src/main/java/io/grpc/examples/helloworld/GreeterGrpc.java index bc39207..8e06d40 100644 --- a/src/main/java/io/grpc/examples/helloworld/GreeterGrpc.java +++ b/src/main/java/io/grpc/examples/helloworld/GreeterGrpc.java @@ -17,29 +17,29 @@ private GreeterGrpc() {} public static final String SERVICE_NAME = "helloworld.Greeter"; // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor getSayHelloMethod; + private static volatile io.grpc.MethodDescriptor getSayHelloMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SayHello", - requestType = HelloRequest.class, - responseType = HelloReply.class, + requestType = io.grpc.examples.helloworld.HelloRequest.class, + responseType = io.grpc.examples.helloworld.HelloReply.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getSayHelloMethod() { - io.grpc.MethodDescriptor getSayHelloMethod; + public static io.grpc.MethodDescriptor getSayHelloMethod() { + io.grpc.MethodDescriptor getSayHelloMethod; if ((getSayHelloMethod = GreeterGrpc.getSayHelloMethod) == null) { synchronized (GreeterGrpc.class) { if ((getSayHelloMethod = GreeterGrpc.getSayHelloMethod) == null) { GreeterGrpc.getSayHelloMethod = getSayHelloMethod = - io.grpc.MethodDescriptor.newBuilder() + io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SayHello")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - HelloRequest.getDefaultInstance())) + io.grpc.examples.helloworld.HelloRequest.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - HelloReply.getDefaultInstance())) + io.grpc.examples.helloworld.HelloReply.getDefaultInstance())) .setSchemaDescriptor(new GreeterMethodDescriptorSupplier("SayHello")) .build(); } @@ -54,7 +54,7 @@ HelloReply> getSayHelloMethod() { public static GreeterStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public GreeterStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new GreeterStub(channel, callOptions); } @@ -69,7 +69,7 @@ public static GreeterBlockingStub newBlockingStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public GreeterBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new GreeterBlockingStub(channel, callOptions); } @@ -84,7 +84,7 @@ public static GreeterFutureStub newFutureStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public GreeterFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new GreeterFutureStub(channel, callOptions); } @@ -104,19 +104,19 @@ public static abstract class GreeterImplBase implements io.grpc.BindableService * Sends a greeting * */ - public void sayHello(HelloRequest request, - io.grpc.stub.StreamObserver responseObserver) { + public void sayHello(io.grpc.examples.helloworld.HelloRequest request, + io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSayHelloMethod(), responseObserver); } - @Override public final io.grpc.ServerServiceDefinition bindService() { + @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( getSayHelloMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< - HelloRequest, - HelloReply>( + io.grpc.examples.helloworld.HelloRequest, + io.grpc.examples.helloworld.HelloReply>( this, METHODID_SAY_HELLO))) .build(); } @@ -133,7 +133,7 @@ private GreeterStub( super(channel, callOptions); } - @Override + @java.lang.Override protected GreeterStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new GreeterStub(channel, callOptions); @@ -144,8 +144,8 @@ protected GreeterStub build( * Sends a greeting * */ - public void sayHello(HelloRequest request, - io.grpc.stub.StreamObserver responseObserver) { + public void sayHello(io.grpc.examples.helloworld.HelloRequest request, + io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getSayHelloMethod(), getCallOptions()), request, responseObserver); } @@ -162,7 +162,7 @@ private GreeterBlockingStub( super(channel, callOptions); } - @Override + @java.lang.Override protected GreeterBlockingStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new GreeterBlockingStub(channel, callOptions); @@ -173,7 +173,7 @@ protected GreeterBlockingStub build( * Sends a greeting * */ - public HelloReply sayHello(HelloRequest request) { + public io.grpc.examples.helloworld.HelloReply sayHello(io.grpc.examples.helloworld.HelloRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSayHelloMethod(), getCallOptions(), request); } @@ -190,7 +190,7 @@ private GreeterFutureStub( super(channel, callOptions); } - @Override + @java.lang.Override protected GreeterFutureStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new GreeterFutureStub(channel, callOptions); @@ -201,8 +201,8 @@ protected GreeterFutureStub build( * Sends a greeting * */ - public com.google.common.util.concurrent.ListenableFuture sayHello( - HelloRequest request) { + public com.google.common.util.concurrent.ListenableFuture sayHello( + io.grpc.examples.helloworld.HelloRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSayHelloMethod(), getCallOptions()), request); } @@ -223,21 +223,21 @@ private static final class MethodHandlers implements this.methodId = methodId; } - @Override - @SuppressWarnings("unchecked") + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_SAY_HELLO: - serviceImpl.sayHello((HelloRequest) request, - (io.grpc.stub.StreamObserver) responseObserver); + serviceImpl.sayHello((io.grpc.examples.helloworld.HelloRequest) request, + (io.grpc.stub.StreamObserver) responseObserver); break; default: throw new AssertionError(); } } - @Override - @SuppressWarnings("unchecked") + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") public io.grpc.stub.StreamObserver invoke( io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { @@ -251,12 +251,12 @@ private static abstract class GreeterBaseDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { GreeterBaseDescriptorSupplier() {} - @Override + @java.lang.Override public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { - return HelloWorld.getDescriptor(); + return io.grpc.examples.helloworld.HelloWorld.getDescriptor(); } - @Override + @java.lang.Override public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { return getFileDescriptor().findServiceByName("Greeter"); } @@ -276,7 +276,7 @@ private static final class GreeterMethodDescriptorSupplier this.methodName = methodName; } - @Override + @java.lang.Override public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { return getServiceDescriptor().findMethodByName(methodName); } diff --git a/src/main/java/io/grpc/examples/helloworld/HelloReply.java b/src/main/java/io/grpc/examples/helloworld/HelloReply.java index 37d93dd..c731d09 100644 --- a/src/main/java/io/grpc/examples/helloworld/HelloReply.java +++ b/src/main/java/io/grpc/examples/helloworld/HelloReply.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/helloworld.proto +// source: helloworld.proto package io.grpc.examples.helloworld; diff --git a/src/main/java/io/grpc/examples/helloworld/HelloReplyOrBuilder.java b/src/main/java/io/grpc/examples/helloworld/HelloReplyOrBuilder.java index 5c0dbc7..b014d86 100644 --- a/src/main/java/io/grpc/examples/helloworld/HelloReplyOrBuilder.java +++ b/src/main/java/io/grpc/examples/helloworld/HelloReplyOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/helloworld.proto +// source: helloworld.proto package io.grpc.examples.helloworld; diff --git a/src/main/java/io/grpc/examples/helloworld/HelloRequest.java b/src/main/java/io/grpc/examples/helloworld/HelloRequest.java index 38d1b66..f5312c0 100644 --- a/src/main/java/io/grpc/examples/helloworld/HelloRequest.java +++ b/src/main/java/io/grpc/examples/helloworld/HelloRequest.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/helloworld.proto +// source: helloworld.proto package io.grpc.examples.helloworld; diff --git a/src/main/java/io/grpc/examples/helloworld/HelloRequestOrBuilder.java b/src/main/java/io/grpc/examples/helloworld/HelloRequestOrBuilder.java index a38f47c..5695708 100644 --- a/src/main/java/io/grpc/examples/helloworld/HelloRequestOrBuilder.java +++ b/src/main/java/io/grpc/examples/helloworld/HelloRequestOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/helloworld.proto +// source: helloworld.proto package io.grpc.examples.helloworld; diff --git a/src/main/java/io/grpc/examples/helloworld/HelloWorld.java b/src/main/java/io/grpc/examples/helloworld/HelloWorld.java index 63d7936..3433324 100644 --- a/src/main/java/io/grpc/examples/helloworld/HelloWorld.java +++ b/src/main/java/io/grpc/examples/helloworld/HelloWorld.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/helloworld.proto +// source: helloworld.proto package io.grpc.examples.helloworld; @@ -33,12 +33,12 @@ public static void registerAllExtensions( descriptor; static { java.lang.String[] descriptorData = { - "\n\037src/main/proto/helloworld.proto\022\nhello" + - "world\"\034\n\014HelloRequest\022\014\n\004name\030\001 \001(\t\"\035\n\nH" + - "elloReply\022\017\n\007message\030\001 \001(\t2I\n\007Greeter\022>\n" + - "\010SayHello\022\030.helloworld.HelloRequest\032\026.he" + - "lloworld.HelloReply\"\000B1\n\033io.grpc.example" + - "s.helloworldB\nHelloWorldP\001\242\002\003HLWb\006proto3" + "\n\020helloworld.proto\022\nhelloworld\"\034\n\014HelloR" + + "equest\022\014\n\004name\030\001 \001(\t\"\035\n\nHelloReply\022\017\n\007me" + + "ssage\030\001 \001(\t2I\n\007Greeter\022>\n\010SayHello\022\030.hel" + + "loworld.HelloRequest\032\026.helloworld.HelloR" + + "eply\"\000B1\n\033io.grpc.examples.helloworldB\nH" + + "elloWorldP\001\242\002\003HLWb\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, diff --git a/src/main/java/io/grpc/examples/manualflowcontrol/HelloReply.java b/src/main/java/io/grpc/examples/manualflowcontrol/HelloReply.java index ce9e9d6..6f18538 100644 --- a/src/main/java/io/grpc/examples/manualflowcontrol/HelloReply.java +++ b/src/main/java/io/grpc/examples/manualflowcontrol/HelloReply.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/hello_streaming.proto +// source: hello_streaming.proto package io.grpc.examples.manualflowcontrol; diff --git a/src/main/java/io/grpc/examples/manualflowcontrol/HelloReplyOrBuilder.java b/src/main/java/io/grpc/examples/manualflowcontrol/HelloReplyOrBuilder.java index d2d05dd..296e4b1 100644 --- a/src/main/java/io/grpc/examples/manualflowcontrol/HelloReplyOrBuilder.java +++ b/src/main/java/io/grpc/examples/manualflowcontrol/HelloReplyOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/hello_streaming.proto +// source: hello_streaming.proto package io.grpc.examples.manualflowcontrol; diff --git a/src/main/java/io/grpc/examples/manualflowcontrol/HelloRequest.java b/src/main/java/io/grpc/examples/manualflowcontrol/HelloRequest.java index 2de4c8e..2716788 100644 --- a/src/main/java/io/grpc/examples/manualflowcontrol/HelloRequest.java +++ b/src/main/java/io/grpc/examples/manualflowcontrol/HelloRequest.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/hello_streaming.proto +// source: hello_streaming.proto package io.grpc.examples.manualflowcontrol; diff --git a/src/main/java/io/grpc/examples/manualflowcontrol/HelloRequestOrBuilder.java b/src/main/java/io/grpc/examples/manualflowcontrol/HelloRequestOrBuilder.java index 3943c06..aab6d83 100644 --- a/src/main/java/io/grpc/examples/manualflowcontrol/HelloRequestOrBuilder.java +++ b/src/main/java/io/grpc/examples/manualflowcontrol/HelloRequestOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/hello_streaming.proto +// source: hello_streaming.proto package io.grpc.examples.manualflowcontrol; diff --git a/src/main/java/io/grpc/examples/manualflowcontrol/HelloStreamingProto.java b/src/main/java/io/grpc/examples/manualflowcontrol/HelloStreamingProto.java index d58531f..93a7cba 100644 --- a/src/main/java/io/grpc/examples/manualflowcontrol/HelloStreamingProto.java +++ b/src/main/java/io/grpc/examples/manualflowcontrol/HelloStreamingProto.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/hello_streaming.proto +// source: hello_streaming.proto package io.grpc.examples.manualflowcontrol; @@ -33,14 +33,14 @@ public static void registerAllExtensions( descriptor; static { java.lang.String[] descriptorData = { - "\n$src/main/proto/hello_streaming.proto\022\021" + - "manualflowcontrol\"\034\n\014HelloRequest\022\014\n\004nam" + - "e\030\001 \001(\t\"\035\n\nHelloReply\022\017\n\007message\030\001 \001(\t2m" + - "\n\020StreamingGreeter\022Y\n\021SayHelloStreaming\022" + - "\037.manualflowcontrol.HelloRequest\032\035.manua" + - "lflowcontrol.HelloReply\"\000(\0010\001BB\n\"io.grpc" + - ".examples.manualflowcontrolB\023HelloStream" + - "ingProtoP\001\242\002\004HLWSb\006proto3" + "\n\025hello_streaming.proto\022\021manualflowcontr" + + "ol\"\034\n\014HelloRequest\022\014\n\004name\030\001 \001(\t\"\035\n\nHell" + + "oReply\022\017\n\007message\030\001 \001(\t2m\n\020StreamingGree" + + "ter\022Y\n\021SayHelloStreaming\022\037.manualflowcon" + + "trol.HelloRequest\032\035.manualflowcontrol.He" + + "lloReply\"\000(\0010\001BB\n\"io.grpc.examples.manua" + + "lflowcontrolB\023HelloStreamingProtoP\001\242\002\004HL" + + "WSb\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, diff --git a/src/main/java/io/grpc/examples/manualflowcontrol/StreamingGreeterGrpc.java b/src/main/java/io/grpc/examples/manualflowcontrol/StreamingGreeterGrpc.java index 7aa2643..fecc16e 100644 --- a/src/main/java/io/grpc/examples/manualflowcontrol/StreamingGreeterGrpc.java +++ b/src/main/java/io/grpc/examples/manualflowcontrol/StreamingGreeterGrpc.java @@ -17,29 +17,29 @@ private StreamingGreeterGrpc() {} public static final String SERVICE_NAME = "manualflowcontrol.StreamingGreeter"; // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor getSayHelloStreamingMethod; + private static volatile io.grpc.MethodDescriptor getSayHelloStreamingMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SayHelloStreaming", - requestType = HelloRequest.class, - responseType = HelloReply.class, + requestType = io.grpc.examples.manualflowcontrol.HelloRequest.class, + responseType = io.grpc.examples.manualflowcontrol.HelloReply.class, methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) - public static io.grpc.MethodDescriptor getSayHelloStreamingMethod() { - io.grpc.MethodDescriptor getSayHelloStreamingMethod; + public static io.grpc.MethodDescriptor getSayHelloStreamingMethod() { + io.grpc.MethodDescriptor getSayHelloStreamingMethod; if ((getSayHelloStreamingMethod = StreamingGreeterGrpc.getSayHelloStreamingMethod) == null) { synchronized (StreamingGreeterGrpc.class) { if ((getSayHelloStreamingMethod = StreamingGreeterGrpc.getSayHelloStreamingMethod) == null) { StreamingGreeterGrpc.getSayHelloStreamingMethod = getSayHelloStreamingMethod = - io.grpc.MethodDescriptor.newBuilder() + io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SayHelloStreaming")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - HelloRequest.getDefaultInstance())) + io.grpc.examples.manualflowcontrol.HelloRequest.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - HelloReply.getDefaultInstance())) + io.grpc.examples.manualflowcontrol.HelloReply.getDefaultInstance())) .setSchemaDescriptor(new StreamingGreeterMethodDescriptorSupplier("SayHelloStreaming")) .build(); } @@ -54,7 +54,7 @@ HelloReply> getSayHelloStreamingMethod() { public static StreamingGreeterStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public StreamingGreeterStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new StreamingGreeterStub(channel, callOptions); } @@ -69,7 +69,7 @@ public static StreamingGreeterBlockingStub newBlockingStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public StreamingGreeterBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new StreamingGreeterBlockingStub(channel, callOptions); } @@ -84,7 +84,7 @@ public static StreamingGreeterFutureStub newFutureStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public StreamingGreeterFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new StreamingGreeterFutureStub(channel, callOptions); } @@ -104,19 +104,19 @@ public static abstract class StreamingGreeterImplBase implements io.grpc.Bindabl * Streams a many greetings * */ - public io.grpc.stub.StreamObserver sayHelloStreaming( - io.grpc.stub.StreamObserver responseObserver) { + public io.grpc.stub.StreamObserver sayHelloStreaming( + io.grpc.stub.StreamObserver responseObserver) { return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getSayHelloStreamingMethod(), responseObserver); } - @Override public final io.grpc.ServerServiceDefinition bindService() { + @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( getSayHelloStreamingMethod(), io.grpc.stub.ServerCalls.asyncBidiStreamingCall( new MethodHandlers< - HelloRequest, - HelloReply>( + io.grpc.examples.manualflowcontrol.HelloRequest, + io.grpc.examples.manualflowcontrol.HelloReply>( this, METHODID_SAY_HELLO_STREAMING))) .build(); } @@ -133,7 +133,7 @@ private StreamingGreeterStub( super(channel, callOptions); } - @Override + @java.lang.Override protected StreamingGreeterStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new StreamingGreeterStub(channel, callOptions); @@ -144,8 +144,8 @@ protected StreamingGreeterStub build( * Streams a many greetings * */ - public io.grpc.stub.StreamObserver sayHelloStreaming( - io.grpc.stub.StreamObserver responseObserver) { + public io.grpc.stub.StreamObserver sayHelloStreaming( + io.grpc.stub.StreamObserver responseObserver) { return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( getChannel().newCall(getSayHelloStreamingMethod(), getCallOptions()), responseObserver); } @@ -162,7 +162,7 @@ private StreamingGreeterBlockingStub( super(channel, callOptions); } - @Override + @java.lang.Override protected StreamingGreeterBlockingStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new StreamingGreeterBlockingStub(channel, callOptions); @@ -180,7 +180,7 @@ private StreamingGreeterFutureStub( super(channel, callOptions); } - @Override + @java.lang.Override protected StreamingGreeterFutureStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new StreamingGreeterFutureStub(channel, callOptions); @@ -202,8 +202,8 @@ private static final class MethodHandlers implements this.methodId = methodId; } - @Override - @SuppressWarnings("unchecked") + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { default: @@ -211,14 +211,14 @@ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserv } } - @Override - @SuppressWarnings("unchecked") + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") public io.grpc.stub.StreamObserver invoke( io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_SAY_HELLO_STREAMING: return (io.grpc.stub.StreamObserver) serviceImpl.sayHelloStreaming( - (io.grpc.stub.StreamObserver) responseObserver); + (io.grpc.stub.StreamObserver) responseObserver); default: throw new AssertionError(); } @@ -229,12 +229,12 @@ private static abstract class StreamingGreeterBaseDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { StreamingGreeterBaseDescriptorSupplier() {} - @Override + @java.lang.Override public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { - return HelloStreamingProto.getDescriptor(); + return io.grpc.examples.manualflowcontrol.HelloStreamingProto.getDescriptor(); } - @Override + @java.lang.Override public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { return getFileDescriptor().findServiceByName("StreamingGreeter"); } @@ -254,7 +254,7 @@ private static final class StreamingGreeterMethodDescriptorSupplier this.methodName = methodName; } - @Override + @java.lang.Override public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { return getServiceDescriptor().findMethodByName(methodName); } diff --git a/src/main/java/io/grpc/examples/routeguide/Feature.java b/src/main/java/io/grpc/examples/routeguide/Feature.java index 7805769..2668841 100644 --- a/src/main/java/io/grpc/examples/routeguide/Feature.java +++ b/src/main/java/io/grpc/examples/routeguide/Feature.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/FeatureDatabase.java b/src/main/java/io/grpc/examples/routeguide/FeatureDatabase.java index 096232c..345a277 100644 --- a/src/main/java/io/grpc/examples/routeguide/FeatureDatabase.java +++ b/src/main/java/io/grpc/examples/routeguide/FeatureDatabase.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/FeatureDatabaseOrBuilder.java b/src/main/java/io/grpc/examples/routeguide/FeatureDatabaseOrBuilder.java index 0b089b5..717c23f 100644 --- a/src/main/java/io/grpc/examples/routeguide/FeatureDatabaseOrBuilder.java +++ b/src/main/java/io/grpc/examples/routeguide/FeatureDatabaseOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/FeatureOrBuilder.java b/src/main/java/io/grpc/examples/routeguide/FeatureOrBuilder.java index 08efba0..a55a0b2 100644 --- a/src/main/java/io/grpc/examples/routeguide/FeatureOrBuilder.java +++ b/src/main/java/io/grpc/examples/routeguide/FeatureOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/Point.java b/src/main/java/io/grpc/examples/routeguide/Point.java index 0bf141c..1d127f3 100644 --- a/src/main/java/io/grpc/examples/routeguide/Point.java +++ b/src/main/java/io/grpc/examples/routeguide/Point.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/PointOrBuilder.java b/src/main/java/io/grpc/examples/routeguide/PointOrBuilder.java index d347604..8a5eac0 100644 --- a/src/main/java/io/grpc/examples/routeguide/PointOrBuilder.java +++ b/src/main/java/io/grpc/examples/routeguide/PointOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/Rectangle.java b/src/main/java/io/grpc/examples/routeguide/Rectangle.java index bb9ad21..ad015fb 100644 --- a/src/main/java/io/grpc/examples/routeguide/Rectangle.java +++ b/src/main/java/io/grpc/examples/routeguide/Rectangle.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/RectangleOrBuilder.java b/src/main/java/io/grpc/examples/routeguide/RectangleOrBuilder.java index 878bd84..f63ffdd 100644 --- a/src/main/java/io/grpc/examples/routeguide/RectangleOrBuilder.java +++ b/src/main/java/io/grpc/examples/routeguide/RectangleOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/RouteGuideGrpc.java b/src/main/java/io/grpc/examples/routeguide/RouteGuideGrpc.java index 5dd3896..057f2c6 100644 --- a/src/main/java/io/grpc/examples/routeguide/RouteGuideGrpc.java +++ b/src/main/java/io/grpc/examples/routeguide/RouteGuideGrpc.java @@ -17,29 +17,29 @@ private RouteGuideGrpc() {} public static final String SERVICE_NAME = "routeguide.RouteGuide"; // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor getGetFeatureMethod; + private static volatile io.grpc.MethodDescriptor getGetFeatureMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetFeature", - requestType = Point.class, - responseType = Feature.class, + requestType = io.grpc.examples.routeguide.Point.class, + responseType = io.grpc.examples.routeguide.Feature.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getGetFeatureMethod() { - io.grpc.MethodDescriptor getGetFeatureMethod; + public static io.grpc.MethodDescriptor getGetFeatureMethod() { + io.grpc.MethodDescriptor getGetFeatureMethod; if ((getGetFeatureMethod = RouteGuideGrpc.getGetFeatureMethod) == null) { synchronized (RouteGuideGrpc.class) { if ((getGetFeatureMethod = RouteGuideGrpc.getGetFeatureMethod) == null) { RouteGuideGrpc.getGetFeatureMethod = getGetFeatureMethod = - io.grpc.MethodDescriptor.newBuilder() + io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetFeature")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - Point.getDefaultInstance())) + io.grpc.examples.routeguide.Point.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - Feature.getDefaultInstance())) + io.grpc.examples.routeguide.Feature.getDefaultInstance())) .setSchemaDescriptor(new RouteGuideMethodDescriptorSupplier("GetFeature")) .build(); } @@ -48,29 +48,29 @@ Feature> getGetFeatureMethod() { return getGetFeatureMethod; } - private static volatile io.grpc.MethodDescriptor getListFeaturesMethod; + private static volatile io.grpc.MethodDescriptor getListFeaturesMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListFeatures", - requestType = Rectangle.class, - responseType = Feature.class, + requestType = io.grpc.examples.routeguide.Rectangle.class, + responseType = io.grpc.examples.routeguide.Feature.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) - public static io.grpc.MethodDescriptor getListFeaturesMethod() { - io.grpc.MethodDescriptor getListFeaturesMethod; + public static io.grpc.MethodDescriptor getListFeaturesMethod() { + io.grpc.MethodDescriptor getListFeaturesMethod; if ((getListFeaturesMethod = RouteGuideGrpc.getListFeaturesMethod) == null) { synchronized (RouteGuideGrpc.class) { if ((getListFeaturesMethod = RouteGuideGrpc.getListFeaturesMethod) == null) { RouteGuideGrpc.getListFeaturesMethod = getListFeaturesMethod = - io.grpc.MethodDescriptor.newBuilder() + io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListFeatures")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - Rectangle.getDefaultInstance())) + io.grpc.examples.routeguide.Rectangle.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - Feature.getDefaultInstance())) + io.grpc.examples.routeguide.Feature.getDefaultInstance())) .setSchemaDescriptor(new RouteGuideMethodDescriptorSupplier("ListFeatures")) .build(); } @@ -79,29 +79,29 @@ Feature> getListFeaturesMethod() { return getListFeaturesMethod; } - private static volatile io.grpc.MethodDescriptor getRecordRouteMethod; + private static volatile io.grpc.MethodDescriptor getRecordRouteMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RecordRoute", - requestType = Point.class, - responseType = RouteSummary.class, + requestType = io.grpc.examples.routeguide.Point.class, + responseType = io.grpc.examples.routeguide.RouteSummary.class, methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) - public static io.grpc.MethodDescriptor getRecordRouteMethod() { - io.grpc.MethodDescriptor getRecordRouteMethod; + public static io.grpc.MethodDescriptor getRecordRouteMethod() { + io.grpc.MethodDescriptor getRecordRouteMethod; if ((getRecordRouteMethod = RouteGuideGrpc.getRecordRouteMethod) == null) { synchronized (RouteGuideGrpc.class) { if ((getRecordRouteMethod = RouteGuideGrpc.getRecordRouteMethod) == null) { RouteGuideGrpc.getRecordRouteMethod = getRecordRouteMethod = - io.grpc.MethodDescriptor.newBuilder() + io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RecordRoute")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - Point.getDefaultInstance())) + io.grpc.examples.routeguide.Point.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - RouteSummary.getDefaultInstance())) + io.grpc.examples.routeguide.RouteSummary.getDefaultInstance())) .setSchemaDescriptor(new RouteGuideMethodDescriptorSupplier("RecordRoute")) .build(); } @@ -110,29 +110,29 @@ RouteSummary> getRecordRouteMethod() { return getRecordRouteMethod; } - private static volatile io.grpc.MethodDescriptor getRouteChatMethod; + private static volatile io.grpc.MethodDescriptor getRouteChatMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RouteChat", - requestType = RouteNote.class, - responseType = RouteNote.class, + requestType = io.grpc.examples.routeguide.RouteNote.class, + responseType = io.grpc.examples.routeguide.RouteNote.class, methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) - public static io.grpc.MethodDescriptor getRouteChatMethod() { - io.grpc.MethodDescriptor getRouteChatMethod; + public static io.grpc.MethodDescriptor getRouteChatMethod() { + io.grpc.MethodDescriptor getRouteChatMethod; if ((getRouteChatMethod = RouteGuideGrpc.getRouteChatMethod) == null) { synchronized (RouteGuideGrpc.class) { if ((getRouteChatMethod = RouteGuideGrpc.getRouteChatMethod) == null) { RouteGuideGrpc.getRouteChatMethod = getRouteChatMethod = - io.grpc.MethodDescriptor.newBuilder() + io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RouteChat")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - RouteNote.getDefaultInstance())) + io.grpc.examples.routeguide.RouteNote.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - RouteNote.getDefaultInstance())) + io.grpc.examples.routeguide.RouteNote.getDefaultInstance())) .setSchemaDescriptor(new RouteGuideMethodDescriptorSupplier("RouteChat")) .build(); } @@ -147,7 +147,7 @@ RouteNote> getRouteChatMethod() { public static RouteGuideStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public RouteGuideStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new RouteGuideStub(channel, callOptions); } @@ -162,7 +162,7 @@ public static RouteGuideBlockingStub newBlockingStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public RouteGuideBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new RouteGuideBlockingStub(channel, callOptions); } @@ -177,7 +177,7 @@ public static RouteGuideFutureStub newFutureStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { - @Override + @java.lang.Override public RouteGuideFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new RouteGuideFutureStub(channel, callOptions); } @@ -200,8 +200,8 @@ public static abstract class RouteGuideImplBase implements io.grpc.BindableServi * position. * */ - public void getFeature(Point request, - io.grpc.stub.StreamObserver responseObserver) { + public void getFeature(io.grpc.examples.routeguide.Point request, + io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetFeatureMethod(), responseObserver); } @@ -214,8 +214,8 @@ public void getFeature(Point request, * huge number of features. * */ - public void listFeatures(Rectangle request, - io.grpc.stub.StreamObserver responseObserver) { + public void listFeatures(io.grpc.examples.routeguide.Rectangle request, + io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListFeaturesMethod(), responseObserver); } @@ -226,8 +226,8 @@ public void listFeatures(Rectangle request, * RouteSummary when traversal is completed. * */ - public io.grpc.stub.StreamObserver recordRoute( - io.grpc.stub.StreamObserver responseObserver) { + public io.grpc.stub.StreamObserver recordRoute( + io.grpc.stub.StreamObserver responseObserver) { return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getRecordRouteMethod(), responseObserver); } @@ -238,40 +238,40 @@ public io.grpc.stub.StreamObserver recordRoute( * while receiving other RouteNotes (e.g. from other users). * */ - public io.grpc.stub.StreamObserver routeChat( - io.grpc.stub.StreamObserver responseObserver) { + public io.grpc.stub.StreamObserver routeChat( + io.grpc.stub.StreamObserver responseObserver) { return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getRouteChatMethod(), responseObserver); } - @Override public final io.grpc.ServerServiceDefinition bindService() { + @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( getGetFeatureMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< - Point, - Feature>( + io.grpc.examples.routeguide.Point, + io.grpc.examples.routeguide.Feature>( this, METHODID_GET_FEATURE))) .addMethod( getListFeaturesMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall( new MethodHandlers< - Rectangle, - Feature>( + io.grpc.examples.routeguide.Rectangle, + io.grpc.examples.routeguide.Feature>( this, METHODID_LIST_FEATURES))) .addMethod( getRecordRouteMethod(), io.grpc.stub.ServerCalls.asyncClientStreamingCall( new MethodHandlers< - Point, - RouteSummary>( + io.grpc.examples.routeguide.Point, + io.grpc.examples.routeguide.RouteSummary>( this, METHODID_RECORD_ROUTE))) .addMethod( getRouteChatMethod(), io.grpc.stub.ServerCalls.asyncBidiStreamingCall( new MethodHandlers< - RouteNote, - RouteNote>( + io.grpc.examples.routeguide.RouteNote, + io.grpc.examples.routeguide.RouteNote>( this, METHODID_ROUTE_CHAT))) .build(); } @@ -288,7 +288,7 @@ private RouteGuideStub( super(channel, callOptions); } - @Override + @java.lang.Override protected RouteGuideStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new RouteGuideStub(channel, callOptions); @@ -302,8 +302,8 @@ protected RouteGuideStub build( * position. * */ - public void getFeature(Point request, - io.grpc.stub.StreamObserver responseObserver) { + public void getFeature(io.grpc.examples.routeguide.Point request, + io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetFeatureMethod(), getCallOptions()), request, responseObserver); } @@ -317,8 +317,8 @@ public void getFeature(Point request, * huge number of features. * */ - public void listFeatures(Rectangle request, - io.grpc.stub.StreamObserver responseObserver) { + public void listFeatures(io.grpc.examples.routeguide.Rectangle request, + io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getListFeaturesMethod(), getCallOptions()), request, responseObserver); } @@ -330,8 +330,8 @@ public void listFeatures(Rectangle request, * RouteSummary when traversal is completed. * */ - public io.grpc.stub.StreamObserver recordRoute( - io.grpc.stub.StreamObserver responseObserver) { + public io.grpc.stub.StreamObserver recordRoute( + io.grpc.stub.StreamObserver responseObserver) { return io.grpc.stub.ClientCalls.asyncClientStreamingCall( getChannel().newCall(getRecordRouteMethod(), getCallOptions()), responseObserver); } @@ -343,8 +343,8 @@ public io.grpc.stub.StreamObserver recordRoute( * while receiving other RouteNotes (e.g. from other users). * */ - public io.grpc.stub.StreamObserver routeChat( - io.grpc.stub.StreamObserver responseObserver) { + public io.grpc.stub.StreamObserver routeChat( + io.grpc.stub.StreamObserver responseObserver) { return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( getChannel().newCall(getRouteChatMethod(), getCallOptions()), responseObserver); } @@ -361,7 +361,7 @@ private RouteGuideBlockingStub( super(channel, callOptions); } - @Override + @java.lang.Override protected RouteGuideBlockingStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new RouteGuideBlockingStub(channel, callOptions); @@ -375,7 +375,7 @@ protected RouteGuideBlockingStub build( * position. * */ - public Feature getFeature(Point request) { + public io.grpc.examples.routeguide.Feature getFeature(io.grpc.examples.routeguide.Point request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetFeatureMethod(), getCallOptions(), request); } @@ -389,8 +389,8 @@ public Feature getFeature(Point request) { * huge number of features. * */ - public java.util.Iterator listFeatures( - Rectangle request) { + public java.util.Iterator listFeatures( + io.grpc.examples.routeguide.Rectangle request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getListFeaturesMethod(), getCallOptions(), request); } @@ -407,7 +407,7 @@ private RouteGuideFutureStub( super(channel, callOptions); } - @Override + @java.lang.Override protected RouteGuideFutureStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new RouteGuideFutureStub(channel, callOptions); @@ -421,8 +421,8 @@ protected RouteGuideFutureStub build( * position. * */ - public com.google.common.util.concurrent.ListenableFuture getFeature( - Point request) { + public com.google.common.util.concurrent.ListenableFuture getFeature( + io.grpc.examples.routeguide.Point request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetFeatureMethod(), getCallOptions()), request); } @@ -446,34 +446,34 @@ private static final class MethodHandlers implements this.methodId = methodId; } - @Override - @SuppressWarnings("unchecked") + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_GET_FEATURE: - serviceImpl.getFeature((Point) request, - (io.grpc.stub.StreamObserver) responseObserver); + serviceImpl.getFeature((io.grpc.examples.routeguide.Point) request, + (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_FEATURES: - serviceImpl.listFeatures((Rectangle) request, - (io.grpc.stub.StreamObserver) responseObserver); + serviceImpl.listFeatures((io.grpc.examples.routeguide.Rectangle) request, + (io.grpc.stub.StreamObserver) responseObserver); break; default: throw new AssertionError(); } } - @Override - @SuppressWarnings("unchecked") + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") public io.grpc.stub.StreamObserver invoke( io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_RECORD_ROUTE: return (io.grpc.stub.StreamObserver) serviceImpl.recordRoute( - (io.grpc.stub.StreamObserver) responseObserver); + (io.grpc.stub.StreamObserver) responseObserver); case METHODID_ROUTE_CHAT: return (io.grpc.stub.StreamObserver) serviceImpl.routeChat( - (io.grpc.stub.StreamObserver) responseObserver); + (io.grpc.stub.StreamObserver) responseObserver); default: throw new AssertionError(); } @@ -484,12 +484,12 @@ private static abstract class RouteGuideBaseDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { RouteGuideBaseDescriptorSupplier() {} - @Override + @java.lang.Override public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { - return RouteGuideProto.getDescriptor(); + return io.grpc.examples.routeguide.RouteGuideProto.getDescriptor(); } - @Override + @java.lang.Override public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { return getFileDescriptor().findServiceByName("RouteGuide"); } @@ -509,7 +509,7 @@ private static final class RouteGuideMethodDescriptorSupplier this.methodName = methodName; } - @Override + @java.lang.Override public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { return getServiceDescriptor().findMethodByName(methodName); } diff --git a/src/main/java/io/grpc/examples/routeguide/RouteGuideProto.java b/src/main/java/io/grpc/examples/routeguide/RouteGuideProto.java index 353405a..8147e89 100644 --- a/src/main/java/io/grpc/examples/routeguide/RouteGuideProto.java +++ b/src/main/java/io/grpc/examples/routeguide/RouteGuideProto.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; @@ -53,26 +53,26 @@ public static void registerAllExtensions( descriptor; static { java.lang.String[] descriptorData = { - "\n src/main/proto/route_guide.proto\022\nrout" + - "eguide\",\n\005Point\022\020\n\010latitude\030\001 \001(\005\022\021\n\tlon" + - "gitude\030\002 \001(\005\"I\n\tRectangle\022\035\n\002lo\030\001 \001(\0132\021." + - "routeguide.Point\022\035\n\002hi\030\002 \001(\0132\021.routeguid" + - "e.Point\"<\n\007Feature\022\014\n\004name\030\001 \001(\t\022#\n\010loca" + - "tion\030\002 \001(\0132\021.routeguide.Point\"7\n\017Feature" + - "Database\022$\n\007feature\030\001 \003(\0132\023.routeguide.F" + - "eature\"A\n\tRouteNote\022#\n\010location\030\001 \001(\0132\021." + - "routeguide.Point\022\017\n\007message\030\002 \001(\t\"b\n\014Rou" + - "teSummary\022\023\n\013point_count\030\001 \001(\005\022\025\n\rfeatur" + - "e_count\030\002 \001(\005\022\020\n\010distance\030\003 \001(\005\022\024\n\014elaps" + - "ed_time\030\004 \001(\0052\205\002\n\nRouteGuide\0226\n\nGetFeatu" + - "re\022\021.routeguide.Point\032\023.routeguide.Featu" + - "re\"\000\022>\n\014ListFeatures\022\025.routeguide.Rectan" + - "gle\032\023.routeguide.Feature\"\0000\001\022>\n\013RecordRo" + - "ute\022\021.routeguide.Point\032\030.routeguide.Rout" + - "eSummary\"\000(\001\022?\n\tRouteChat\022\025.routeguide.R" + - "outeNote\032\025.routeguide.RouteNote\"\000(\0010\001B6\n" + - "\033io.grpc.examples.routeguideB\017RouteGuide" + - "ProtoP\001\242\002\003RTGb\006proto3" + "\n\021route_guide.proto\022\nrouteguide\",\n\005Point" + + "\022\020\n\010latitude\030\001 \001(\005\022\021\n\tlongitude\030\002 \001(\005\"I\n" + + "\tRectangle\022\035\n\002lo\030\001 \001(\0132\021.routeguide.Poin" + + "t\022\035\n\002hi\030\002 \001(\0132\021.routeguide.Point\"<\n\007Feat" + + "ure\022\014\n\004name\030\001 \001(\t\022#\n\010location\030\002 \001(\0132\021.ro" + + "uteguide.Point\"7\n\017FeatureDatabase\022$\n\007fea" + + "ture\030\001 \003(\0132\023.routeguide.Feature\"A\n\tRoute" + + "Note\022#\n\010location\030\001 \001(\0132\021.routeguide.Poin" + + "t\022\017\n\007message\030\002 \001(\t\"b\n\014RouteSummary\022\023\n\013po" + + "int_count\030\001 \001(\005\022\025\n\rfeature_count\030\002 \001(\005\022\020" + + "\n\010distance\030\003 \001(\005\022\024\n\014elapsed_time\030\004 \001(\0052\205" + + "\002\n\nRouteGuide\0226\n\nGetFeature\022\021.routeguide" + + ".Point\032\023.routeguide.Feature\"\000\022>\n\014ListFea" + + "tures\022\025.routeguide.Rectangle\032\023.routeguid" + + "e.Feature\"\0000\001\022>\n\013RecordRoute\022\021.routeguid" + + "e.Point\032\030.routeguide.RouteSummary\"\000(\001\022?\n" + + "\tRouteChat\022\025.routeguide.RouteNote\032\025.rout" + + "eguide.RouteNote\"\000(\0010\001B6\n\033io.grpc.exampl" + + "es.routeguideB\017RouteGuideProtoP\001\242\002\003RTGb\006" + + "proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, diff --git a/src/main/java/io/grpc/examples/routeguide/RouteNote.java b/src/main/java/io/grpc/examples/routeguide/RouteNote.java index 07d5f8d..5b65531 100644 --- a/src/main/java/io/grpc/examples/routeguide/RouteNote.java +++ b/src/main/java/io/grpc/examples/routeguide/RouteNote.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/RouteNoteOrBuilder.java b/src/main/java/io/grpc/examples/routeguide/RouteNoteOrBuilder.java index 2312dcf..023b85b 100644 --- a/src/main/java/io/grpc/examples/routeguide/RouteNoteOrBuilder.java +++ b/src/main/java/io/grpc/examples/routeguide/RouteNoteOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/RouteSummary.java b/src/main/java/io/grpc/examples/routeguide/RouteSummary.java index 059701b..112bc8b 100644 --- a/src/main/java/io/grpc/examples/routeguide/RouteSummary.java +++ b/src/main/java/io/grpc/examples/routeguide/RouteSummary.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/routeguide/RouteSummaryOrBuilder.java b/src/main/java/io/grpc/examples/routeguide/RouteSummaryOrBuilder.java index fdcd6cb..a3de2cc 100644 --- a/src/main/java/io/grpc/examples/routeguide/RouteSummaryOrBuilder.java +++ b/src/main/java/io/grpc/examples/routeguide/RouteSummaryOrBuilder.java @@ -1,5 +1,5 @@ // Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/proto/route_guide.proto +// source: route_guide.proto package io.grpc.examples.routeguide; diff --git a/src/main/java/io/grpc/examples/server/GrpcServer.java b/src/main/java/io/grpc/examples/server/GrpcServer.java new file mode 100644 index 0000000..fbd4050 --- /dev/null +++ b/src/main/java/io/grpc/examples/server/GrpcServer.java @@ -0,0 +1,52 @@ +package io.grpc.examples.server; + +import io.grpc.Server; +import io.grpc.ServerBuilder; +import io.grpc.examples.service.UserServiceImpl; + +import java.io.IOException; + +/** + * @Author: zjfan + * @Description: + * @Date: Created in 21:21 2021/2/5 + */ +public class GrpcServer { + private Server server; + + private void start() throws IOException { + this.server = ServerBuilder + .forPort(8888) + .addService(new UserServiceImpl()) + .build() + .start(); + + System.out.println("server started!"); + + //这是在服务端jvm关闭之前主动退出grpc服务，且关闭其相应的资源 + Runtime.getRuntime().addShutdownHook(new Thread(() -> { + System.out.println("close server"); + GrpcServer.this.stop(); + })); + } + + private void stop(){ + if(null != this.server){ + this.server.shutdown(); + } + } + + //让服务启动后处于等待状态，不然服务已启动马上就停止了 + private void awaitTermination() throws InterruptedException { + if(null != this.server){ + this.server.awaitTermination(); + } + } + + public static void main(String[] args) throws InterruptedException, IOException { + GrpcServer grpcServer = new GrpcServer(); + + grpcServer.start(); + grpcServer.awaitTermination(); + } +} diff --git a/src/main/java/io/grpc/examples/service/UserServiceImpl.java b/src/main/java/io/grpc/examples/service/UserServiceImpl.java new file mode 100644 index 0000000..5c8b664 --- /dev/null +++ b/src/main/java/io/grpc/examples/service/UserServiceImpl.java @@ -0,0 +1,91 @@ +package io.grpc.examples.service; + +import io.grpc.examples.user.*; +import io.grpc.stub.StreamObserver; + +import java.util.*; +import java.util.concurrent.TimeUnit; + +/** + * @Author: zjfan + * @Description: 服务实现类 + * @Date: Created in 21:06 2021/2/5 + */ +public class UserServiceImpl extends UserServiceGrpc.UserServiceImplBase{ + + private static Map userStore = new HashMap<>(); + + static { + for(int i=1; i<=10; i++) { + userStore.put(i, User.newBuilder().setName("小明" + i + "号").build()); + } + } + + /** + * 获取单个用户 + * @param request + * @param responseObserver + */ + @Override + public void getUser(GetUserRequest request, StreamObserver responseObserver) { + + System.out.println("Receive a message from the client： " + request.getId()); + User user = userStore.get(request.getId()); + responseObserver.onNext(GetUserResponse.newBuilder().setUser(user).build()); + responseObserver.onCompleted(); + } + + /** + * 流式获取用户列表 + * @param request + * @param responseObserver + */ + @Override + public void getUserList(GetUserListRequest request, StreamObserver responseObserver) { + List userList = new ArrayList<>(); + userList.addAll(userStore.values()); + int startIndex = (request.getPage()-1) * request.getSize(); + int endIndex = request.getPage() * request.getSize(); + endIndex = endIndex > userStore.size() ? userStore.size() : endIndex; + if(startIndex < userStore.size()){ + Iterator userIterator = userList.subList(startIndex, endIndex).iterator(); + while (userIterator.hasNext()){ + + // 模拟耗时操作 + try { + TimeUnit.SECONDS.sleep(2); + } catch (InterruptedException e) { + e.printStackTrace(); + } + responseObserver.onNext(userIterator.next()); + } + } + responseObserver.onCompleted(); + } + + /** + * 请求和响应都以流式进行 + * @param responseObserver + * @return + */ + @Override + public StreamObserver getUserOneByOne(StreamObserver responseObserver) { + return new StreamObserver() { + @Override + public void onNext(GetUserRequest request) { + User user = userStore.get(request.getId()); + responseObserver.onNext(user); + } + + @Override + public void onError(Throwable t) { + + } + + @Override + public void onCompleted() { + responseObserver.onCompleted(); + } + }; + } +} diff --git a/src/main/java/io/grpc/examples/user/GetUserListRequest.java b/src/main/java/io/grpc/examples/user/GetUserListRequest.java new file mode 100644 index 0000000..b52edc1 --- /dev/null +++ b/src/main/java/io/grpc/examples/user/GetUserListRequest.java @@ -0,0 +1,547 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +/** + * Protobuf type {@code GetUserListRequest} + */ +public final class GetUserListRequest extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:GetUserListRequest) + GetUserListRequestOrBuilder { +private static final long serialVersionUID = 0L; + // Use GetUserListRequest.newBuilder() to construct. + private GetUserListRequest(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private GetUserListRequest() { + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new GetUserListRequest(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private GetUserListRequest( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + 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; + case 8: { + + page_ = input.readInt32(); + break; + } + case 16: { + + size_ = input.readInt32(); + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserListRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserListRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.grpc.examples.user.GetUserListRequest.class, io.grpc.examples.user.GetUserListRequest.Builder.class); + } + + public static final int PAGE_FIELD_NUMBER = 1; + private int page_; + /** + * int32 page = 1; + * @return The page. + */ + @java.lang.Override + public int getPage() { + return page_; + } + + public static final int SIZE_FIELD_NUMBER = 2; + private int size_; + /** + * int32 size = 2; + * @return The size. + */ + @java.lang.Override + public int getSize() { + return size_; + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (page_ != 0) { + output.writeInt32(1, page_); + } + if (size_ != 0) { + output.writeInt32(2, size_); + } + unknownFields.writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (page_ != 0) { + size += com.google.protobuf.CodedOutputStream + .computeInt32Size(1, page_); + } + if (size_ != 0) { + size += com.google.protobuf.CodedOutputStream + .computeInt32Size(2, size_); + } + size += unknownFields.getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof io.grpc.examples.user.GetUserListRequest)) { + return super.equals(obj); + } + io.grpc.examples.user.GetUserListRequest other = (io.grpc.examples.user.GetUserListRequest) obj; + + if (getPage() + != other.getPage()) return false; + if (getSize() + != other.getSize()) return false; + if (!unknownFields.equals(other.unknownFields)) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + PAGE_FIELD_NUMBER; + hash = (53 * hash) + getPage(); + hash = (37 * hash) + SIZE_FIELD_NUMBER; + hash = (53 * hash) + getSize(); + hash = (29 * hash) + unknownFields.hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static io.grpc.examples.user.GetUserListRequest parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static io.grpc.examples.user.GetUserListRequest parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserListRequest parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserListRequest parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(io.grpc.examples.user.GetUserListRequest prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code GetUserListRequest} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:GetUserListRequest) + io.grpc.examples.user.GetUserListRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserListRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserListRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.grpc.examples.user.GetUserListRequest.class, io.grpc.examples.user.GetUserListRequest.Builder.class); + } + + // Construct using io.grpc.examples.user.GetUserListRequest.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessageV3 + .alwaysUseFieldBuilders) { + } + } + @java.lang.Override + public Builder clear() { + super.clear(); + page_ = 0; + + size_ = 0; + + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserListRequest_descriptor; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserListRequest getDefaultInstanceForType() { + return io.grpc.examples.user.GetUserListRequest.getDefaultInstance(); + } + + @java.lang.Override + public io.grpc.examples.user.GetUserListRequest build() { + io.grpc.examples.user.GetUserListRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserListRequest buildPartial() { + io.grpc.examples.user.GetUserListRequest result = new io.grpc.examples.user.GetUserListRequest(this); + result.page_ = page_; + result.size_ = size_; + onBuilt(); + return result; + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.setField(field, value); + } + @java.lang.Override + public Builder clearField( + com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + @java.lang.Override + public Builder clearOneof( + com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.addRepeatedField(field, value); + } + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof io.grpc.examples.user.GetUserListRequest) { + return mergeFrom((io.grpc.examples.user.GetUserListRequest)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(io.grpc.examples.user.GetUserListRequest other) { + if (other == io.grpc.examples.user.GetUserListRequest.getDefaultInstance()) return this; + if (other.getPage() != 0) { + setPage(other.getPage()); + } + if (other.getSize() != 0) { + setSize(other.getSize()); + } + this.mergeUnknownFields(other.unknownFields); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + io.grpc.examples.user.GetUserListRequest parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (io.grpc.examples.user.GetUserListRequest) e.getUnfinishedMessage(); + throw e.unwrapIOException(); + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + + private int page_ ; + /** + * int32 page = 1; + * @return The page. + */ + @java.lang.Override + public int getPage() { + return page_; + } + /** + * int32 page = 1; + * @param value The page to set. + * @return This builder for chaining. + */ + public Builder setPage(int value) { + + page_ = value; + onChanged(); + return this; + } + /** + * int32 page = 1; + * @return This builder for chaining. + */ + public Builder clearPage() { + + page_ = 0; + onChanged(); + return this; + } + + private int size_ ; + /** + * int32 size = 2; + * @return The size. + */ + @java.lang.Override + public int getSize() { + return size_; + } + /** + * int32 size = 2; + * @param value The size to set. + * @return This builder for chaining. + */ + public Builder setSize(int value) { + + size_ = value; + onChanged(); + return this; + } + /** + * int32 size = 2; + * @return This builder for chaining. + */ + public Builder clearSize() { + + size_ = 0; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:GetUserListRequest) + } + + // @@protoc_insertion_point(class_scope:GetUserListRequest) + private static final io.grpc.examples.user.GetUserListRequest DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new io.grpc.examples.user.GetUserListRequest(); + } + + public static io.grpc.examples.user.GetUserListRequest getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public GetUserListRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new GetUserListRequest(input, extensionRegistry); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserListRequest getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + +} + diff --git a/src/main/java/io/grpc/examples/user/GetUserListRequestOrBuilder.java b/src/main/java/io/grpc/examples/user/GetUserListRequestOrBuilder.java new file mode 100644 index 0000000..bb08add --- /dev/null +++ b/src/main/java/io/grpc/examples/user/GetUserListRequestOrBuilder.java @@ -0,0 +1,21 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +public interface GetUserListRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:GetUserListRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * int32 page = 1; + * @return The page. + */ + int getPage(); + + /** + * int32 size = 2; + * @return The size. + */ + int getSize(); +} diff --git a/src/main/java/io/grpc/examples/user/GetUserRequest.java b/src/main/java/io/grpc/examples/user/GetUserRequest.java new file mode 100644 index 0000000..5d419f6 --- /dev/null +++ b/src/main/java/io/grpc/examples/user/GetUserRequest.java @@ -0,0 +1,483 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +/** + * Protobuf type {@code GetUserRequest} + */ +public final class GetUserRequest extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:GetUserRequest) + GetUserRequestOrBuilder { +private static final long serialVersionUID = 0L; + // Use GetUserRequest.newBuilder() to construct. + private GetUserRequest(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private GetUserRequest() { + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new GetUserRequest(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private GetUserRequest( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + 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; + case 8: { + + id_ = input.readInt32(); + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.grpc.examples.user.GetUserRequest.class, io.grpc.examples.user.GetUserRequest.Builder.class); + } + + public static final int ID_FIELD_NUMBER = 1; + private int id_; + /** + * int32 id = 1; + * @return The id. + */ + @java.lang.Override + public int getId() { + return id_; + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (id_ != 0) { + output.writeInt32(1, id_); + } + unknownFields.writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (id_ != 0) { + size += com.google.protobuf.CodedOutputStream + .computeInt32Size(1, id_); + } + size += unknownFields.getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof io.grpc.examples.user.GetUserRequest)) { + return super.equals(obj); + } + io.grpc.examples.user.GetUserRequest other = (io.grpc.examples.user.GetUserRequest) obj; + + if (getId() + != other.getId()) return false; + if (!unknownFields.equals(other.unknownFields)) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + ID_FIELD_NUMBER; + hash = (53 * hash) + getId(); + hash = (29 * hash) + unknownFields.hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static io.grpc.examples.user.GetUserRequest parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserRequest parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserRequest parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserRequest parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserRequest parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserRequest parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static io.grpc.examples.user.GetUserRequest parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserRequest parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static io.grpc.examples.user.GetUserRequest parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserRequest parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(io.grpc.examples.user.GetUserRequest prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code GetUserRequest} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:GetUserRequest) + io.grpc.examples.user.GetUserRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.grpc.examples.user.GetUserRequest.class, io.grpc.examples.user.GetUserRequest.Builder.class); + } + + // Construct using io.grpc.examples.user.GetUserRequest.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessageV3 + .alwaysUseFieldBuilders) { + } + } + @java.lang.Override + public Builder clear() { + super.clear(); + id_ = 0; + + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserRequest_descriptor; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserRequest getDefaultInstanceForType() { + return io.grpc.examples.user.GetUserRequest.getDefaultInstance(); + } + + @java.lang.Override + public io.grpc.examples.user.GetUserRequest build() { + io.grpc.examples.user.GetUserRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserRequest buildPartial() { + io.grpc.examples.user.GetUserRequest result = new io.grpc.examples.user.GetUserRequest(this); + result.id_ = id_; + onBuilt(); + return result; + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.setField(field, value); + } + @java.lang.Override + public Builder clearField( + com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + @java.lang.Override + public Builder clearOneof( + com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.addRepeatedField(field, value); + } + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof io.grpc.examples.user.GetUserRequest) { + return mergeFrom((io.grpc.examples.user.GetUserRequest)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(io.grpc.examples.user.GetUserRequest other) { + if (other == io.grpc.examples.user.GetUserRequest.getDefaultInstance()) return this; + if (other.getId() != 0) { + setId(other.getId()); + } + this.mergeUnknownFields(other.unknownFields); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + io.grpc.examples.user.GetUserRequest parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (io.grpc.examples.user.GetUserRequest) e.getUnfinishedMessage(); + throw e.unwrapIOException(); + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + + private int id_ ; + /** + * int32 id = 1; + * @return The id. + */ + @java.lang.Override + public int getId() { + return id_; + } + /** + * int32 id = 1; + * @param value The id to set. + * @return This builder for chaining. + */ + public Builder setId(int value) { + + id_ = value; + onChanged(); + return this; + } + /** + * int32 id = 1; + * @return This builder for chaining. + */ + public Builder clearId() { + + id_ = 0; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:GetUserRequest) + } + + // @@protoc_insertion_point(class_scope:GetUserRequest) + private static final io.grpc.examples.user.GetUserRequest DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new io.grpc.examples.user.GetUserRequest(); + } + + public static io.grpc.examples.user.GetUserRequest getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public GetUserRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new GetUserRequest(input, extensionRegistry); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserRequest getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + +} + diff --git a/src/main/java/io/grpc/examples/user/GetUserRequestOrBuilder.java b/src/main/java/io/grpc/examples/user/GetUserRequestOrBuilder.java new file mode 100644 index 0000000..8a66e77 --- /dev/null +++ b/src/main/java/io/grpc/examples/user/GetUserRequestOrBuilder.java @@ -0,0 +1,15 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +public interface GetUserRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:GetUserRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * int32 id = 1; + * @return The id. + */ + int getId(); +} diff --git a/src/main/java/io/grpc/examples/user/GetUserResponse.java b/src/main/java/io/grpc/examples/user/GetUserResponse.java new file mode 100644 index 0000000..d08e8de --- /dev/null +++ b/src/main/java/io/grpc/examples/user/GetUserResponse.java @@ -0,0 +1,607 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +/** + * Protobuf type {@code GetUserResponse} + */ +public final class GetUserResponse extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:GetUserResponse) + GetUserResponseOrBuilder { +private static final long serialVersionUID = 0L; + // Use GetUserResponse.newBuilder() to construct. + private GetUserResponse(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private GetUserResponse() { + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new GetUserResponse(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private GetUserResponse( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + 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; + case 10: { + io.grpc.examples.user.User.Builder subBuilder = null; + if (user_ != null) { + subBuilder = user_.toBuilder(); + } + user_ = input.readMessage(io.grpc.examples.user.User.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(user_); + user_ = subBuilder.buildPartial(); + } + + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserResponse_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserResponse_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.grpc.examples.user.GetUserResponse.class, io.grpc.examples.user.GetUserResponse.Builder.class); + } + + public static final int USER_FIELD_NUMBER = 1; + private io.grpc.examples.user.User user_; + /** + * .User user = 1; + * @return Whether the user field is set. + */ + @java.lang.Override + public boolean hasUser() { + return user_ != null; + } + /** + * .User user = 1; + * @return The user. + */ + @java.lang.Override + public io.grpc.examples.user.User getUser() { + return user_ == null ? io.grpc.examples.user.User.getDefaultInstance() : user_; + } + /** + * .User user = 1; + */ + @java.lang.Override + public io.grpc.examples.user.UserOrBuilder getUserOrBuilder() { + return getUser(); + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (user_ != null) { + output.writeMessage(1, getUser()); + } + unknownFields.writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (user_ != null) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(1, getUser()); + } + size += unknownFields.getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof io.grpc.examples.user.GetUserResponse)) { + return super.equals(obj); + } + io.grpc.examples.user.GetUserResponse other = (io.grpc.examples.user.GetUserResponse) obj; + + if (hasUser() != other.hasUser()) return false; + if (hasUser()) { + if (!getUser() + .equals(other.getUser())) return false; + } + if (!unknownFields.equals(other.unknownFields)) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + if (hasUser()) { + hash = (37 * hash) + USER_FIELD_NUMBER; + hash = (53 * hash) + getUser().hashCode(); + } + hash = (29 * hash) + unknownFields.hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static io.grpc.examples.user.GetUserResponse parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserResponse parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserResponse parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserResponse parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserResponse parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.GetUserResponse parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.GetUserResponse parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserResponse parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static io.grpc.examples.user.GetUserResponse parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserResponse parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static io.grpc.examples.user.GetUserResponse parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.grpc.examples.user.GetUserResponse parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(io.grpc.examples.user.GetUserResponse prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code GetUserResponse} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:GetUserResponse) + io.grpc.examples.user.GetUserResponseOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserResponse_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserResponse_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.grpc.examples.user.GetUserResponse.class, io.grpc.examples.user.GetUserResponse.Builder.class); + } + + // Construct using io.grpc.examples.user.GetUserResponse.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessageV3 + .alwaysUseFieldBuilders) { + } + } + @java.lang.Override + public Builder clear() { + super.clear(); + if (userBuilder_ == null) { + user_ = null; + } else { + user_ = null; + userBuilder_ = null; + } + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return io.grpc.examples.user.UserServiceProto.internal_static_GetUserResponse_descriptor; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserResponse getDefaultInstanceForType() { + return io.grpc.examples.user.GetUserResponse.getDefaultInstance(); + } + + @java.lang.Override + public io.grpc.examples.user.GetUserResponse build() { + io.grpc.examples.user.GetUserResponse result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserResponse buildPartial() { + io.grpc.examples.user.GetUserResponse result = new io.grpc.examples.user.GetUserResponse(this); + if (userBuilder_ == null) { + result.user_ = user_; + } else { + result.user_ = userBuilder_.build(); + } + onBuilt(); + return result; + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.setField(field, value); + } + @java.lang.Override + public Builder clearField( + com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + @java.lang.Override + public Builder clearOneof( + com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.addRepeatedField(field, value); + } + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof io.grpc.examples.user.GetUserResponse) { + return mergeFrom((io.grpc.examples.user.GetUserResponse)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(io.grpc.examples.user.GetUserResponse other) { + if (other == io.grpc.examples.user.GetUserResponse.getDefaultInstance()) return this; + if (other.hasUser()) { + mergeUser(other.getUser()); + } + this.mergeUnknownFields(other.unknownFields); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + io.grpc.examples.user.GetUserResponse parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (io.grpc.examples.user.GetUserResponse) e.getUnfinishedMessage(); + throw e.unwrapIOException(); + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + + private io.grpc.examples.user.User user_; + private com.google.protobuf.SingleFieldBuilderV3< + io.grpc.examples.user.User, io.grpc.examples.user.User.Builder, io.grpc.examples.user.UserOrBuilder> userBuilder_; + /** + * .User user = 1; + * @return Whether the user field is set. + */ + public boolean hasUser() { + return userBuilder_ != null || user_ != null; + } + /** + * .User user = 1; + * @return The user. + */ + public io.grpc.examples.user.User getUser() { + if (userBuilder_ == null) { + return user_ == null ? io.grpc.examples.user.User.getDefaultInstance() : user_; + } else { + return userBuilder_.getMessage(); + } + } + /** + * .User user = 1; + */ + public Builder setUser(io.grpc.examples.user.User value) { + if (userBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + user_ = value; + onChanged(); + } else { + userBuilder_.setMessage(value); + } + + return this; + } + /** + * .User user = 1; + */ + public Builder setUser( + io.grpc.examples.user.User.Builder builderForValue) { + if (userBuilder_ == null) { + user_ = builderForValue.build(); + onChanged(); + } else { + userBuilder_.setMessage(builderForValue.build()); + } + + return this; + } + /** + * .User user = 1; + */ + public Builder mergeUser(io.grpc.examples.user.User value) { + if (userBuilder_ == null) { + if (user_ != null) { + user_ = + io.grpc.examples.user.User.newBuilder(user_).mergeFrom(value).buildPartial(); + } else { + user_ = value; + } + onChanged(); + } else { + userBuilder_.mergeFrom(value); + } + + return this; + } + /** + * .User user = 1; + */ + public Builder clearUser() { + if (userBuilder_ == null) { + user_ = null; + onChanged(); + } else { + user_ = null; + userBuilder_ = null; + } + + return this; + } + /** + * .User user = 1; + */ + public io.grpc.examples.user.User.Builder getUserBuilder() { + + onChanged(); + return getUserFieldBuilder().getBuilder(); + } + /** + * .User user = 1; + */ + public io.grpc.examples.user.UserOrBuilder getUserOrBuilder() { + if (userBuilder_ != null) { + return userBuilder_.getMessageOrBuilder(); + } else { + return user_ == null ? + io.grpc.examples.user.User.getDefaultInstance() : user_; + } + } + /** + * .User user = 1; + */ + private com.google.protobuf.SingleFieldBuilderV3< + io.grpc.examples.user.User, io.grpc.examples.user.User.Builder, io.grpc.examples.user.UserOrBuilder> + getUserFieldBuilder() { + if (userBuilder_ == null) { + userBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< + io.grpc.examples.user.User, io.grpc.examples.user.User.Builder, io.grpc.examples.user.UserOrBuilder>( + getUser(), + getParentForChildren(), + isClean()); + user_ = null; + } + return userBuilder_; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:GetUserResponse) + } + + // @@protoc_insertion_point(class_scope:GetUserResponse) + private static final io.grpc.examples.user.GetUserResponse DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new io.grpc.examples.user.GetUserResponse(); + } + + public static io.grpc.examples.user.GetUserResponse getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public GetUserResponse parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new GetUserResponse(input, extensionRegistry); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public io.grpc.examples.user.GetUserResponse getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + +} + diff --git a/src/main/java/io/grpc/examples/user/GetUserResponseOrBuilder.java b/src/main/java/io/grpc/examples/user/GetUserResponseOrBuilder.java new file mode 100644 index 0000000..6174ad7 --- /dev/null +++ b/src/main/java/io/grpc/examples/user/GetUserResponseOrBuilder.java @@ -0,0 +1,24 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +public interface GetUserResponseOrBuilder extends + // @@protoc_insertion_point(interface_extends:GetUserResponse) + com.google.protobuf.MessageOrBuilder { + + /** + * .User user = 1; + * @return Whether the user field is set. + */ + boolean hasUser(); + /** + * .User user = 1; + * @return The user. + */ + io.grpc.examples.user.User getUser(); + /** + * .User user = 1; + */ + io.grpc.examples.user.UserOrBuilder getUserOrBuilder(); +} diff --git a/src/main/java/io/grpc/examples/user/User.java b/src/main/java/io/grpc/examples/user/User.java new file mode 100644 index 0000000..ee91cc1 --- /dev/null +++ b/src/main/java/io/grpc/examples/user/User.java @@ -0,0 +1,557 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +/** + * Protobuf type {@code User} + */ +public final class User extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:User) + UserOrBuilder { +private static final long serialVersionUID = 0L; + // Use User.newBuilder() to construct. + private User(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private User() { + name_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new User(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private User( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + 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; + case 10: { + java.lang.String s = input.readStringRequireUtf8(); + + name_ = s; + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.grpc.examples.user.UserServiceProto.internal_static_User_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.grpc.examples.user.UserServiceProto.internal_static_User_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.grpc.examples.user.User.class, io.grpc.examples.user.User.Builder.class); + } + + public static final int NAME_FIELD_NUMBER = 1; + private volatile java.lang.Object name_; + /** + * string name = 1; + * @return The name. + */ + @java.lang.Override + public java.lang.String getName() { + java.lang.Object ref = name_; + 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(); + name_ = s; + return s; + } + } + /** + * string name = 1; + * @return The bytes for name. + */ + @java.lang.Override + public com.google.protobuf.ByteString + getNameBytes() { + java.lang.Object ref = name_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + name_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (!getNameBytes().isEmpty()) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 1, name_); + } + unknownFields.writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!getNameBytes().isEmpty()) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, name_); + } + size += unknownFields.getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof io.grpc.examples.user.User)) { + return super.equals(obj); + } + io.grpc.examples.user.User other = (io.grpc.examples.user.User) obj; + + if (!getName() + .equals(other.getName())) return false; + if (!unknownFields.equals(other.unknownFields)) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + NAME_FIELD_NUMBER; + hash = (53 * hash) + getName().hashCode(); + hash = (29 * hash) + unknownFields.hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static io.grpc.examples.user.User parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.User parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.User parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.User parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.User parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.grpc.examples.user.User parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.grpc.examples.user.User parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.grpc.examples.user.User parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static io.grpc.examples.user.User parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static io.grpc.examples.user.User parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static io.grpc.examples.user.User parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.grpc.examples.user.User parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(io.grpc.examples.user.User prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code User} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:User) + io.grpc.examples.user.UserOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.grpc.examples.user.UserServiceProto.internal_static_User_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.grpc.examples.user.UserServiceProto.internal_static_User_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.grpc.examples.user.User.class, io.grpc.examples.user.User.Builder.class); + } + + // Construct using io.grpc.examples.user.User.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessageV3 + .alwaysUseFieldBuilders) { + } + } + @java.lang.Override + public Builder clear() { + super.clear(); + name_ = ""; + + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return io.grpc.examples.user.UserServiceProto.internal_static_User_descriptor; + } + + @java.lang.Override + public io.grpc.examples.user.User getDefaultInstanceForType() { + return io.grpc.examples.user.User.getDefaultInstance(); + } + + @java.lang.Override + public io.grpc.examples.user.User build() { + io.grpc.examples.user.User result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public io.grpc.examples.user.User buildPartial() { + io.grpc.examples.user.User result = new io.grpc.examples.user.User(this); + result.name_ = name_; + onBuilt(); + return result; + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.setField(field, value); + } + @java.lang.Override + public Builder clearField( + com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + @java.lang.Override + public Builder clearOneof( + com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.addRepeatedField(field, value); + } + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof io.grpc.examples.user.User) { + return mergeFrom((io.grpc.examples.user.User)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(io.grpc.examples.user.User other) { + if (other == io.grpc.examples.user.User.getDefaultInstance()) return this; + if (!other.getName().isEmpty()) { + name_ = other.name_; + onChanged(); + } + this.mergeUnknownFields(other.unknownFields); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + io.grpc.examples.user.User parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (io.grpc.examples.user.User) e.getUnfinishedMessage(); + throw e.unwrapIOException(); + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + + private java.lang.Object name_ = ""; + /** + * string name = 1; + * @return The name. + */ + public java.lang.String getName() { + java.lang.Object ref = name_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + name_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string name = 1; + * @return The bytes for name. + */ + public com.google.protobuf.ByteString + getNameBytes() { + java.lang.Object ref = name_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + name_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string name = 1; + * @param value The name to set. + * @return This builder for chaining. + */ + public Builder setName( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + name_ = value; + onChanged(); + return this; + } + /** + * string name = 1; + * @return This builder for chaining. + */ + public Builder clearName() { + + name_ = getDefaultInstance().getName(); + onChanged(); + return this; + } + /** + * string name = 1; + * @param value The bytes for name to set. + * @return This builder for chaining. + */ + public Builder setNameBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + + name_ = value; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:User) + } + + // @@protoc_insertion_point(class_scope:User) + private static final io.grpc.examples.user.User DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new io.grpc.examples.user.User(); + } + + public static io.grpc.examples.user.User getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public User parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new User(input, extensionRegistry); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public io.grpc.examples.user.User getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + +} + diff --git a/src/main/java/io/grpc/examples/user/UserOrBuilder.java b/src/main/java/io/grpc/examples/user/UserOrBuilder.java new file mode 100644 index 0000000..4e7ee39 --- /dev/null +++ b/src/main/java/io/grpc/examples/user/UserOrBuilder.java @@ -0,0 +1,21 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +public interface UserOrBuilder extends + // @@protoc_insertion_point(interface_extends:User) + com.google.protobuf.MessageOrBuilder { + + /** + * string name = 1; + * @return The name. + */ + java.lang.String getName(); + /** + * string name = 1; + * @return The bytes for name. + */ + com.google.protobuf.ByteString + getNameBytes(); +} diff --git a/src/main/java/io/grpc/examples/user/UserServiceGrpc.java b/src/main/java/io/grpc/examples/user/UserServiceGrpc.java new file mode 100644 index 0000000..5463b85 --- /dev/null +++ b/src/main/java/io/grpc/examples/user/UserServiceGrpc.java @@ -0,0 +1,400 @@ +package io.grpc.examples.user; + +import static io.grpc.MethodDescriptor.generateFullMethodName; + +/** + */ +@javax.annotation.Generated( + value = "by gRPC proto compiler (version 1.35.0)", + comments = "Source: UserService.proto") +public final class UserServiceGrpc { + + private UserServiceGrpc() {} + + public static final String SERVICE_NAME = "UserService"; + + // Static method descriptors that strictly reflect the proto. + private static volatile io.grpc.MethodDescriptor getGetUserMethod; + + @io.grpc.stub.annotations.RpcMethod( + fullMethodName = SERVICE_NAME + '/' + "GetUser", + requestType = io.grpc.examples.user.GetUserRequest.class, + responseType = io.grpc.examples.user.GetUserResponse.class, + methodType = io.grpc.MethodDescriptor.MethodType.UNARY) + public static io.grpc.MethodDescriptor getGetUserMethod() { + io.grpc.MethodDescriptor getGetUserMethod; + if ((getGetUserMethod = UserServiceGrpc.getGetUserMethod) == null) { + synchronized (UserServiceGrpc.class) { + if ((getGetUserMethod = UserServiceGrpc.getGetUserMethod) == null) { + UserServiceGrpc.getGetUserMethod = getGetUserMethod = + io.grpc.MethodDescriptor.newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetUser")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + io.grpc.examples.user.GetUserRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + io.grpc.examples.user.GetUserResponse.getDefaultInstance())) + .setSchemaDescriptor(new UserServiceMethodDescriptorSupplier("GetUser")) + .build(); + } + } + } + return getGetUserMethod; + } + + private static volatile io.grpc.MethodDescriptor getGetUserListMethod; + + @io.grpc.stub.annotations.RpcMethod( + fullMethodName = SERVICE_NAME + '/' + "GetUserList", + requestType = io.grpc.examples.user.GetUserListRequest.class, + responseType = io.grpc.examples.user.User.class, + methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) + public static io.grpc.MethodDescriptor getGetUserListMethod() { + io.grpc.MethodDescriptor getGetUserListMethod; + if ((getGetUserListMethod = UserServiceGrpc.getGetUserListMethod) == null) { + synchronized (UserServiceGrpc.class) { + if ((getGetUserListMethod = UserServiceGrpc.getGetUserListMethod) == null) { + UserServiceGrpc.getGetUserListMethod = getGetUserListMethod = + io.grpc.MethodDescriptor.newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetUserList")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + io.grpc.examples.user.GetUserListRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + io.grpc.examples.user.User.getDefaultInstance())) + .setSchemaDescriptor(new UserServiceMethodDescriptorSupplier("GetUserList")) + .build(); + } + } + } + return getGetUserListMethod; + } + + private static volatile io.grpc.MethodDescriptor getGetUserOneByOneMethod; + + @io.grpc.stub.annotations.RpcMethod( + fullMethodName = SERVICE_NAME + '/' + "GetUserOneByOne", + requestType = io.grpc.examples.user.GetUserRequest.class, + responseType = io.grpc.examples.user.User.class, + methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) + public static io.grpc.MethodDescriptor getGetUserOneByOneMethod() { + io.grpc.MethodDescriptor getGetUserOneByOneMethod; + if ((getGetUserOneByOneMethod = UserServiceGrpc.getGetUserOneByOneMethod) == null) { + synchronized (UserServiceGrpc.class) { + if ((getGetUserOneByOneMethod = UserServiceGrpc.getGetUserOneByOneMethod) == null) { + UserServiceGrpc.getGetUserOneByOneMethod = getGetUserOneByOneMethod = + io.grpc.MethodDescriptor.newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetUserOneByOne")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + io.grpc.examples.user.GetUserRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + io.grpc.examples.user.User.getDefaultInstance())) + .setSchemaDescriptor(new UserServiceMethodDescriptorSupplier("GetUserOneByOne")) + .build(); + } + } + } + return getGetUserOneByOneMethod; + } + + /** + * Creates a new async stub that supports all call types for the service + */ + public static UserServiceStub newStub(io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public UserServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new UserServiceStub(channel, callOptions); + } + }; + return UserServiceStub.newStub(factory, channel); + } + + /** + * Creates a new blocking-style stub that supports unary and streaming output calls on the service + */ + public static UserServiceBlockingStub newBlockingStub( + io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public UserServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new UserServiceBlockingStub(channel, callOptions); + } + }; + return UserServiceBlockingStub.newStub(factory, channel); + } + + /** + * Creates a new ListenableFuture-style stub that supports unary calls on the service + */ + public static UserServiceFutureStub newFutureStub( + io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public UserServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new UserServiceFutureStub(channel, callOptions); + } + }; + return UserServiceFutureStub.newStub(factory, channel); + } + + /** + */ + public static abstract class UserServiceImplBase implements io.grpc.BindableService { + + /** + */ + public void getUser(io.grpc.examples.user.GetUserRequest request, + io.grpc.stub.StreamObserver responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetUserMethod(), responseObserver); + } + + /** + */ + public void getUserList(io.grpc.examples.user.GetUserListRequest request, + io.grpc.stub.StreamObserver responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetUserListMethod(), responseObserver); + } + + /** + */ + public io.grpc.stub.StreamObserver getUserOneByOne( + io.grpc.stub.StreamObserver responseObserver) { + return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getGetUserOneByOneMethod(), responseObserver); + } + + @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { + return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) + .addMethod( + getGetUserMethod(), + io.grpc.stub.ServerCalls.asyncUnaryCall( + new MethodHandlers< + io.grpc.examples.user.GetUserRequest, + io.grpc.examples.user.GetUserResponse>( + this, METHODID_GET_USER))) + .addMethod( + getGetUserListMethod(), + io.grpc.stub.ServerCalls.asyncServerStreamingCall( + new MethodHandlers< + io.grpc.examples.user.GetUserListRequest, + io.grpc.examples.user.User>( + this, METHODID_GET_USER_LIST))) + .addMethod( + getGetUserOneByOneMethod(), + io.grpc.stub.ServerCalls.asyncBidiStreamingCall( + new MethodHandlers< + io.grpc.examples.user.GetUserRequest, + io.grpc.examples.user.User>( + this, METHODID_GET_USER_ONE_BY_ONE))) + .build(); + } + } + + /** + */ + public static final class UserServiceStub extends io.grpc.stub.AbstractAsyncStub { + private UserServiceStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected UserServiceStub build( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new UserServiceStub(channel, callOptions); + } + + /** + */ + public void getUser(io.grpc.examples.user.GetUserRequest request, + io.grpc.stub.StreamObserver responseObserver) { + io.grpc.stub.ClientCalls.asyncUnaryCall( + getChannel().newCall(getGetUserMethod(), getCallOptions()), request, responseObserver); + } + + /** + */ + public void getUserList(io.grpc.examples.user.GetUserListRequest request, + io.grpc.stub.StreamObserver responseObserver) { + io.grpc.stub.ClientCalls.asyncServerStreamingCall( + getChannel().newCall(getGetUserListMethod(), getCallOptions()), request, responseObserver); + } + + /** + */ + public io.grpc.stub.StreamObserver getUserOneByOne( + io.grpc.stub.StreamObserver responseObserver) { + return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( + getChannel().newCall(getGetUserOneByOneMethod(), getCallOptions()), responseObserver); + } + } + + /** + */ + public static final class UserServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub { + private UserServiceBlockingStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected UserServiceBlockingStub build( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new UserServiceBlockingStub(channel, callOptions); + } + + /** + */ + public io.grpc.examples.user.GetUserResponse getUser(io.grpc.examples.user.GetUserRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getGetUserMethod(), getCallOptions(), request); + } + + /** + */ + public java.util.Iterator getUserList( + io.grpc.examples.user.GetUserListRequest request) { + return io.grpc.stub.ClientCalls.blockingServerStreamingCall( + getChannel(), getGetUserListMethod(), getCallOptions(), request); + } + } + + /** + */ + public static final class UserServiceFutureStub extends io.grpc.stub.AbstractFutureStub { + private UserServiceFutureStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected UserServiceFutureStub build( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new UserServiceFutureStub(channel, callOptions); + } + + /** + */ + public com.google.common.util.concurrent.ListenableFuture getUser( + io.grpc.examples.user.GetUserRequest request) { + return io.grpc.stub.ClientCalls.futureUnaryCall( + getChannel().newCall(getGetUserMethod(), getCallOptions()), request); + } + } + + private static final int METHODID_GET_USER = 0; + private static final int METHODID_GET_USER_LIST = 1; + private static final int METHODID_GET_USER_ONE_BY_ONE = 2; + + private static final class MethodHandlers implements + io.grpc.stub.ServerCalls.UnaryMethod, + io.grpc.stub.ServerCalls.ServerStreamingMethod, + io.grpc.stub.ServerCalls.ClientStreamingMethod, + io.grpc.stub.ServerCalls.BidiStreamingMethod { + private final UserServiceImplBase serviceImpl; + private final int methodId; + + MethodHandlers(UserServiceImplBase serviceImpl, int methodId) { + this.serviceImpl = serviceImpl; + this.methodId = methodId; + } + + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") + public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { + switch (methodId) { + case METHODID_GET_USER: + serviceImpl.getUser((io.grpc.examples.user.GetUserRequest) request, + (io.grpc.stub.StreamObserver) responseObserver); + break; + case METHODID_GET_USER_LIST: + serviceImpl.getUserList((io.grpc.examples.user.GetUserListRequest) request, + (io.grpc.stub.StreamObserver) responseObserver); + break; + default: + throw new AssertionError(); + } + } + + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") + public io.grpc.stub.StreamObserver invoke( + io.grpc.stub.StreamObserver responseObserver) { + switch (methodId) { + case METHODID_GET_USER_ONE_BY_ONE: + return (io.grpc.stub.StreamObserver) serviceImpl.getUserOneByOne( + (io.grpc.stub.StreamObserver) responseObserver); + default: + throw new AssertionError(); + } + } + } + + private static abstract class UserServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { + UserServiceBaseDescriptorSupplier() {} + + @java.lang.Override + public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { + return io.grpc.examples.user.UserServiceProto.getDescriptor(); + } + + @java.lang.Override + public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { + return getFileDescriptor().findServiceByName("UserService"); + } + } + + private static final class UserServiceFileDescriptorSupplier + extends UserServiceBaseDescriptorSupplier { + UserServiceFileDescriptorSupplier() {} + } + + private static final class UserServiceMethodDescriptorSupplier + extends UserServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { + private final String methodName; + + UserServiceMethodDescriptorSupplier(String methodName) { + this.methodName = methodName; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { + return getServiceDescriptor().findMethodByName(methodName); + } + } + + private static volatile io.grpc.ServiceDescriptor serviceDescriptor; + + public static io.grpc.ServiceDescriptor getServiceDescriptor() { + io.grpc.ServiceDescriptor result = serviceDescriptor; + if (result == null) { + synchronized (UserServiceGrpc.class) { + result = serviceDescriptor; + if (result == null) { + serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) + .setSchemaDescriptor(new UserServiceFileDescriptorSupplier()) + .addMethod(getGetUserMethod()) + .addMethod(getGetUserListMethod()) + .addMethod(getGetUserOneByOneMethod()) + .build(); + } + } + } + return result; + } +} diff --git a/src/main/java/io/grpc/examples/user/UserServiceProto.java b/src/main/java/io/grpc/examples/user/UserServiceProto.java new file mode 100644 index 0000000..ad831f4 --- /dev/null +++ b/src/main/java/io/grpc/examples/user/UserServiceProto.java @@ -0,0 +1,88 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: UserService.proto + +package io.grpc.examples.user; + +public final class UserServiceProto { + private UserServiceProto() {} + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistryLite registry) { + } + + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistry registry) { + registerAllExtensions( + (com.google.protobuf.ExtensionRegistryLite) registry); + } + static final com.google.protobuf.Descriptors.Descriptor + internal_static_GetUserRequest_descriptor; + static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_GetUserRequest_fieldAccessorTable; + static final com.google.protobuf.Descriptors.Descriptor + internal_static_GetUserResponse_descriptor; + static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_GetUserResponse_fieldAccessorTable; + static final com.google.protobuf.Descriptors.Descriptor + internal_static_GetUserListRequest_descriptor; + static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_GetUserListRequest_fieldAccessorTable; + static final com.google.protobuf.Descriptors.Descriptor + internal_static_User_descriptor; + static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_User_fieldAccessorTable; + + public static com.google.protobuf.Descriptors.FileDescriptor + getDescriptor() { + return descriptor; + } + private static com.google.protobuf.Descriptors.FileDescriptor + descriptor; + static { + java.lang.String[] descriptorData = { + "\n\021UserService.proto\"\034\n\016GetUserRequest\022\n\n" + + "\002id\030\001 \001(\005\"&\n\017GetUserResponse\022\023\n\004user\030\001 \001" + + "(\0132\005.User\"0\n\022GetUserListRequest\022\014\n\004page\030" + + "\001 \001(\005\022\014\n\004size\030\002 \001(\005\"\024\n\004User\022\014\n\004name\030\001 \001(" + + "\t2\235\001\n\013UserService\022.\n\007GetUser\022\017.GetUserRe" + + "quest\032\020.GetUserResponse\"\000\022-\n\013GetUserList" + + "\022\023.GetUserListRequest\032\005.User\"\0000\001\022/\n\017GetU" + + "serOneByOne\022\017.GetUserRequest\032\005.User\"\000(\0010" + + "\001B+\n\025io.grpc.examples.userB\020UserServiceP" + + "rotoP\001b\006proto3" + }; + descriptor = com.google.protobuf.Descriptors.FileDescriptor + .internalBuildGeneratedFileFrom(descriptorData, + new com.google.protobuf.Descriptors.FileDescriptor[] { + }); + internal_static_GetUserRequest_descriptor = + getDescriptor().getMessageTypes().get(0); + internal_static_GetUserRequest_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_GetUserRequest_descriptor, + new java.lang.String[] { "Id", }); + internal_static_GetUserResponse_descriptor = + getDescriptor().getMessageTypes().get(1); + internal_static_GetUserResponse_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_GetUserResponse_descriptor, + new java.lang.String[] { "User", }); + internal_static_GetUserListRequest_descriptor = + getDescriptor().getMessageTypes().get(2); + internal_static_GetUserListRequest_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_GetUserListRequest_descriptor, + new java.lang.String[] { "Page", "Size", }); + internal_static_User_descriptor = + getDescriptor().getMessageTypes().get(3); + internal_static_User_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_User_descriptor, + new java.lang.String[] { "Name", }); + } + + // @@protoc_insertion_point(outer_class_scope) +} diff --git a/src/main/proto/UserService.proto b/src/main/proto/UserService.proto new file mode 100644 index 0000000..09be2a6 --- /dev/null +++ b/src/main/proto/UserService.proto @@ -0,0 +1,28 @@ +syntax = "proto3"; + +option java_multiple_files = true; +option java_package = "io.grpc.examples.user"; +option java_outer_classname = "UserServiceProto"; + +service UserService { + rpc GetUser (GetUserRequest) returns (GetUserResponse) {} + rpc GetUserList (GetUserListRequest) returns (stream User) {} + rpc GetUserOneByOne (stream GetUserRequest) returns (stream User) {} +} + +message GetUserRequest { + int32 id = 1; +} + +message GetUserResponse { + User user = 1; +} + +message GetUserListRequest { + int32 page = 1; + int32 size = 2; +} + +message User { + string name = 1; +} \ No newline at end of file