• X代表交换机rabbitMQ内部组件,erlang 消息产生者是代码完成,代码的执行效率不高,消息产生者将消息放入交换机,交换机发布订阅把消息发送到所有消息队列中,对应消息队列的消费者拿到消息进行消费

  • 相关场景:邮件群发,群聊天,广播(广告)

    转自:go语言中文文档:www.topgoer.com

目录结构

kuteng-RabbitMQ

-RabbitMQ

--rabitmq.go //这个是RabbitMQ的封装

-Pub

--mainPub.go //Publish 先启动

-Sub

--mainSub.go

-Sub2

--mainSub.go

rabitmq.go代码

mainPub.go代码

mainSub.go代码(两个消费者代码是一样的)