<dependency> <groupId>io.grpc</groupId> <artifactId>grpc-netty</artifactId> <version>1.16.1</version></dependency><dependency> <groupId>io.grpc</groupId> <artifactId>grpc-protobuf</artifactId> <version>1.16.1</version></dependency><dependency> <groupId>io.grpc</groupId> <artifactId>grpc-stub</artifactId> <version>1.16.1</version></dependency>

syntax = "proto3"; // 告诉编译器此文件使用什么版本的语法，而且默认情况下，编译器在单个 Java 文件中生成所有 Java 代码。option java_multiple_files = true; // 可选配置，再次告诉编译器所有内容都将在单个文件中生成。package org.baeldung.grpc; //最后，我们指定要用于生成的 Java 类的包。

// 定义消息结构体，相当于 Http Request// 并对每个属性都定义数据类型，需要为每个属性分配一个唯一编号，称为标记。此标记由 protobuf 用于表示属性，而不是使用属性名称。// 因此，与 JSON 不同，我们每次都会传递属性名称 name，而 protobuf 将使用数字 1 来表示 name。message HelloRequest { string firstName = 1; string lastName = 2;}
// 定义消息结构体，相当于 Http Response// 这里的响应体定义与 `HelloRequest` 类似。需要注意的是，我们可以在多个消息类型之间使用相同的标记：message HelloResponse { string greeting = 1;}
// 最后，让我们定义服务(method)。对于我们的 HelloService，我这里定义了一个 hello() 操作：单次接受一个请求并返回一个响应service HelloService { rpc hello(HelloRequest) returns (HelloResponse);}

protoc -I=$SRC_DIR --java_out=$DST_DIR $SRC_DIR/HelloService.proto

<build> <extensions> <extension> <groupId>kr.motd.maven</groupId> <artifactId>os-maven-plugin</artifactId> <version>1.6.1</version> </extension> </extensions> <plugins> <plugin> <groupId>org.xolstice.maven.plugins</groupId> <artifactId>protobuf-maven-plugin</artifactId> <version>0.6.1</version> <configuration> <protocArtifact> com.google.protobuf:protoc:3.3.0:exe:${os.detected.classifier} </protocArtifact> <pluginId>grpc-java</pluginId> <pluginArtifact> io.grpc:protoc-gen-grpc-java:1.4.0:exe:${os.detected.classifier} </pluginArtifact> </configuration> <executions> <execution> <goals> <goal>compile</goal> <goal>compile-custom</goal> </goals> </execution> </executions> </plugin> </plugins></build>

public class HelloServiceImpl extends HelloServiceImplBase {  @Override public void hello( HelloRequest request, StreamObserver<HelloResponse> responseObserver) {  String greeting = new StringBuilder() .append("Hello, ") .append(request.getFirstName()) .append(" ") .append(request.getLastName()) .toString();  HelloResponse response = HelloResponse.newBuilder() .setGreeting(greeting) .build();  responseObserver.onNext(response); responseObserver.onCompleted(); }}

public class GrpcServer { public static void main(String[] args) { Server server = ServerBuilder .forPort(8080) .addService(new HelloServiceImpl()).build();  server.start(); server.awaitTermination(); }}

public class GrpcClient { public static void main(String[] args) { // 这里使用 `ManagedChannelBuilder` 创建通道，并指定需要连接的服务器地址和端口。 ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 8080) .usePlaintext() //这里将使用纯文本，无需任何加密 .build();  /** 接下来，我们需要创建一个 Stub，我们将用它来进行实际的调用远程的 hello() 方法。Stub（存根）是客户端与服务器交互的主要方式。使用自动生成Stub时，Stub 类包含了用于包装通道（channel）的构造函数。 **/ HelloServiceGrpc.HelloServiceBlockingStub stub  = HelloServiceGrpc.newBlockingStub(channel);  // 是时候进行 hello() RPC 调用了。在这里，我们传递 Hello 请求。我们可以使用newBuilder 来设置 HelloRequest 对象的姓、名属性。并得到从服务器返回的 HelloResponse 对象。 HelloResponse helloResponse = stub.hello(HelloRequest.newBuilder() .setFirstName("test") .setLastName("gRPC") .build());  channel.shutdown(); }}