转载

Dapr 运用之 Java gRPC 调用篇

JAVA GRPC 服务与调用

安装协议编译器

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

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

启动 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
StreamObserver<Any>
```
- helloworld.proto
```
Say
SayRequest
SayResponse
onInvoke
```
启动 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 设置调用函数名称

gRPC 服务端收到消息

输出为：

Server: message one
 Server: message two

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

源码地址

原文 http://www.cnblogs.com/Zhang-Xiang/p/12058097.html

正文到此结束

所属分类： Java 编程技术

本文标签： message 编译 App 下载 java 代码 http IDE 安装 src stream apr client id example 服务端源码实例 Service 协议 HTML
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

Dapr 运用之 Java gRPC 调用篇

JAVA GRPC 服务与调用

安装协议编译器

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流