上一篇部落格中，我們實現了工作佇列，並且我們的工作佇列中的一個任務只會發給一個工作者，除非某個工作者未完成任務意外被殺死，會轉發給另外的工作者。在這部分中，我們會做一些完全不同的事情 - 我們會向多個消費者傳遞資訊。這種模式被稱為“釋出/訂閱”。

為了說明這個模式，我們要建立一個簡單的日誌記錄系統。它將包括兩個程式 - 第一個將發出日誌訊息，第二個將接收並列印它們。

在我們的日誌系統中，每一個執行的接收者程式都會收到日誌。這樣我們就可以實現一個接收者將接收到的資料寫到硬碟上，與此同時，另一個接收者把接收到的訊息展現在螢幕上。

本質上來說，就是已釋出的日誌訊息將被廣播到所有接收者。

轉發器（Exchanges）

前面的部落格中我們主要的介紹都是傳送者傳送訊息給佇列，接收者從佇列接收訊息。下面我們會引入Exchanges，展示RabbitMQ的完整的訊息模型。

讓我們快速瞭解我們在以前的教程中介紹的內容：

生產者是傳送訊息的使用者應用程式。
佇列是儲存訊息的緩衝區。
消費者是接收訊息的使用者應用程式。

RabbitMQ中的訊息傳遞模型的核心思想是，生產者從不將任何訊息直接傳送到佇列。實際上，生產者通常甚至不知道是否將訊息傳遞到任何佇列。

相反，生產者只能將資訊傳送到exchange。交換是一件非常簡單的事情。一方面，它收到來自生產者的訊息，另一方將它們推送到佇列。交換機必須準確知道接收到的訊息如何處理。應該追加到特定佇列嗎？應該追加到很多佇列嗎？或者應該丟棄。其規則由exchange

channel.ExchangeDeclare("logs", "fanout");

fanout交換器非常簡單。 正如您可以從名稱猜出，它只是將所有收到的訊息廣播到所有知道的佇列。 這正是我們需要的記錄器。

列出交換機

要列出伺服器上的交換機，您可以執行有用的rabbitmqctl：

sudo rabbitmqctl list_exchanges

在這個列表中會有一些amq.*

預設交換

在本教程的前面部分，我們對交換沒有任何瞭解，但仍然能夠將訊息傳送到佇列。 這是可能的，因為我們使用預設交換，我們通過空字串("")標識。

回想一下我們之前釋出的訊息：

var message = GetMessage(args);
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "",
                         routingKey: "hello",
                         basicProperties: null,
                         body: body);

第一個引數是交換的名稱。 空字串表示預設或無名交換：訊息通過路由Key指定的名稱路由到佇列（如果存在）。

現在，我們可以釋出到我們命名的交換機：

var message = GetMessage(args);
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "logs",
                     routingKey: "",
                     basicProperties: null,
                     body: body);

臨時佇列（Temporary queues）

前面我們使用的是具有指定名稱的佇列（記得hello和task_queue？）。 能夠命名佇列對我們而言至關重要 - 我們需要將工作者指向同一個佇列。 當您想要在生產者和消費者之間共享佇列時，給佇列一個名字很重要。

但是我們的日誌系統我們並不關心佇列的名稱。 我們希望接收到所有的日誌訊息，而不僅僅是它們的一部分。 而且我們也只對當前正在傳遞的資料的感興趣。 要解決我們的需，要做兩件事情。

首先，每當我們連線到Rabbit，我們需要一個新的空的佇列。 為此，我們可以建立一個具有隨機名稱的佇列，或者甚至更好 - 讓伺服器為我們選擇一個隨機佇列名稱。

其次，一旦消費者與Rabbit斷開，佇列應該被自動刪除。

在.NET客戶端中，當我們沒有為queueDeclare()提供引數時，我們建立了一個不可持續的，獨佔的，自動刪除的佇列，其中包含一個生成的名稱：

var queueName = channel.QueueDeclare().QueueName;

此時，queueName包含一個隨機佇列名稱。 例如，它可能看起來像amq.gen-JzTY20BRgKO-HjmUJj0wLg。

繫結（Bindings）

我們已經建立了一個扇出交換和一個佇列。 現在我們需要告訴交換機發送訊息到我們的佇列。 交換和佇列之間的關係稱為繫結（binding）。

channel.QueueBind(queue: queueName,
                  exchange: "logs",
                  routingKey: "");

從現在開始，logs交換器將追加訊息到我們的佇列。

列出繫結

你可以列出現有的繫結:

rabbitmqctl list_bindings

完整的例子

發出日誌訊息的生產者程式與上一個教程並沒有太大的區別。 最重要的變化是我們現在想將訊息釋出到我們的logs交換器，而不是無名的。 傳送時需要提供一個routingKey，但是對於fanout交換來說，它的值被忽略。 這裡是EmitLog.cs檔案的程式碼：

using System;
using RabbitMQ.Client;
using System.Text;

class EmitLog
{
    public static void Main(string[] args)
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using(var connection = factory.CreateConnection())
        using(var channel = connection.CreateModel())
        {
            channel.ExchangeDeclare(exchange: "logs", type: "fanout");

            var message = GetMessage(args);
            var body = Encoding.UTF8.GetBytes(message);
            channel.BasicPublish(exchange: "logs",
                                 routingKey: "",
                                 basicProperties: null,
                                 body: body);
            Console.WriteLine(" [x] Sent {0}", message);
        }

        Console.WriteLine(" Press [enter] to exit.");
        Console.ReadLine();
    }

    private static string GetMessage(string[] args)
    {
        return ((args.Length > 0)
               ? string.Join(" ", args)
               : "info: Hello World!");
    }
}

如你所見，建立連線後，我們宣告交換。 此步驟是必須的，因為禁止釋出到不存在的交換機。

如果沒有任何佇列繫結到交換機，訊息將丟失，但是對我們來說沒關係; 如果沒有消費者正在收聽，我們可以放心地放棄資訊。

ReceiveLogs.cs的程式碼：

using System;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;

class ReceiveLogs
{
    public static void Main()
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using(var connection = factory.CreateConnection())
        using(var channel = connection.CreateModel())
        {
            channel.ExchangeDeclare(exchange: "logs", type: "fanout");

            var queueName = channel.QueueDeclare().QueueName;
            channel.QueueBind(queue: queueName,
                              exchange: "logs",
                              routingKey: "");

            Console.WriteLine(" [*] Waiting for logs.");

            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body;
                var message = Encoding.UTF8.GetString(body);
                Console.WriteLine(" [x] {0}", message);
            };
            channel.BasicConsume(queue: queueName,
                                 noAck: true,
                                 consumer: consumer);

            Console.WriteLine(" Press [enter] to exit.");
            Console.ReadLine();
        }
    }
}

按照教程一的安裝說明生成EmitLogs和ReceiveLogs專案。

如果要將日誌儲存到檔案，只需開啟控制檯並鍵入：

cd ReceiveLogs
dotnet run > logs_from_rabbit.log

如果您希望在螢幕上看到日誌，則產生一個新的終端並執行：

cd ReceiveLogs
dotnet run

當然，要發射日誌型別：

cd EmitLog
dotnet run

使用rabbitmqctl list_bindings，您可以驗證程式碼是否按照我們想要的方式建立繫結和佇列。 執行兩個ReceiveLogs.cs程式時，您應該看到如下所示：

sudo rabbitmqctl list_bindings
# => Listing bindings ...
# => logs    exchange        amq.gen-JzTY20BRgKO-HjmUJj0wLg  queue           []
# => logs    exchange        amq.gen-vso0PVvyiRIL2WoV3i48Yg  queue           []
# => ...done.

對結果的解釋很簡單：來自交換機logs的資料轉到具有伺服器分配名稱的兩個佇列。 這正是我們的意圖。