rabbitmq

README

Broker

Micro中的broker用于代理消息的发布与订阅。

本章节只讲如何使用broker的基础方式

内容

• main.go mian程序运行两个协程10秒钟，各自负责发布与订阅消息。
• plugin.go 引入rabbitmq插件

运行程序

go run main.go plugin.go --broker=rabbitmq

在rabbitmq管理控制台上发送消息

进入控制台的相应的mu.micro.book.topic.queue上发送消息如下图：