grpc的具体实现（Java版本）-Toy模板网

这篇具有很好参考价值的文章主要介绍了grpc的具体实现（Java版本）。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

grpc（java实现）

可以看看中文官方文档或者官方文档
grpc是什么，官方文档告诉你，我来告诉你怎么使用Java实现！

maven依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.examole</groupId>
    <artifactId>grpc-study-demo-01</artifactId>
    <version>1.0-SNAPSHOT</version>


    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13</version>
        </dependency>

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.21</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.21</version>
        </dependency>

        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-all</artifactId>
            <version>1.12.0</version>
        </dependency>


    </dependencies>
    <build>
        <extensions>
            <extension>
                <groupId>kr.motd.maven</groupId>
                <artifactId>os-maven-plugin</artifactId>
                <version>1.4.1.Final</version>
            </extension>
        </extensions>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.0</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>
            <plugin>
                <groupId>org.xolstice.maven.plugins</groupId>
                <artifactId>protobuf-maven-plugin</artifactId>
                <version>0.5.0</version>
                <configuration>
                    <pluginId>grpc-java</pluginId>
                    <protocArtifact>com.google.protobuf:protoc:3.0.2:exe:${os.detected.classifier}</protocArtifact>
                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.2.0:exe:${os.detected.classifier}</pluginArtifact>
                </configuration>
                <executions>
                    <execution>
                        <goals>
                            <goal>compile</goal>
                            <goal>compile-custom</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
</project>

proto文件

文件布局：
grpc的具体实现（Java版本）
命名**.proto文件在proto文件夹内

syntax = "proto3"; // 协议版本

// 选项配置
option java_package = "com.example.grpc.api";
option java_outer_classname = "RPCDateServiceApi";
option java_multiple_files = true;

// 定义包名
package com.example.grpc.api;

// 定义服务类型：服务接口.定义请求参数和相应结果
service RPCDateService {
  rpc getDate (RPCDateRequest) returns (RPCDateResponse) {
  }
}

// 定义请求体（即我们发送出去的请求数据的数据类型，由1递增）
message RPCDateRequest {
  int32 id = 1;
  string userName = 2;
  string message = 3;
  int32 age = 4;
}

// 定义相应内容（即定义我们接收请求数据的数据类型）
message RPCDateResponse {
  string serverDate = 1;
}

四种服务类型
grpc的具体实现（Java版本）
other

使用插件生成

grpc的具体实现（Java版本）
成功的话，就会出现下面的target文件
（注意：如果下面的server代码里，调用不出来该用的类，那么注意一下生成的target-》generated-sources-》protobuf下的包类型是否和图中一致，不一致的话：鼠标右击该包-》找到Mark Directory as改变成图中的包样式，这样即可调用插件为我们生成的类）
grpc的具体实现（Java版本）

注意：（如果运行失败且出现下面的报错信息，没有则跳过）
grpc的具体实现（Java版本）
出现这个错误，那代表你的maven版本不够（在setting设置下的maven看一下，我的3.6貌似不行，需要3.8才能运行插件）

服务端server

public class GrpcServer {
    public static void main(String[] args) {
        Server server=null;
        try {
            server = ServerBuilder.forPort(8888)
                    .addService(new MyRPCDateServiceImpl())
                    .build().start();
            server.awaitTermination();//持续等待信息
        } catch (IOException e) {
            System.out.println("server--错误信息===>"+e);
        } catch (InterruptedException e) {
            System.out.println("server--错误信息===>"+e);
        } finally {
            if (server!=null) {
                server.shutdown();
            }
        }
    }
}

实现类

public class MyRPCDateServiceImpl extends RPCDateServiceGrpc.RPCDateServiceImplBase {
    @Override
    public void getDate(RPCDateRequest request, StreamObserver<RPCDateResponse> responseObserver) {
        try {
            String message = request.getId() + "\ngetUserName:" +
                    request.getUserName() + "\ngetMessage:" +
                    request.getMessage() + "\ngetAge:" +
                    request.getAge() + "\ngetSerializedSize:" +
                    request.getAllFields();
            System.out.println("message" + message);
            RPCDateResponse build = RPCDateResponse.newBuilder().setServerDate(message).build();
            System.out.println("bulid:" + build);
            responseObserver.onNext(build);
            responseObserver.onCompleted();
        } catch (Exception e) {
            System.out.println("impl---错误信息====》");
            responseObserver.onError(e);
        }
    }
}

客户端client

public class GrpcClient {
    public static void main(String[] args) {
        //1.拿到一个通信的channel
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost",8888)
                .usePlaintext().build();
        try {
            //2.将信息传入request对象
            RPCDateRequest build = RPCDateRequest.newBuilder()
                    .setId(117)
                    .setUserName("yyx")
                    .setMessage("喜欢吃蔬菜")
                    .setAge(22).build();
            System.out.println("build:" + build+"...");
            RPCDateServiceGrpc.RPCDateServiceBlockingStub stub = RPCDateServiceGrpc.newBlockingStub(channel);
            stub.getDate(build);
            while (true) {
                Scanner scanner = new Scanner(System.in);
                String next = scanner.next();
                if (next .equals("exit")) {
                    break;
                }
            }
        }finally {
            channel.shutdown();
        }
    }
}