在 RabbitMQ 中，交换机（Exchange）是用来路由消息到一个或多个队列的组件。根据路由逻辑和用途的不同，交换机有几种不同的类型。

发送消息

const string message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);

channel.BasicPublish(exchange: string.Empty,
                     routingKey: "hello",
                     basicProperties: null,
                     body: body);

Direct Exchange

• 直接交换机将消息路由到与其路由键完全匹配的队列。（如果有多个匹配的都会发送）
• 特点:
  • 消息的路由键（routing key）必须与队列的绑定键完全匹配。
  • 适用于简单的消息路由需求。

  channel.ExchangeDeclare(exchange: "direct_logs", type: ExchangeType.Direct);
  channel.QueueBind(queue: "info_queue", exchange: "direct_logs", routingKey: "info");
  channel.QueueBind(queue: "error_queue", exchange: "direct_logs", routingKey: "error");
  

Fanout Exchange

• 扇形交换机将消息广播到所有绑定的队列，而不考虑路由键。
• 特点:
  • 消息会被发送到所有与交换机绑定的队列。
  • 适用于广播或多播场景。

  channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
  channel.QueueBind(queue: "queue1", exchange: "logs", routingKey: "");
  channel.QueueBind(queue: "queue2", exchange: "logs", routingKey: "");
  

Topic Exchange

• 主题交换机根据消息的路由键和队列的绑定模式来路由消息。路由键和模式使用通配符。

• 特点:

  • 允许复杂的路由规则，支持多级路由。
  • 通常用于需要复杂路由逻辑的场景。

  channel.ExchangeDeclare(exchange: "topic_logs", type: ExchangeType.Topic);
  channel.QueueBind(queue: "critical_queue", exchange: "topic_logs", routingKey: "critical.*");
  channel.QueueBind(queue: "info_queue", exchange: "topic_logs", routingKey: "*.info");
  

• 路由键（Routing Key）：发送消息时指定的字符串，通常由点号（.）分隔的多个单词组成，例如user.create、order.cancelled等。

  • 单词之间应该有一定的语义关联，通常使用多个单词（由点号分隔）来表示层次结构，例如order.created.payment可以表示订单创建并完成支付。

• 绑定键（Binding Key）：队列在绑定到Topic交换机时指定的键，同样由点号分隔的字符串，并可以包含通配符。

• 通配符：
  • *（星号）：匹配路由键中的一个单词。例如，user.*可以匹配user.create或user.delete，但不能匹配user.profile.update。
  • #（井号）：匹配零个或多个单词。例如，order.#可以匹配order、order.created、order.cancelled.refunded等。
  • 通常在设计绑定键时，可以根据业务需求来使用*或#进行匹配。例如，如果要匹配所有与用户相关的操作，可以使用user.#作为绑定键。

匹配过程：

• 消息的路由键与每个绑定键逐个匹配。当路由键和绑定键能够匹配时，消息将被路由到该绑定键对应的队列。
  假设有以下绑定：

  • 绑定键user.*绑定到队列A
  • 绑定键order.#绑定到队列B
  • 绑定键*.created绑定到队列C

  如果发送一条消息，路由键为user.created，则该消息会被路由到队列A和队列C。

• 建议：
  • 路由键尽量简短且具备明确的语义，方便与绑定键进行匹配。
  • 使用有意义的层次结构，例如system.module.action，可以提高可读性和管理性。
    。

Headers Exchange

• 标头交换机根据消息的头部（即消息的属性）来路由消息，而不是根据路由键。
• 特点:
  • 允许使用消息的头部字段进行路由。
  • 可以进行复杂的路由逻辑。

  channel.ExchangeDeclare(exchange: "headers_logs", type: ExchangeType.Headers);
  var headers = new Dictionary<string, object> { { "x-match", "all" }, { "format", "pdf" } };
  channel.QueueBind(queue: "pdf_queue", exchange: "headers_logs", routingKey: "", arguments: headers);