【手册】——mq延迟队列

目录

  • 一、背景介绍
  • 二、思路&方案
  • 三、过程
    • 1.项目为啥用延迟队列?
    • 2.项目为啥用三方延迟队列?
    • 3.项目中为啥用rabbitmq延迟队列?
    • 4.rabbitmq延迟队列的安装
    • 5.rabbitmq的延迟队列配置方式
      • 5.1.exchange配置
      • 5.2.queues配置
      • 5.3.exchange和queues的绑定
    • 6.rabbitmq的延迟队列java集成方式
      • 6.1.pom文件中加入依赖
      • 6.2.配置文件中加入配置项
      • 6.3.增加类,设置对应exchange和queues的消息监听
  • 四、总结
  • 五、升华

一、背景介绍

对于mq延时队列,产品中对应的应用场景用到了,自己也在执行过程中踩了认知上的坑,历历在目的画面让我不由得动笔总结。

二、思路&方案

  • 1.项目为啥用延迟队列?
  • 2.项目为啥用三方延迟队列?
  • 3.项目中为啥用rabbitmq延迟队列?
  • 4.rabbitmq延迟队列的安装
  • 5.rabbitmq的延迟队列配置方式
  • 6.rabbitmq的延迟队列java集成方式

三、过程

1.项目为啥用延迟队列?

项目中有这样一个业务需求,需要再未来某个时间点执行任务,这些任务或消息可能由于某些原因(如依赖其他任务的完成、等待特定时间、进行定时操作等)不能立即处理。通过使用延迟队列,可以确保这些任务或消息在指定的延迟时间后得到处理,从而实现更为灵活和高效的任务调度。

1.1. 解耦:通过将需要延迟处理的任务放入队列,实现了业务逻辑与延迟处理逻辑的解耦,使得代码更加清晰和易于维护。
可扩展性:延迟队列可以轻松地水平扩展,以应对大量延迟任务的处理需求。通过增加队列的数量或调整消费者的数量,可以灵活地调整系统的处理能力。
1.2. 高可用性:一些延迟队列实现(如RabbitMQ的延迟插件、Redis的有序集合等)提供了持久化机制,即使系统崩溃或重启,也能确保延迟任务不会丢失。

2.项目为啥用三方延迟队列?

2.1. 功能完善与性能优化:第三方延迟队列经过大量的实践和优化,通常具有更完善的功能和更高的性能。它们可能已经解决了许多常见的延迟队列问题,如精确的延迟时间控制、高并发处理、消息的持久化等,从而减少了自行开发可能遇到的困难和风险。
2.2. 可靠性与稳定性:第三方延迟队列通常经过严格的测试和验证,具有更高的可靠性和稳定性。它们可能提供了数据备份、容错处理、负载均衡等机制,确保在复杂的网络环境和系统压力下,延迟队列仍然能够稳定、可靠地运行。
2.3. 易于集成与维护:使用第三方延迟队列可以简化项目的集成工作。这些队列通常提供了丰富的API和文档,方便开发者快速集成到项目中。同时,由于第三方队列的维护和更新由专业的团队负责,开发者可以专注于业务逻辑的实现,而无需过多关注底层技术的细节。
2.4. 成本考虑:虽然自行编写延迟队列可以根据项目需求进行定制,但这通常需要投入大量的人力和时间成本。而使用成熟的第三方延迟队列,则可以快速实现功能,减少开发周期和成本。

3.项目中为啥用rabbitmq延迟队列?

3.1.RabbitMQ:通过插件或死信队列机制实现,具有灵活性和可扩展性,但需要一定的配置和管理工作。
3.2.Redis:利用有序集合数据结构实现,简单直观且性能较高,但需要定期轮询检查延迟消息。
3.3.Kafka:通常需要结合其他组件或自定义实现来模拟延迟队列,可以实现复杂的流处理和延迟逻辑,但相对复杂且需要更多的开发工作。
3.4.Amazon SQS:直接支持延迟队列功能,无需额外配置和管理工作,适合在云环境中使用。

4.rabbitmq延迟队列的安装

安装方式借鉴如下博文即可:
【rabbitmq 实现延迟消息-插件版本安装(docker环境)】

5.rabbitmq的延迟队列配置方式

5.1.exchange配置

在这里插入图片描述

5.2.queues配置

在这里插入图片描述

5.3.exchange和queues的绑定

在这里插入图片描述

6.rabbitmq的延迟队列java集成方式

6.1.pom文件中加入依赖

  <!-- amqp依赖,包含RabbitMQ--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>2.3.5.RELEASE</version></dependency>

6.2.配置文件中加入配置项

spring:rabbitmq:host: rabbitmq域名port: rabbitmq端口virtual-host: 指定的virtual-host,默认可以是/username: 账号password: 密码#MQ业务配置#exchangeclassEndExchange: class_end_exchange#queuesclassEndQueues: Class.End.Queue#exchange和queues绑定时候的routingkeyclassEndRoutingKey: delayed_class_end

6.3.增加类,设置对应exchange和queues的消息监听

@Service
public class classEndQueues {@RabbitListener(queues = {"${spring.rabbitmq.classEndQueues}"})public synchronized void endClass(Message message){String messageString = new String(message.getBody());System.out.println(" endClass接收到的结束消息为:"+messageString );//要处理的业务}
}

四、总结

  • 1.逻辑性思考,一环一环,一步一步的去找,少了哪一步也都会出现断层,而断层所带来的代价是付出更多的时间成本;而总结的意义恰恰是避免类似的事情以后再付出更大的成本
  • 2.经验办事,想当然的办事所带来的认知陷阱,会成为一个扣了盖子的井
  • 3.于此形成相关手册,进行总结的过程是给自己未来建立一个连接点的过程

五、升华

写博文的深意,又有了更多维度的思考,它能够让作者静心思考,从宏观、微观、行为、心理的角度去思考、去总结、去升华。
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/785004.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

初识C++ · 入门(2)

目录 1 引用 1.1引用的概念 1.2 引用的特性 2 传值&#xff0c;传引用的效率 3 引用和指针的区别 4 内联函数 4.1 内联函数的定义 4. 2 内联函数的特性 5 关键字auto 5.1关于命名的思考 5.2 关于auto的发展 5.3 auto使用规则 6 范围for的使用 7 空指针 1 引用 …

web渗透测试漏洞复现:docker API未授权漏洞复现并getshell

web渗透测试漏洞复现 1. docker API未授权漏洞复现1.1 dokcer的概念1.2 dokcer API的概念1.3 dokcer API未授权漏洞浮现1.3.1 验证是否存在漏洞1.3.2 未授权复现步骤1.3.2 未授权操作容器1.4 扩展方法--docker未授权getshell1.4.1 获取shell的方法一:反弹shell1.4.2 挂载宿主机…

win10如何开启麦克风权限,win10麦克风权限设置

手机下载软件后,总是会跳出各种权限需要,例如访问通讯录、读取位置信息、启动相机等等。电脑上的应用也有这些权限设置,比如说玩游戏、直播、或录制视频时,我们需要打开麦克风权限,否则无法进行交流和录音。但是,win10如何开启麦克风权限呢?针对这个问题,小编已整理了两…

构建现代Web应用:JavaScript与Node.js的完美搭档

文章目录 JavaScript基本解释补充前端开发定义DOM树和JavaScript的角色浏览器引擎的进化动态内容更新SPA Node.js JavaScript 基本解释 javaScript的出现使得前端变的强大了很多。前端开发指的是&#xff0c;写一些代码&#xff0c;这些代码最终可以转化为浏览器可以懂的代码…

《自动机理论、语言和计算导论》阅读笔记:p115-p138

《自动机理论、语言和计算导论》学习第 6 天&#xff0c;p115-p138 总结&#xff0c;总计 24 页。 一、技术总结 1.associativity and comutativity (1)commutativity(交换性): Commutativity is the property of an operator that says we can switch the order of its ope…

python flask生成被控服务端 开放接口 可以调用本地程序启动D盘的app.py文件,并生成一个前端文件,有一个启动按钮

要创建一个使用 Flask 的被控服务端&#xff0c;开放接口以调用本地程序并启动 D 盘的 app.py 文件&#xff0c;以及生成一个带有启动按钮的前端文件&#xff0c;你需要做以下几个步骤&#xff1a; 设置 Flask 服务端&#xff1a;创建一个 Flask 应用&#xff0c;并定义一个 A…

大型C++代码一些英文缩写理解

1.Cfg"通常是指"Configuration"&#xff0c;即"配置"的意思 2.“info"通常是指"information”&#xff0c;也就是"信息"的意思 3.DLG通常表示"Dialog"&#xff0c;即对话框的意思 4.opt表示选择 5"Img"可能表…

比KMP简单的Manacher

P3805 【模板】manacher - 洛谷 | 计算机科学教育新生态 (luogu.com.cn) “没时间悼念KMP了&#xff0c;接下来上场的是Manacher&#xff01;” 什么是Manacher? 历史背景&#xff1a; 1975 年&#xff0c;一个叫 Manacher 的人发明了这个算法&#xff0c;所以叫Manacher 算…

Kratos 基础学习记录

一、安装golang环境 golang的安装和系统变量配置的教程有很多&#xff0c;简单列举几个教程: windows: 超详细Go语言环境安装(有图详解)_go环境安装-CSDN博客 linux: 【Linux — 安装 Go】Linux 系统安装 Go 过程总结_linux 安装go-CSDN博客 mac: mac安装Golang开发环境…

财务管理系统的设计与实现|Springboot+ Mysql+Java+ B/S结构(可运行源码+数据库+设计文档)

本项目包含可运行源码数据库LW&#xff0c;文末可获取本项目的所有资料。 推荐阅读100套最新项目持续更新中..... 2024年计算机毕业论文&#xff08;设计&#xff09;学生选题参考合集推荐收藏&#xff08;包含Springboot、jsp、ssmvue等技术项目合集&#xff09; 目录 1. …

Python类的构造方法 __init__及super().__init__

__init__ 是 Python 中特殊的方法&#xff0c;__init__ 构造方法在对象被创建时自动调用&#xff0c;用于在创建类的实例时进行初始化新创建的对象的状态。在这个方法内部&#xff0c;可以设置对象的初始属性&#xff0c;或者执行其他必要的初始化操作。 class ClassName:def …

02-JDK新特性-接口新特性

接口新特性 接口组成更新概述 接口的组成 常量 public static final String ZERO "0";抽象方法 public abstract void dance();默认方法&#xff08;JAVA8新增&#xff09; public default void dance(){}静态方法&#xff08;JAVA8新增&#xff09; public stat…

leecode 331 |验证二叉树的前序序列化 | gdb 调试找bug

计算的本质是数据的计算 数据的计算需要采用格式化的存储&#xff0c; 规则的数据结果&#xff0c;可以快速的按照指定要求存储数据 这里就不得不说二叉树了&#xff0c;二叉树应用场景真的很多 本题讲的是&#xff0c;验证二叉树的前序序列化 换言之&#xff0c;不采用建立树的…

Logback日志框架常见配置

版权声明 本文原创作者&#xff1a;谷哥的小弟作者博客地址&#xff1a;http://blog.csdn.net/lfdfhl logback简介 Logback是一个高性能、功能强大的日志框架&#xff0c;专为Java应用程序设计。它由Log4j的创始人Ceki Glc创建&#xff0c;并被视为Log4j的继承者和改进版。Lo…

3D Web轻量化平台HOOPS Web Platform在大型水利工程中的应用和价值

随着科技的不断进步和互联网的普及&#xff0c;数字化技术在各个领域的应用日益广泛&#xff0c;大型水利工程也不例外。作为一种先进的3D Web轻量化引擎&#xff0c;HOOPS Web Platform在大型水利工程中扮演着重要的角色&#xff0c;为工程设计、施工管理、运行维护等方面提供…

Ubuntu部署BOA服务器

BOA服务器概述 BOA是一款非常小巧的Web服务器&#xff0c;源代码开放、性能优秀、支持CGI通用网关接口技术&#xff0c;特别适合用在嵌入式系统中。 BOA服务器主要功能是在互联嵌入式设备之间进行信息交互&#xff0c;达到通用网络对嵌入式设备进行监控&#xff0c;并将反馈信…

Go的数据结构与实现【Binary Search Tree】

介绍 本文用Go将实现二叉搜索树数据结构&#xff0c;以及常见的一些方法 二叉树 二叉树是一种递归数据结构&#xff0c;其中每个节点最多可以有两个子节点。 二叉树的一种常见类型是二叉搜索树&#xff0c;其中每个节点的值都大于或等于左子树中的节点值&#xff0c;并且小…

Unbtun-arach64架构安装PySide2(python3.6)

aarch平台是无法通过pip安装PySide2的&#xff0c;同时利用源码下载一直报错 1. 我是python3.6.9&#xff0c;在官网上找到对应的PySide2版本 5.15.2.所以首先在官网下载Qt5.15.2的源码&#xff1a;https://download.qt.io/archive/qt/5.15/5.15.2/single/ 2. 编译qt环境 aar…

了解机器学习/深度学习常用的框架、工具

&#x1f349; CSDN 叶庭云&#xff1a;https://yetingyun.blog.csdn.net/ 一、scikit-learn scikit-learn 官方文档&#xff1a;https://scikit-learn.org/stable/# scikit-learn 的背景和创建者 scikit-learn 是一个为 Python 编程语言设计的自由软件机器学习库。该项目最初…

lodash插件

安装 npm install lodash引入 import orderBy from lodash/orderBy使用 orderBy(要排序的变量&#xff0c;要排序的字段&#xff0c;升序还是降序) // 例如&#xff0c;评论按照点赞数量排序 orderBy(lilst, like, desc)