The documentation you are viewing is for Dapr v1.12 which is an older version of Dapr. For up-to-date documentation, see the latest version.

Go SDK 回调 Dapr 服务入门

如何使用 Go SDK 回调 Dapr 服务

Dapr gRPC Service SDK for Go

先决条件

首先导入 Dapr Go service/grpc 包：

daprd "github.com/dapr/go-sdk/service/grpc"

创建和启动服务

要创建 gRPC Dapr服务，首先创建一个带有特定地址的 Dapr 回调实例：

s, err := daprd.NewService(":50001")
if err != nil {
    log.Fatalf("failed to start the server: %v", err)
}

如果您想要合并现有服务 listener，可使用现有的 net.Listener 的地址。

list, err := net.Listen("tcp", "localhost:0")
if err != nil {
    log.Fatalf("gRPC listener creation failed: %s", err)
}
s := daprd.NewServiceWithListener(list)

一旦你创建了一个服务实例，你就可以给该服务 “附加 “任何数量的事件、绑定和服务调用逻辑处理程序。 定义逻辑后，即可启动服务：

if err := s.Start(); err != nil {
    log.Fatalf("server error: %v", err)
}

事件处理

要处理来自特定 topic 的事件，您需要在启动服务之前至少添加一个 topic event handler：

sub := &common.Subscription{
        PubsubName: "messages",
        Topic:      "topic1",
    }
if err := s.AddTopicEventHandler(sub, eventHandler); err != nil {
    log.Fatalf("error adding topic subscription: %v", err)
}

handler 本身可以是具有预期签名的任何方法：

func eventHandler(ctx context.Context, e *common.TopicEvent) (retry bool, err error) {
    log.Printf("event - PubsubName:%s, Topic:%s, ID:%s, Data: %v", e.PubsubName, e.Topic, e.ID, e.Data)
    // do something with the event
    return true, nil
}

服务调用处理

要处理服务调用，您需要在启动服务之前添加至少一个服务调用 handler：

if err := s.AddServiceInvocationHandler("echo", echoHandler); err != nil {
    log.Fatalf("error adding invocation handler: %v", err)
}

handler 本身可以是具有预期签名的任何方法：

func echoHandler(ctx context.Context, in *common.InvocationEvent) (out *common.Content, err error) {
    log.Printf("echo - ContentType:%s, Verb:%s, QueryString:%s, %+v", in.ContentType, in.Verb, in.QueryString, string(in.Data))
    // do something with the invocation here 
    out = &common.Content{
        Data:        in.Data,
        ContentType: in.ContentType,
        DataTypeURL: in.DataTypeURL,
    }
    return
}

绑定调用处理

要处理服务调用，您需要在启动服务之前添加至少一个服务调用 handler：

if err := s.AddBindingInvocationHandler("run", runHandler); err != nil {
    log.Fatalf("error adding binding handler: %v", err)
}

handler 本身可以是具有预期签名的任何方法：

func runHandler(ctx context.Context, in *common.BindingEvent) (out []byte, err error) {
    log.Printf("binding - Data:%v, Meta:%v", in.Data, in.Metadata)
    // do something with the invocation here 
    return nil, nil
}

相关链接