Topics 交换器

topic交换器的功能是很强大的，它可以表现出一些其他交换器的行为。

当一个队列与键＃（哈希）绑定时， 它会忽略路由键，接收所有消息，这就像fanout交换器一样。

当特殊字符*（星号）和＃（哈希）未在绑定中使用时，topic交换器的行为就像direct交换器一样。

组合在一起

我们将要在我们的日志系统中使用topic交换器，首先假设日志的路由键有两个单词组成：<facility>.<severity>。

代码与上一篇 教程 中的代码几乎相同。

EmitLogTopic.cs的代码：

using System;using System.Linq;using RabbitMQ.Client;using System.Text;class EmitLogTopic{ 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: "topic_logs", type: "topic"); var routingKey = (args.Length > 0) ? args[0] : "anonymous.info"; var message = (args.Length > 1) ? string.Join(" ", args.Skip(1).ToArray()) : "Hello World!"; var body = Encoding.UTF8.GetBytes(message); channel.BasicPublish(exchange: "topic_logs", routingKey: routingKey, basicProperties: null, body: body); Console.WriteLine(" [x] Sent "{0}":"{1}"", routingKey, message); } }}

ReceiveLogsTopic.cs的代码：

using System;using RabbitMQ.Client;using RabbitMQ.Client.Events;using System.Text;class ReceiveLogsTopic{ 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: "topic_logs", type: "topic"); var queueName = channel.QueueDeclare().QueueName; if(args.Length < 1) { Console.Error.WriteLine("Usage: {0} [binding_key...]", Environment.GetCommandLineArgs()[0]); Console.WriteLine(" Press [enter] to exit."); Console.ReadLine(); Environment.ExitCode = 1; return; } foreach(var bindingKey in args) { channel.QueueBind(queue: queueName, exchange: "topic_logs", routingKey: bindingKey); } Console.WriteLine(" [*] Waiting for messages. To exit press CTRL+C"); 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, autoAck: true, consumer: consumer); Console.WriteLine(" Press [enter] to exit."); Console.ReadLine(); } }}

请运行以下示例：

要接收所有日志：

cd ReceiveLogsTopicdotnet run "#"

要接收来自设备kern的所有日志：

cd ReceiveLogsTopicdotnet run "kern.*"

或者，如果您只想监听级别为critical的日志：

cd ReceiveLogsTopicdotnet run "*.critical"

您可以创建多个绑定：

cd ReceiveLogsTopicdotnet run "kern.*" "*.critical"

使用路由键kern.critical发出日志：

cd EmitLogTopicdotnet run "kern.critical" "A critical kernel error"

希望运行这些程序能让您玩得开心。要注意的是，这些代码没有针对路由键和绑定键做任何预设，您可以尝试使用两个以上的路由键参数。

（ EmitLogTopic.cs 和 ReceiveLogsTopic.cs 的完整源码）

接下来，在 教程[6] 中将了解如何将往返消息作为远程过程调用。

写在最后

本文翻译自RabbitMQ官方教程C#版本。如本文介绍内容与官方有所出入，请以官方最新内容为准。水平有限，翻译的不好请见谅，如有翻译错误还请指正。

原文链接：RabbitMQ tutorial - Topics

实验环境：RabbitMQ 3.7.4 、.NET Core 2.1.3、Visual Studio Code

最后更新：2018-09-06