Dapr的gRPC接口

Dapr 和 gRPC

Dapr 为本地调用实现 HTTP 和 gRPC API 。 gRPC适用于低延迟、高性能的场景，并且使用原生客户端进行语言集成。

您可以在 这里找到自动生成的客户端 的列表。

Dapr 运行时实现 ，应用程序可以通过 gRPC 进行通信。

除了通过 gRPC 调用 Dapr ， Dapr 也可以通过 gRPC 与应用程序通信。 要做到这一点，应用程序需要托管一个gRPC服务器，并实现Dapr appcallback服务。

这将告诉Dapr通过gRPC与您的应用程序通过5005端口进行通信。

Kubernetes

在Kubernetes中，需要在deployment YAML文件中设置以下注解:

  1. apiVersion: apps/v1
  2. kind: Deployment
  3. metadata:
  4.   name: myapp
  5.   namespace: default
  6.   labels:
  7.     app: myapp
  8. spec:
  9.   replicas: 1
  10.   selector:
  11.     matchLabels:
  12.       app: myapp
  13.   template:
  14.     metadata:
  15.       labels:
  16.         app: myapp
  17.       annotations:
  18.         dapr.io/enabled: "true"
  19.         dapr.io/app-id: "myapp"
  20.         dapr.io/app-protocol: "grpc"
  21.         dapr.io/app-port: "5005"

下面的步骤显示了如何创建 Dapr 客户端并调用 SaveStateData 操作：

  1. 导入包
  3. import (
  4.     "context"
  5.     "log"
  6.     "os"
  8.     dapr "github.com/dapr/go-sdk/client"
  9. )
  1. 创建客户端
  1. 调用 “ SaveState “ 方法
  1. // 保存key1的状态
  2. err = client.SaveState(ctx, "statestore", "key1", data)
  3. if err != nil {
  4.   log.Panic(err)
  5. }
  6. log.Println("data saved")

好耶!

以下步骤将向您显示如何创建一个让Dapr服务器与之通信的应用程序。

  1. 导入包
  1. package main
  3. import (
  4.     "context"
  5.     "fmt"
  6.     "log"
  7.     "net"
  9.     "github.com/golang/protobuf/ptypes/any"
  11.     commonv1pb "github.com/dapr/go-sdk/dapr/proto/common/v1"
  12.     pb "github.com/dapr/go-sdk/dapr/proto/runtime/v1"
  13.     "google.golang.org/grpc"
  14. )
  1. 实现接口
  1. 创建服务器
  1. func main() {
  2.     // create listener
  3.     lis, err := net.Listen("tcp", ":50001")
  4.     if err != nil {
  5.         log.Fatalf("failed to listen: %v", err)
  6.     }
  8.     // create grpc server
  9.     s := grpc.NewServer()
  10.     pb.RegisterAppCallbackServer(s, &server{})
  12.     fmt.Println("Client starting...")
  14.     // 启动......
  15.     if err := s.Serve(lis); err != nil {
  16.         log.Fatalf("failed to serve: %v", err)
  17.     }
  18. }

这将在4000 端口上为应用程序创建一个 gRPC 服务器。

  1. 运行你的应用

使用 Dapr CLI在本地运行：

  1. dapr run --app-id goapp --app-port 4000 --app-protocol grpc go run main.go

Kubernetes 中，必须在您的Pod规范文档中进行如下设置： dapr.io/app-protocol: "grpc" 和 。

相关主题