说明

联犀内部默认使用nats进行内部消息流转,使用nats的原因可以参考 nats比较 (opens new window)

联犀底层已经对nats进行了深度封装,将链路追踪,上下文传递, 订阅(同步异步),发布sdk都进行了完善的封装.

链路追踪及上下文传递封装

代码地址: share/events/events.go

订阅及发布封装

代码地址: share/clients/nats.go

快速消息队列

快速消息队列是对以上两个组件的封装,将消息队列的使用变得简单易用,这也是官方推荐使用消息队列的方式

代码地址: share/eventBus/fastEvent.go