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代码(两个消费者代码是一样的)