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 通信。

源碼地址