微服务框架 SpringCloud微服务架构服务异步通讯 52 惰性队列 52.2 惰性队列

news2024/11/24 4:33:21

微服务框架

【SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式，系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】

服务异步通讯

文章目录

- - 微服务框架
  - 服务异步通讯
  - 52 惰性队列
  - - 52.2 惰性队列
    - - 52.2.1 惰性队列
      - 52.2.2 总结

52 惰性队列

52.2 惰性队列

52.2.1 惰性队列

从RabbitMQ的3.6.0版本开始，就增加了Lazy Queues的概念，也就是惰性队列。

惰性队列的特征如下：

接收到消息后直接存入磁盘而非内存【传统的消息默认就是在内存】
消费者要消费消息时才会从磁盘中读取并加载到内存
支持数百万条的消息存储

而要设置一个队列为惰性队列，只需要在声明队列时，指定x-queue-mode属性为lazy即可。可以通过命令行将一个运行中的队列修改为惰性队列：

在这里插入图片描述

用SpringAMQP声明惰性队列分两种方式：

@Bean的方式：

在这里插入图片描述

注解方式：

在这里插入图片描述

试试@Bean 的

在消费者中新来一个配置类

package cn.itcast.mq.config;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * ClassName: LazyConfig
 * date: 2022/11/9 21:33
 *
 * @author DingJiaxiong
 */

@Configuration
public class LazyConfig {

    //惰性队列
    @Bean
    public Queue lazyQueue(){

        return QueueBuilder.durable("lazy.queue")
                .lazy()
                .build();
    }

    //普通队列
    @Bean
    public Queue normalQueue(){

        return QueueBuilder.durable("normal.queue")
                .build();
    }


}

OK，直接运行消费者服务

查看RabbitMQ 的控制台

在这里插入图片描述

OK。两个队列都创建完成了

编写发送消息的测试方法

@Test
public void testLazyQueue() throws InterruptedException {

    for (int i = 0; i < 1000000; i++) {
        //1. 准备消息
        Message message = MessageBuilder.withBody("Hello,Lazy!!!!".getBytes(StandardCharsets.UTF_8))
                .setDeliveryMode(MessageDeliveryMode.NON_PERSISTENT)
                .build();

        //2. 发送消息
        rabbitTemplate.convertAndSend("lazy.queue", message);
    }

}

@Test
public void testNormalQueue() throws InterruptedException {

    for (int i = 0; i < 1000000; i++) {
        //1. 准备消息
        Message message = MessageBuilder.withBody("Hello,Lazy!!!!".getBytes(StandardCharsets.UTF_8))
                .setDeliveryMode(MessageDeliveryMode.NON_PERSISTENT)
                .build();

        //2. 发送消息
        rabbitTemplate.convertAndSend("normal.queue", message);
    }

}