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上发送消息如下图: