消息发布-订阅中间件服务
为了促进产品的平台化建设，把kafka消息队列从服务中抽象出来。让消息队列只关注消息的订阅和发布，使用微服务，减少与业务逻辑的耦合，该服务支持多实例部署。
使用方法：
只需要在models/grpc_server.go文件中填充要接收的消息体和发送的消息体protocolbuffer，业务逻辑在其他业务逻辑服务中实现,本项目写了一个与工作有关的订单和短信订阅和发送实例,其目的是让大家明白怎么样使用该服务。
技术栈1.[**beego**](https://beego.me/)2.[**rpcx**](github.com/smallnest/rpcx)3.[**sarama**](https://github.com/Shopify/sarama)`
Standard `goget`:
```go$ goget-v-ugithub.com/1046102779/message_middleware```
评论