RabbitMQ交换机详解：从架构到实战

RabbitMQ交换机详解：从架构到实战

引用

CSDN

1.

https://m.blog.csdn.net/2201_75732091/article/details/145908090

在微服务架构中，消息队列是实现服务间解耦和异步通信的关键组件。RabbitMQ作为一款广泛使用的消息队列系统，其核心组件之一——交换机（Exchange），在消息路由中扮演着至关重要的角色。本文将详细介绍RabbitMQ中交换机的类型、功能及其在SpringAMQP中的具体实现方式，帮助读者深入理解这一重要概念。

总体架构

在RabbitMQ中，交换机（Exchange）是消息路由的核心组件。其基本架构包括以下几个关键部分：

• 生产者（Publisher）：负责发送消息到交换机，而不是直接发送到队列。
• 交换机（Exchange）：接收生产者发送的消息，并根据预定义的规则（如消息的路由键和交换机类型）将消息路由到一个或多个队列。交换机本身不存储消息，因此如果没有任何队列与之绑定，或者没有符合路由规则的队列，消息将会丢失。
• 队列（Queue）：负责接收并缓存消息。队列需要与交换机绑定才能接收消息。
• 消费者（Consumer）：订阅队列并消费其中的消息。

交换机类型

RabbitMQ支持多种类型的交换机，每种类型都有其特定的路由逻辑：

1. Fanout交换机：将消息广播到所有绑定的队列，适用于发布/订阅场景。
2. Direct交换机：基于路由键（Routing Key）精确匹配，将消息发送到特定的队列。
3. Topic交换机：支持通配符路由键，提供更灵活的消息路由能力。
4. Headers交换机：基于消息头进行匹配，使用较少。

Fanout交换机

Fanout交换机类似于广播模式，会将消息发送给所有绑定到它的队列。以下是Fanout交换机的实现方式：

基于Bean声明队列和交换机

@Configuration
public class FanoutConfiguration {
    @Bean
    public FanoutExchange fanoutExchange() {
        return ExchangeBuilder.fanoutExchange("user.fanout").build();
    }

    @Bean
    public Queue fanoutQueue1() {
        return QueueBuilder.durable("fanout.queue1").build();
    }

    @Bean
    public Binding fanoutQueue1Binding(Queue fanoutQueue1, FanoutExchange fanoutExchange) {
        return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);
    }

    @Bean
    public Queue fanoutQueue2() {
        return QueueBuilder.durable("fanout.queue2").build();
    }

    @Bean
    public Binding fanoutQueue2Binding(Queue fanoutQueue2, FanoutExchange fanoutExchange) {
        return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);
    }
}

基于注解声明队列和交换机

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "fanout.queue3", durable = "true"),
        exchange = @Exchange(name = "fanout.exchange", type = "fanout"),
        key = "fanout.key"
))
public void listenFanoutQueue1(String msg) {
    System.out.println("消费者1接收到消息：【" + msg + "】" + LocalTime.now());
}

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "fanout.queue4", durable = "true"),
        exchange = @Exchange(name = "fanout.exchange", type = "fanout"),
        key = "fanout.key"
))
public void listenFanoutQueue2(String msg) {
    System.out.println("消费者2接收到消息：【" + msg + "】" + LocalTime.now());
}

Direct交换机

Direct交换机基于路由键（Routing Key）进行精确匹配，将消息发送到特定的队列。以下是Direct交换机的实现方式：

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "direct.queue1", durable = "true"),
        exchange = @Exchange(name = "user.direct", type = "direct"),
        key = {"red","blue"}
))
public void listenDirectQueue1(String msg) {
    System.out.println("消费者1接收到消息：【" + msg + "】" + LocalTime.now());
}

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "direct.queue2", durable = "true"),
        exchange = @Exchange(name = "user.direct", type = "direct"),
        key = {"red","green"}
))
public void listenDirectQueue2(String msg) {
    System.out.println("消费者2接收到消息：【" + msg + "】" + LocalTime.now());
}

Topic交换机

Topic交换机支持通配符路由键，提供更灵活的消息路由能力。以下是Topic交换机的实现方式：

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "topic.queue1"),
        exchange = @Exchange(name = "user.topic", type = ExchangeTypes.TOPIC),
        key = "china.#"
))
public void listenTopicQueue1(String msg){
    System.out.println("消费者1接收到topic.queue1的消息：【" + msg + "】");
}

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "topic.queue2"),
        exchange = @Exchange(name = "user.topic", type = ExchangeTypes.TOPIC),
        key = "#.news"
))
public void listenTopicQueue2(String msg){
    System.out.println("消费者2接收到topic.queue2的消息：【" + msg + "】");
}

通过以上介绍，我们可以看到RabbitMQ的交换机机制为构建灵活、可靠的消息传递系统提供了强大的支持。合理配置不同类型的交换机，可以满足各种复杂的业务场景需求，从而增强系统的可扩展性和灵活性。