RabbitMQ系列笔记广播模式和路由模式_rabbit 广播模式 路由传值

导语

上一节介绍了简单的工作模式，即一个队列可以被多个消费者进行消费，只有一条消息被送到消费者，采用公平调度的方式，在以往的例子中似乎我们还没用到交换器进行发送消息，我们都知道，往队列里发送消息，是需要用交换器进行分发的消息的，为什么我们没有申请交换器仍然可以发送消息呢？因为在RabbitMQ服务器中，如果不申请交换器，服务器会使用默认的交换器，所以说，交换器在发送消息的时候必不可少，今天我们学习两种交换器分别为fanout（扇形交换器）和direct（直连交换器）

扇形交换器（日志记录器）

特性

分发消息到与之绑定的所有队列，发送消息到交换器时会忽略routing key（路由），我们可以称它为广播消息。
####生产者

申请交换器

• 指定交换器的名字
• 指定交换器的类型

err = ch.ExchangeDeclare(
	"logs",   //交换器的名字
	"fanout", //交换器的类型、这里为广播类型
	true,     //是否持久
	false,    //无用的时候是否自动删除
	false,    //true表示是。客户端无法直接发送msg到内部交换器，只有交换器可以发送msg到内部交换器。
	false,    //no-wait
	nil,      //arguments
)
1
2
3
4
5
6
7
8
9

发送消息

生产者制制定了交换器后就可以直接发送消息了

err = ch.Publish(
	"logs", //发送到交换机的名字
	"",     // 路由，即队列的名字
	false,  //mandatory
	false,  //immediate
	amqp.Publishing{
		DeliveryMode: amqp.Persistent, //消息的持久化
		ContentType:  "text/plain",
		Body:         []byte(body),
	},
)
1
2
3
4
5
6
7
8
9
10
11

消费者

申请交换器

消费者申请交换器需要和生产者完全保持一致。

err = ch.ExchangeDeclare