Go Micro 中文文档发布订阅
发布订阅#
前言：用 Go Micro 的发布订阅构建事件驱动的微服务
概述#
微服务是一种事件驱动的体系结构模式，因此 Go Micro 使用消息代理接口构建异步消息的概念。它可为您无缝地运行 protobuf 类型。自动编码和解码消息，因为它们从代理发送和接收.
默认情况下，go-micro 包括点对点 http 代理，但可以通过 go-plugins 置换实现.
发布消息#
使用 topic 名称和服务客户端创建一个新的发布者
p := micro.NewEvent("events", service.Client())
发布 proto 消息
p.Publish(context.TODO(), &proto.Event{Name: "event"})
订阅#
创建消息处理程序。它的签名应该是 func(context.Context, v interface{}) error
func ProcessEvent(ctx context.Context, event *proto.Event) error {
fmt.Printf("Got event %+v\n", event)
return nil
}
使用 topic 注册消息处理程序
micro.RegisterSubscriber("events", ProcessEvent)
有关完整示例，可参阅 examples/pubsub
关于 LearnKu
粤公网安备 44030502004330号
推荐文章：