在前一个教程中,我们创建了一个工作队列。工作队列背后的假设是每个任务会被交付给一个【工人】。在这一部分我们将做一些完全不同的事情--我们将向多个【消费者】传递信息。这种模式被称为“发布/订阅”。
为了说明这种模式,我们将构建一个简单的日志系统。它将包括两个程序,第一个将发出日志消息,第二个将接收并打印它们。
在我们的日志系统中每个接收程序的运行副本都会得到消息。这样我们就可以运行一个接收者程序,将日志记录到磁盘;同时我们可以运行另一个接收者程序,并在屏幕上看到打印出来的日志。
从本质上讲,已发布的日志消息将被广播到所有的接收者程序。
1、消息交换机【Exchange】
在教程的前面部分,我们从队列中发送和接收消息。在RabbitMQ中,现在是时候引入全消息模型。
让我们快速看看我们以前的教程讲了什么:
【生产者】:就是一个用于发送消息的用户程序
【消费者】:就是一个用于接收和使用消息的用户程序
【队列】:是一个暂存消息的缓存区
RabbitMQ消息传递模型的核心思想是,【生产者】不直接发送任何信息到队列。事实上,【生产者】根本就不知道消息是否会被传送到任何队列。
相反,【生产者】只能发送消息到【消息交换机】。交换是件很简单的事。一方面它接收来自【生产者】的消息,另一方面是将接收到消息推送到队列中。【消息交换机】必须知道它如何处理接收消息的确切方法。是否应该发送到特定队列?它应该被发送到多个队列呢?或者它应该被丢弃。该规则由【消息交换机】的类型来定义。
这里有一些可用的【消息交换机】的类型:【Direct】直接,【Topic】主题,【Headers】标题和【Fanout】扇出。我们将集中关注最后一个-【Fanout】扇出。让我们创建一个这种类型的【消息交换机】,并给它命名为Logs:
channel.ExchangeDeclare("logs", "fanout");
【Fanout】类型的【消息交换机】非常简单。正如你从名字可能猜出的,它只是传播它收到的所有消息去它知道所有的队列中。这正是我们需要我们的日志记录器。
显示【消息交换机】的列表:
使用Rabbitmqctl列出在服务器上可以运行的最有用的【消息交换机】
sudo rabbitmqctl list_exchanges
在这个列表中会有一些amq.*【消息交换机】和默认(未命名)消息交换机。这些都是默认创建的,但现在不太可能需要使用它们。
默认的消息交换机
在教程前面的部分我们队【消息交换机】是一无所知,但是我依然可以发送消息去想去的队列,那是因为我们使用了默认