RabbitMQ 基础

核心

消息发送者 ==> 交换机 ==> 队列 ==> 消费者

形式

1. 同步通讯==>视频电话
2. 异步通讯==>消息聊天

三个角色：消息发送者,消息代理,消息接收者

消息发送者 ==> 消息代理 ==> 消息接受者1，消息接受者2

数据隔离

不同的用户之间具有数据隔离，只能看到其他用户的数据，而不能操作。

使用

依赖 ==> 配置信息 ==> 发送消息 ==> 接收消息

发送
public void send() {
    String queueName = "simple.queue";
    String msg = "at tcs";
    rabbitTemplate.convertAndSend(queueName, msg);
}

接收
@RabbitListener(queues = "simple.queue")
public void getMsg(String msg) {
    System.out.println("队列中的消息" + msg);
}

工作模式

Work模型

让多个消费者绑定到一个队列中，共同使用队列中的消息。（如果有 50 条, 两个消费者，则每人处理 25 条）

1. 默认为轮询机制，即不考虑某个消费者是否处理完消息，就直接按照轮询又给一条消息，如果该消费者处理信息慢（性能差）可能会导致消息堆积。
2. 通过prefetch配置，控制消息预取数量，处理完一条再接收下一条，能者多劳，从而解决这个问题

交换机类型

1. Fanout（广播）

交换机会把消息推送到与其绑定的每一个消息队列。

交换机 A
队列 1 绑定到 A
队列 2 绑定到 A
队列 1 和 2 都能接收到交换机 A 发送的消息

2. Direct（定向）

交换机会按照规则路由到指定的消息队列。

发送消息时，给交换机指定 RoutingKey。 队列绑定时使用 BindingKey。

交换机 `RoutingKey` 为 `Blue`
队列 1 绑定 `BindingKey` 为 `Red`
队列 2 绑定 `BindingKey` 为 `Blue`
只有队列 2 能接收到消息

3. Topic（话题）

1. 与Direct类似，区别在于交换机的RoutingKey可以是多个以 . 分隔的单词列表

2. 队列绑定BinddingKey时可以使用通配符==>

   2.1 #: 代表0或多个单词（多个层级）

   2.2 *: 代表1个单词（一个层级）

BindingKey 为 china.# ：能接收 china.news、china.weather。
BindingKey 为 #.weather ：能接收 china.weather、japan.weather。

BindingKey 为 china.*：能接收 china.news、china.weather，
但 不能接收 china.news.cy，因为 * 只能匹配一个单词。

声明队列与交换机

1. 基于注解

@Component
public class RabbitMQConsumer {

    @RabbitListener(
        bindings = @QueueBinding(
            value = @Queue(value = "testQueue", durable = "true"), // 声明队列
            exchange = @Exchange(value = "testExchange", type = "direct"), // 声明交换机
            key = "testRoutingKey" // 绑定 RoutingKey
        )
    )
    public void receiveMessage(String message) {
        System.out.println("收到消息：" + message);
    }
}

2. 手写 @Bean

@Configuration
public class RabbitMQConfig {

    // 声明队列
    @Bean
    public Queue testQueue() {
        return new Queue("testQueue", true); // true 表示队列持久化
    }

    // 声明交换机
    @Bean
    public DirectExchange testExchange() {
        return new DirectExchange("testExchange");
    }

    // 绑定队列到交换机，并指定 RoutingKey
    @Bean
    public Binding bindingTestQueue(Queue testQueue, DirectExchange testExchange) {
        return BindingBuilder.bind(testQueue).to(testExchange).with("testRoutingKey");
    }
}