【譯】RabbitMQ：路由（Routing）

在前一篇中，我們構建了一個簡單的日志系統，我們已經能夠廣播消息到許多的接收者。在這一篇中，我們希望增加一個特性，讓訂閱消息的子集成為可能。例如，我們可以將重要的錯誤日志存放到日志文件（即，磁盤上面），同時將仍然所有的日志信息打印到控制台。

綁定

在前面的例子中我們已經創建過綁定，你應該還能記得下面的代碼：

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

一個綁定是一個交換器和一個隊列的關系，可以形象的解讀為：這個隊列對來自這個交換器的消息感興趣。綁定可以擁有一個額外的參數：routingKey，為了避免和BasicPublish里面的routingKey混淆，我們稱其為綁定關鍵字（binding Key）,下面展示了如何通過一個綁定關鍵字創建一個綁定：

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

綁定關鍵字的意義依賴於交換器的類型，前面我們使用過的fanout類型的交換器，直接簡單的忽略了它的綁定關鍵字的值。

Direct交換器

前一篇教程中的日志系統廣播所有的消息到所有的消費者，我們希望擴展它能根據嚴重程度對消息進行過濾。例如，我們希望寫日志到磁盤的程序能夠只接收重要的錯誤，不要在“警告”、“信息”級別的日志身上浪費磁盤空間。

我們使用fanout類型的交換器，並不能帶來很大的靈活性，它只能盲目的廣播。作為替代，我們將使用direct類型的交換器，這種交換器背后的路由算法非常簡單，消息發送到綁定關鍵字（binding Key）和消息的路由關鍵字（routing Key）完全匹配的隊列。

為了幫助說明，設想下面的配置：

                                         

在這個設置中，我們看到direct類型的交換器X綁定了兩個隊列.第一個隊列綁定關鍵字是orange；第二個隊列有兩個綁定，一個是black，另一個是green。在這樣的配置中，發送到使用orange為路由關鍵字的消息將被路由到Q1，使用black或green為路由關鍵字的消息將被路由到隊列Q2，其他消息將被銷毀。

多綁定

                                         

使用同一個綁定關鍵字綁定多個隊列是完全合法的，在我們的示例中我們可以在X和Q1中添加一個以black為綁定關鍵字的綁定。在這種情況下，direct類型的交換器會展現出fanout類型交換器的行為，並且會廣播消息到所有滿足條件的隊列，發送到路由關鍵字為black的消息會發送到Q1和Q2.

發送日志

我們會為日志系統使用這種模式，將消息發送到direct類型而非fanout類型的交換器。我們將使用日志的嚴重等級來作為路由關鍵字，這樣的話消息的接收程序就可以依據自己的需要選擇不同的嚴重等級。首先讓我們把注意力集中到發送日志上。

和往常一樣，我們首先需要創建一個交換器：

channel.ExchangeDeclare(exchange: "direct_logs", type: "direct");

接着我們准備好發送消息了：

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

為了簡化問題，我們假設嚴重等級是‘info’、‘warning’、‘error’。

訂閱

馬上就可以像前面的教程中那樣接收消息了，但是有一個不同點，我們要用自己感興趣的所有日志嚴重程度分別創建一個綁定。

var queueName = channel.QueueDeclare().QueueName;

foreach(var severity in args)
{
    channel.QueueBind(queue: queueName,
                      exchange: "direct_logs",
                      routingKey: severity);
} 

組合在一起

                                       

EmitLogDirect.cs類的代碼：

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

class EmitLogDirect
{
    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: "direct_logs",
                                    type: "direct");

            var severity = (args.Length > 0) ? args[0] : "info";
            var message = (args.Length > 1)
                          ? string.Join(" ", args.Skip( 1 ).ToArray())
                          : "Hello World!";
            var body = Encoding.UTF8.GetBytes(message);
            channel.BasicPublish(exchange: "direct_logs",
                                 routingKey: severity,
                                 basicProperties: null,
                                 body: body);
            Console.WriteLine(" [x] Sent '{0}':'{1}'", severity, message);
        }

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

ReceiveLogsDirect.cs的代碼：

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

class ReceiveLogsDirect
{
    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: "direct_logs",
                                    type: "direct");
            var queueName = channel.QueueDeclare().QueueName;

            if(args.Length < 1)
            {
                Console.Error.WriteLine("Usage: {0} [info] [warning] [error]",
                                        Environment.GetCommandLineArgs()[0]);
                Console.WriteLine(" Press [enter] to exit.");
                Console.ReadLine();
                Environment.ExitCode = 1;
                return;
            }

            foreach(var severity in args)
            {
                channel.QueueBind(queue: queueName,
                                  exchange: "direct_logs",
                                  routingKey: severity);
            }

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

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

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

像通常那樣編譯（編譯建議見教程一）。

如果你只想保存嚴重等級為‘warning’、‘error’的日志到文件中，只需要打開控制台然后輸入：

$ ReceiveLogsDirect.exe warning error > logs_from_rabbit.log

如果你想在屏幕上看到所有的日志，打開另一個終端輸入：

$ ReceiveLogsDirect.exe info warning error
 [*] Waiting for logs. To exit press CTRL+C

如果想發送‘error’級別的日志，舉例來說，你只需要輸入如下信息：

$ EmitLogDirect.exe error "Run. Run. Or it will explode."
 [x] Sent 'error':'Run. Run. Or it will explode.' 

進入教程五，了解如何基於模式（pattern）監聽消息。

 

原文鏈接：http://www.rabbitmq.com/tutorials/tutorial-four-dotnet.html