Dapr 运用之 Java gRPC 调用篇

JAVA GRPC 服务与调用

安装协议编译器

1. 下载对应的版本编译器，并把路径加入到环境变量中，执行如下命令生成代码

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

   -I 表示源码所在文件夹位置，--java_out 表示输出路径，空格后表示具体的 proto 文件位置，如下为示例命令

   protoc -I=C:\Users\JR\DaprDemos\java\examples\src\main\protos\examples --java_out=C:\Users\JR\DaprDemos\java\examples\src\main\java  C:\Users\JR\DaprDemos\java\examples\src\main\protos\examples\helloworld.proto

2. 启动 Dapr gRPC 服务端

   dapr run --app-id hellogrpc --app-port 5000 --protocol grpc -- mvn exec:java -pl=examples -Dexec.mainClass=server.HelloWorldService -Dexec.args="-p 5000"

   服务端主要实现说明
   • 经过 Java SDK（实际此 SDK 可经过 protoc 本身生成，完成没有必要引用官方给的 SDK） 实现 dapr 对 gRPC 的通信封装
   • 服务端 proto 文件为 daprclient.proto ，鉴于语言之间的不一样，名字看上去有点奇怪。（好比：以 client 为后缀，实际是服务端）
   • 若是使用 Java SDK 则须要 Override onInvoke() 函数，该函数为 Dapr gRPC 调用封装。该函数提供两个签名 InvokeEnvelope 和 StreamObserver<Any>
     • InvokeEnvelope 用于解析 gRPC 请求函数
     • StreamObserver<Any> 用于疯转 gRPC 应答
   • helloworld.proto
     • 定义了一个 gRPC 函数 Say
     • 定义了函数签名 SayRequest
     • 定义了函数返回类型 SayResponse
     • 根据步骤1提供的 cmd 命令生成代码以在 onInvoke 函数中调用

3. 启动 Dapr gRPC 客户端

   dapr run --protocol grpc --grpc-port 50001 -- mvn exec:java -pl=examples -Dexec.mainClass=client.HelloWorldClient -Dexec.args="-p 50001 'message one' 'message two'"

   客户端主要实现说明
   • 客户端 proto 文件为 dapr.proto
   • 使用生成代码调用 InvokeServiceEnvelope() 函数
     • setId 设置该函数须要调用的服务 Id ，该 Id 指在使用 Dapr 启动实例时 --app-id 指定的名称（例如步骤2中的 hellogrpc）
     • setData 设置调用函数的签名
     • setMethod 设置调用函数名称

4. gRPC 服务端收到消息

   输出为：

   Server: message one
    Server: message two

至此， Java 客户端服务端经过 Dapr 完成 gRPC 通信。

源码地址