操纵014：惰性队列

操纵014：惰性队列

一、创建惰性队列

1、官网说明

队列可以创建为默认或惰性模式，模式指定方式是：

• 使用队列策略（建议）
  
• 设置queue.declare参数
  

假如策略和队列参数同时指定，那么队列参数有更高优先级。假如队列模式是在声明时通过可选参数指定的，那么只能通过删除队列再重新创建来修改。
2、基于策略方式设定

1. # 登录Docker容器
2. docker exec -it rabbitmq /bin/bash
4. # 运行rabbitmqctl命令
5. rabbitmqctl set_policy Lazy "^lazy-queue$" '{"queue-mode":"lazy"}' --apply-to queues

复制代码

命令解读：

• rabbitmqctl命令所在目录是：/opt/rabbitmq/sbin，该目录已配置到Path环境变量
  
• set_policy是子命令，表示设置策略
  
• Lazy是当前要设置的策略名称，是我们本身自定义的，不是系统定义的
  
• "^lazy-queue$"是用正则表达式限定的队列名称，凡是名称符合这个正则表达式的队列都会应用这里的设置
  
• '{“queue-mode”:“lazy”}'是一个JSON格式的参数设置指定了队列的模式为"lazy"
  
• –-apply-to参数指定该策略将应用于队列（queues）级别
  
• 命令执行后，所著名称符合正则表达式的队列都会应用指定策略，包括将来新创建的队列
  

假如需要修改队列模式可以执行如下命令（不必删除队列再重建）：

1. rabbitmqctl set_policy Lazy "^lazy-queue$" '{"queue-mode":"default"}' --apply-to queues

复制代码

3、在声明队列时使用参数设定

• 参数名称：x-queue-mode
  
• 可用参数值：
  
  
  
  • default
    
  • lazy
    
  
  
• 不设置就是取值为default
  

Java代码原生API设置方式：

1. Map<String, Object> args = new HashMap<String, Object>();
2. args.put("x-queue-mode", "lazy");
3. channel.queueDeclare("myqueue", false, false, false, args);

复制代码

Java代码注解设置方式：

1. @Queue(value = QUEUE_NAME, durable = "true", autoDelete = "false", arguments = {
2.         @Argument(name = "x-queue-mode", value = "lazy")
3. })

复制代码

二、实操演练

1、生产者端代码

①配置POM

1.     <parent>
2.         <groupId>org.springframework.boot</groupId>
3.         <artifactId>spring-boot-starter-parent</artifactId>
4.         <version>3.1.5</version>
5.     </parent>
7.     <dependencies>
8.         <dependency>
9.             <groupId>org.springframework.boot</groupId>
10.             <artifactId>spring-boot-starter-amqp</artifactId>
11.         </dependency>
12.         <dependency>
13.             <groupId>org.springframework.boot</groupId>
14.             <artifactId>spring-boot-starter-test</artifactId>
15.         </dependency>
16.         <dependency>
17.             <groupId>org.projectlombok</groupId>
18.             <artifactId>lombok</artifactId>
19.         </dependency>
20.     </dependencies>

复制代码

②配置YAML

1. spring:
2.   rabbitmq:
3.     host: 192.168.200.100
4.     port: 5672
5.     username: guest
6.     password: 123456
7.     virtual-host: /

复制代码

③主启动类

1. package com.atguigu.mq;
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
6. @SpringBootApplication
7. public class RabbitMQLazyProducer {
9.     public static void main(String[] args) {
10.         SpringApplication.run(RabbitMQLazyProducer.class, args);
11.     }
13. }

复制代码

④发送消息

1. package com.atguigu.mq.test;
3. import jakarta.annotation.Resource;
4. import org.junit.jupiter.api.Test;
5. import org.springframework.amqp.rabbit.core.RabbitTemplate;
6. import org.springframework.boot.test.context.SpringBootTest;
8. @SpringBootTest
9. public class RabbitMQTest {
11.     public static final String EXCHANGE_LAZY_NAME = "exchange.atguigu.lazy";
12.     public static final String ROUTING_LAZY_KEY = "routing.key.atguigu.lazy";
14.     @Resource
15.     private RabbitTemplate rabbitTemplate;
17.     @Test
18.     public void testSendMessage() {
19.         rabbitTemplate.convertAndSend(EXCHANGE_LAZY_NAME, ROUTING_LAZY_KEY, "I am a message for test lazy queue.");
20.     }
22. }

复制代码

2、消费者端代码

①配置POM

1.     <parent>
2.         <groupId>org.springframework.boot</groupId>
3.         <artifactId>spring-boot-starter-parent</artifactId>
4.         <version>3.1.5</version>
5.     </parent>
7.     <dependencies>
8.         <dependency>
9.             <groupId>org.springframework.boot</groupId>
10.             <artifactId>spring-boot-starter-amqp</artifactId>
11.         </dependency>
12.         <dependency>
13.             <groupId>org.springframework.boot</groupId>
14.             <artifactId>spring-boot-starter-web</artifactId>
15.         </dependency>
16.         <dependency>
17.             <groupId>org.projectlombok</groupId>
18.             <artifactId>lombok</artifactId>
19.         </dependency>
20.     </dependencies>

复制代码

②配置YAML

1. spring:
2.   rabbitmq:
3.     host: 192.168.200.100
4.     port: 5672
5.     username: guest
6.     password: 123456
7.     virtual-host: /

复制代码

③主启动类

1. package com.atguigu.mq;
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
6. @SpringBootApplication
7. public class RabbitMQLazyConsumerMainType {
9.     public static void main(String[] args) {
10.         SpringApplication.run(RabbitMQLazyConsumerMainType.class, args);
11.     }
12.    
13. }

复制代码

④监听器

1. package com.atguigu.mq.listener;
3. import com.rabbitmq.client.Channel;
4. import lombok.extern.slf4j.Slf4j;
5. import org.springframework.amqp.core.Message;
6. import org.springframework.amqp.rabbit.annotation.*;
7. import org.springframework.stereotype.Component;
9. @Component
10. @Slf4j
11. public class MyLazyMessageProcessor {
13.     public static final String EXCHANGE_LAZY_NAME = "exchange.atguigu.lazy";
14.     public static final String ROUTING_LAZY_KEY = "routing.key.atguigu.lazy";
15.     public static final String QUEUE_LAZY_NAME = "queue.atguigu.lazy";
17.     @RabbitListener(bindings = @QueueBinding(
18.         value = @Queue(value = QUEUE_LAZY_NAME, durable = "true", autoDelete = "false", arguments = {
19.             @Argument(name = "x-queue-mode", value = "lazy")
20.         }),
21.         exchange = @Exchange(value = EXCHANGE_LAZY_NAME, durable = "true", autoDelete = "false"),
22.         key = {ROUTING_LAZY_KEY}
23.     ))
24.     public void processMessageLazy(String data, Message message, Channel channel) {
25.         log.info("消费端接收到消息：" + data);
26.     }
28. }

复制代码

三、测试

• 先启动消费端
  
• 基于消费端@RabbitListener注解中的配置，自动创建了队列
  

• 发送消息
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。