小飞知识库 | YeLu🤠MiLu🤪 小飞知识库 | YeLu🤠MiLu🤪
  • 函数式编程
  • Spring
  • SpringMVC
  • SpringBoot
  • SpringCloud
  • Mybatis
  • JVM
  • JUC并发编程
  • 设计模式
  • 单元测试
  • Redis
  • RabbitMQ
  • mysql
  • oracle
  • linux
  • nginx
  • docker
  • elasticSearch
  • windows
  • 虚拟机
  • 监控系统
  • https
  • 内网穿透
  • 前端文章

    • JavaScript
  • 页面

    • HTML
    • CSS
  • 学习笔记

    • 《JavaScript教程》
    • 《JavaScript高级程序设计》
    • 《ES6 教程》
    • 《Vue》
    • 《React》
    • 《TypeScript 从零实现 axios》
    • TypeScript
    • JS设计模式总结
  • 技术文档
  • GitHub技巧
  • Nodejs
  • 博客搭建
  • 版本管理

    • Git笔记
  • 项目构建

    • maven
  • 学习
  • 面试
  • 心情杂货
  • 实用技巧
  • 友情链接
  • JAR包相关
  • 关于
  • 收藏
  • 分类
  • 标签
  • 归档
GitHub (opens new window)

YeLu

爱技术的YeLu🤠
  • 函数式编程
  • Spring
  • SpringMVC
  • SpringBoot
  • SpringCloud
  • Mybatis
  • JVM
  • JUC并发编程
  • 设计模式
  • 单元测试
  • Redis
  • RabbitMQ
  • mysql
  • oracle
  • linux
  • nginx
  • docker
  • elasticSearch
  • windows
  • 虚拟机
  • 监控系统
  • https
  • 内网穿透
  • 前端文章

    • JavaScript
  • 页面

    • HTML
    • CSS
  • 学习笔记

    • 《JavaScript教程》
    • 《JavaScript高级程序设计》
    • 《ES6 教程》
    • 《Vue》
    • 《React》
    • 《TypeScript 从零实现 axios》
    • TypeScript
    • JS设计模式总结
  • 技术文档
  • GitHub技巧
  • Nodejs
  • 博客搭建
  • 版本管理

    • Git笔记
  • 项目构建

    • maven
  • 学习
  • 面试
  • 心情杂货
  • 实用技巧
  • 友情链接
  • JAR包相关
  • 关于
  • 收藏
  • 分类
  • 标签
  • 归档
GitHub (opens new window)
  • RabbitMQ

    • 介绍
    • 安装
    • 卸载
    • 基础使用

    • 高级使用

      • confirm机制
      • return机制
      • limit_requeue
      • ttl
      • 死信队列 [dead-letter]
      • 消息传输的一致性问题
      • Springboot整合RabbitMQ
  • 消息队列
  • RabbitMQ
  • 高级使用
YeLu🤠
2025-01-06

ttl

参考demo:G:\学习资料\java\java学习文档\java技术文档\消息队列文档\rabbimitmq\cd-xufei-rabbiitmq-parent\cd-xufei-rabbitmq-01 => ttl

场景:比如下单之后 一段时间 我们的系统未处理这个下单的话 那么这个下单就失败了 简单的跟你说 这个队列中的数据 如果超过了 指定的时间 那么这个队列的数据 就会被清空 这种队列 就称为 TTL队列

代码示例如下:

public class Producer {

    /**
     * 下面这个模拟的是TTL队列
     */
    private static final String QUEUE_NAME = "queue_ttl";

    public static void main(String[] args) throws Exception {
        // 获取连接
        Connection connection = ConnectionUtils.getConnection();
        // 建立通道
        Channel channel = connection.createChannel();
        // 申明一个队列
        /**
         *第一个参数:队列的名字
         *第二个参数:是否持久化  :这个数据 发送到队列去的时候 这个数据 是否要持久化到数据库中去
         *第三个参数:是否排外
         *           第一个意思:是否允许这个通道以外的 其他消费者来消费这个数据
         *           第二个意思:连接关闭之后  这个队列是否自动删除
         *第四个参数:是否自动删除
         *           表示的是 当最后一个连接退出的时候是否要删除这个队列
         *第五个参数:创建队列 付带的头的信息(TTL   死信队列)
         *
         */
        // 申明队列是一个TTL队列
        // 参数解析:5000 5秒过期 单位 milliseconds
        // 参数解析:x-message-ttl TTL 队列
        Map<String, Object> maps = new HashMap<>();
        maps.put("x-message-ttl", 5000);

        channel.queueDeclare(QUEUE_NAME, false, false, false, maps);
        // 生产者 要向这个队列中  发送一条消息

        channel.basicPublish("", QUEUE_NAME, null, ("TTL队列的测试").getBytes());
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
最近更新: 2025/01/07, 09:25:39
limit_requeue
死信队列 [dead-letter]

← limit_requeue 死信队列 [dead-letter]→

最近更新
01
服务端配置
07-30
02
frp 安装
07-30
03
Prometheus采集Springboot应用
02-20
更多文章>
Theme by Vdoing | Copyright © 2019-2025 | YeLu🤠MiLu🤪 | MIT License 蜀ICP备2024116879号 | 川公网安备51012202001998号
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式
欢迎你,我的朋友
看板娘