当前位置：首页 > news >正文

免费网站论坛/百度搜索引擎收录

news 2025/8/5 2:00:21

免费网站论坛,百度搜索引擎收录,本地网站建设教程,设计公司网页欣赏RabbitMQ可以对消息和队列设置TTL(消息的过期时间)，消息在队列的生存时间一旦超过设置的TTL值，就称为dead message， 消费者将无法再收到该消息。 TTL 过期时间对消息设置预期的时间，超过此时间后，消息被自动删除&…

RabbitMQ可以对消息和队列设置TTL(消息的过期时间)，消息在队列的生存时间一旦超过设置的TTL值，就称为dead message，消费者将无法再收到该消息。

TTL 过期时间

对消息设置预期的时间，超过此时间后，消息被自动删除，消费者再无法接收获取

设置方式

通过队列属性设置：队列中所有消息都有相同的过期时间
对消息进行单独设置：每条消息TTL可以不同

!! 注意：如同时使用2种方式，过期时间以最小的数值为准。

准备：项目搭建

本文示例中是SpringBoot 整合RabbitMQ项目

1. 新建springBoot 项目

2. 引入依赖

3. 配置文件配置rabbit参数

注意：如果是连接本地localhost，Spring默认有配置本地可以不需要配置，默认是guest用户

过期队列

搭建路由模式的交换机，设置队列为过期队列

完整的项目结构如下

1. 编写 TTL_Queue_DirectConfiguration 类，声明创建交换机、队列，以及绑定关系

@Configuration
public class TTL_Queue_DirectConfiguration {// 1.声明创建direct路由模式的交换机@Beanpublic DirectExchange getDirectExchange(){/** @params1 : 交换机名称*  @params2 : 是否持久化（是，重启后不会消失）*  @params3 : 是否自动删除（交换机无消息可投递，则自动删除交换机）*/return new DirectExchange("direct_Exchange",true,false);}// 2.声明创建过期队列队列@Beanpublic Queue getTTL_Queue1(){/** 2.1 设置该队列内的所有消息过期时间为5秒*      key：rabbitmq图形化界面中的规定名称*      value：默认是int类型值，否则报错，单位毫秒*/Map<String,Object> map = new HashMap<>();map.put("x-message-ttl",5000);/** @params1 : 队列名称*  @params2 : 是否持久化（true：重启后不会消失）*  @params3 : 是否独占队列（true：仅限于此连接使用）*  @params4 : 是否自动删除（队列内最后一条消息被消费后，队列将自动删除）*/return new Queue("ttl_Queue1",true,false,false,map);}// 3.绑定交换机与队列的关系，并设置交换机与队列之间的BindingKey@Beanpublic Binding getBinding_TTL(){// 投递消息时指定的RoutingKey与此BindingKey（ttl）匹配上，消息才会被投递到ttl_Queue1队列return BindingBuilder.bind(getTTL_Queue1()).to(getDirectExchange()).with("ttl");}
}

☛ 温馨提示：上述过期队列map参数中的key，是图形化界面规定的固定key设置，不是随意写的

2. 编写 OrderService 类，模拟用户下单，通过MQ进行消息异步分发

@Service
public class OrderService {// 注入Spring提供的rabbit模板服务@Autowiredprivate RabbitTemplate template;// 模拟用户下单public void createOrder3(String userId, String productId, int num){// 1.根据商品ID查询库存是否充足....// 2.生成订单String orderId = UUID.randomUUID().toString();System.out.println("订单生成成功....");// 3.将订单id封装成MQ消息，投递到交换机/**@params1 ：交换机名称* @params2 ：投递消息指定的RoutingKey路由键或者队列名称* @params3 ：消息内容*/template.convertAndSend("direct_Exchange","ttl",orderId);}
}

3. SpringBoot 测试类进行测试，调用orderService 中的创建订单方法

@SpringBootTest
class RabbitOrderSpringbootProducerApplicationTests {// 1.注入订单服务@Autowiredprivate OrderService orderService;@Testvoid testDirect_TTL() {// 2.调用订单服务中的创建订单方法/** @params1 : 用户ID*  @params2 : 产品ID*  @params3 : 购买数量*/orderService.createOrder3("1001","96",1);}
}

4. 运行测试类

5. 图形化登陆查看队列结果信息

!! 注意：这条被投递进队列的消息，5秒后将自动被删除

▶ 扩展：除了通过代码设置过期队列，还可以通过图形化界面创建过期队列

单条过期消息

同样是搭建路由模式的交换机，我们针对单条消息进行设置过期时间

1. 整体架构同过期队列中的一样，在原configuration 配置文件基础上，新增一个新的队列

2. 针对单条消息设置过期时间

扩展：如果针对单条消息进行设置，在springboot中需要借助MessagePostProcessor消息加工器对消息进行加工！

// 消息加工类，可以针对消息进行特殊处理
MessagePostProcessor processor = new MessagePostProcessor() {@Overridepublic Message postProcessMessage(Message message) throws AmqpException {// 设置消息的编码格式message.getMessageProperties().setContentEncoding("UTF-8");// 设置消息5秒后过期message.getMessageProperties().setExpiration("5000");// 设置消息优先级 （优先级分为消息优先级和队列优先级）// ——队列优先级高的会先被处理，消息优先级高的会先被消费message.getMessageProperties().setPriority(5);// 设置消息持久化message.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT);return message;}
};

3. 测试类运行

4. 查看图形化结果

针对单条消息设置过期时间，超出时间后该条消息将会被自动删除，该队列内的其他消息不受影响

☛ 创建队列注意事项

假设队列已经存在的情况，去重新修改队列的属性，或者新增属性，启动会报异常

@Bean
public Queue ttlQueue() {// 问题描述：队列已经存在，设置了5秒过期，此时我修改为6秒，重启项目后会报错Map<String,Object> map = new HashMap<>();map.put("x-message-ttl",5000); // ttl_queue已经存在了return new Queue("ttl_queue", true,false,false,args);
}

解决方案