RabbitMQ(十一)队列的扩展属性(Arguments)

目录

    • 一、简介
    • 二、队列扩展属性清单
    • 三、代码示例
      • 3.1 实现方式一:channel.queueDeclare()
      • 3.2 实现方式二:QueueBuilder.build()

在这里插入图片描述

一、简介

RabbitMQ 允许用户在声明队列、交换机或绑定时设置 扩展属性(Arguments),这些扩展属性可以用于 自定义和增强消息处理的行为。这里我们主要探讨 RabbitMQ 的 队列扩展属性

RabbitMQ 管理界面中的队列扩展属性:

在这里插入图片描述


二、队列扩展属性清单

队列扩展属性清单如下:

  • x-dead-letter-exchange:死信交换机。

  • x-dead-letter-routing-key:死信队列的路由键。

  • x-expires:队列在指定毫秒数后被删除。

  • x-message-ttl:队列的消息过期时间,单位为毫秒。

  • x-max-length:队列的消息条数限,限制加入 queue 中消息的条数。(先进先出原则,超过限制后,后面的消息会顶替前面的消息。)

  • x-max-length-bytes:队列的消息容量限制。(该参数和 x-max-length 目的一样,限制队列的容量,但是这个参数是靠队列大小(bytes)来进行限制。)

  • x-max-priority:队列的优先级,最大优先值为 255。

  • x-overflow:设置队列溢出行为。这决定了当达到队列的最大长度时消息会发生什么。有效值是:drop-head、reject-publish、reject-publish-dlx。

  • x-single-active-consumer:表示队列是否是单一活动消费者。

    值为 true 时,注册的消费组内只有一个消费者消费消息,其他被忽略。

    值为 false 时,消息循环分给所有消费者。(默认)

  • x-queue-mode:将队列设置为延迟模式,在磁盘上保留尽可能多的消息,以减少 RAM 的使用。如果未设置,队列将保留内存缓存以尽快地传递消息。

  • x-queue-master-locator:在集群模式下设置镜像队列的主节点信息。

  • x-ha-policy:创建 HA 队列,此参数已失效。

  • x-ha-nodes:HA 队列的分布节点,此参数已失效。


三、代码示例

3.1 实现方式一:channel.queueDeclare()

示例:声明一个包含扩展属性的队列。

Map<String, Object> args = new HashMap<>();
args.put("x-message-ttl", 60000); // 消息TTL为60秒
args.put("x-dead-letter-exchange", "myDeadLetterExchange"); // 死信交换机
args.put("x-dead-letter-routing-key", "myDeadLetterRouingKey"); // 死信路由键channel.queueDeclare("myQueue", true, false, false, args);

3.2 实现方式二:QueueBuilder.build()

示例:声明一个包含扩展属性的队列。

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;Queue queue = QueueBuilder.durable("myQueue").withArgument("x-message-ttl", 60000) // 消息TTL为60秒.withArgument("x-dead-letter-exchange", "myDeadLetterExchange") // 死信交换机.withArgument("x-dead-letter-routing-key", "myDeadLetterRoutingKey") // 死信路由键.build();

整理完毕,完结撒花~ 🌻

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

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

相关文章

c++语言基础19-洗盘子(栈)

题目描述 在餐厅里&#xff0c;洗盘子的工作需要使用到栈这种数据结构。假设你手里有一个盘子堆放区。现在需要模拟洗盘子的过程&#xff0c;每个盘子都有一个编号。 盘子堆放区操作说明&#xff1a; 1. 当操作为 1 时&#xff0c;表示从盘子堆放区拿走顶部的盘子清洗。 2. 当…

数据库管理-第130期 JSON二元性(20240109)

数据库管理130期 2024-01-09 第130期 JSON二元性&#xff08;20240109&#xff09;1 简介2 关系型表和JSON存储的优劣3 Oracle JSON关系型二元性视图总结 第130期 JSON二元性&#xff08;20240109&#xff09; 上周&#xff0c;又双叒飞了一趟上海&#xff0c;也是2024年第一飞…

LeetCode-字符串转换整数atoi(8)

题目描述&#xff1a; 请你来实现一个 myAtoi(string s) 函数&#xff0c;使其能将字符串转换成一个 32 位有符号整数&#xff08;类似 C/C 中的 atoi 函数&#xff09;。 函数 myAtoi(string s) 的算法如下&#xff1a; 读入字符串并丢弃无用的前导空格 检查下一个字符&…

无线网卡怎么连接台式电脑?正确操作步骤分享!

“我在使用电脑时经常都需要用到网络&#xff0c;请问大家在使用无线网卡时怎么将它与台式电脑进行连接的呢&#xff1f;” 使用电脑的用户在进行网上冲浪时都需要先连接网络。如果不想使用网线&#xff0c;无线网卡不仅可以为用户提供网络服务&#xff0c;在使用时该更加灵活和…

MySQL使用count进行行数统计

MySQL count 在使用count进行数据统计行数时&#xff0c;有时候会使用count(*)&#xff0c;有时候会使用count(1)&#xff0c;有时候会使用count(列名)&#xff0c;那么这些有什么不同呢 当使用列名作为参数时&#xff0c;count函数会自动忽略null值&#xff0c;而使用*或者常量…

springCould中的gateway-从小白开始【9】

目录 1.&#x1f35f;网关是什么 2.&#x1f37f;gateway是什么 3.&#x1f95a;gateway能什么 4.&#x1f32d;核心概念 5.&#x1f9c2;工作流程 6.&#x1f9c8;实例 7.&#x1f953;gateway网关配置的方式 8.&#x1f373;配置动态路由 9.&#x1f9c7;pred…

Excel使用pandas拆分单元格扩展

需要&#xff1a; 1. anconda环境 2. excel文件&#xff0c;有拆分标准的单元格内容&#xff08;比如我此次的&#xff1a;**, ***, ****,...) 以前尝试自己写公式&#xff0c;唉&#x1f614;&#xff0c;不是写不出来&#xff0c;就是太折腾了 3. 2行code&#xff0c;超级…

2022 年全国职业院校技能大赛高职组云计算赛项试卷部分解析

2022 年全国职业院校技能大赛高职组云计算赛项试卷部分解析 【赛程名称】高职组-云计算赛项第一场-私有云【任务 1】私有云服务搭建[10 分]【题目 2】Yum 源配置[0.5 分]【题目 3】配置无秘钥 ssh[0.5 分]【题目 4】基础安装[0.5 分]【题目 5】数据库安装与调优[0.5 分]【题目 …

IBM Spectrum LSF 常见问题

IBM Spectrum LSF 常见问题 1、随此产品一起部署的集群中包含哪些 Spectrum LSF 软件包? 包含以下 Spectrum LSF 程序: IBM Spectrum LSF Standard Edition IBM Spectrum LSF 许可证调度程序 IBM Spectrum LSF 数据管理器 2、哪些位置可用于部署 VPC 资源? 可以在 资源部…

yolo v7支持的设备

将一个深度学习模型&#xff08;在这里是YOLOv7&#xff0c;一个目标检测模型&#xff09;从PyTorch导出到不同的格式&#xff0c;以便在不同平台上进行推理&#xff08;inference&#xff09;。列出的方法包括&#xff1a; PyTorch 转 CoreML&#xff08;适用于 macOS/iOS&am…

C++PDF书籍下载

[提高C.性能的编程技术].左飞.扫描版[www.ed2kers.com].pdf 链接: https://pan.baidu.com/s/1uA-oDGYhtAHmGZsbcr_Eow 密码: abv1 深度探索C对象模型.pdf 链接: https://pan.baidu.com/s/1uG9FDIq7T9EZIbjrfAVQaw 密码: gqaj C和C编码安全.pdf 链接: https://pan.baidu.com/s…

0003__WebAssembly完全入门——了解wasm的前世今身

WebAssembly完全入门——了解wasm的前世今身_webassembly.instantiate env-CSDN博客 WebAssembly初级——认识WebAssebmly&#xff08;一&#xff09;-CSDN博客

Hystrix服务熔断机制

熔断机制 熔断机制是应对雪崩效应的一种微服务链路保护机制&#xff0c;当系统链路中的某个微服务出现错误不可用或者响应时间太长的时候就会进行服务的降级&#xff0c;进而熔断该服务的调用&#xff0c;快速返回熔断的响应信息。当检测到该节点微服务调用正常后&#xff0c;…

Ansible自动化运维(二)ad-hoc 模式详解

&#x1f468;‍&#x1f393;博主简介 &#x1f3c5;云计算领域优质创作者   &#x1f3c5;华为云开发者社区专家博主   &#x1f3c5;阿里云开发者社区专家博主 &#x1f48a;交流社区&#xff1a;运维交流社区 欢迎大家的加入&#xff01; &#x1f40b; 希望大家多多支…

506 - System Dependencies (UVA)

题目链接如下&#xff1a; Online Judge 这道题有个小细节&#xff0c;explicitly installed的component&#xff0c;不能被implicitly removed. 有一点拓扑排序的思想&#xff0c;用in[component]代表目前depend on在这个component上的component数量。 我的代码如下&…

秒杀相关问题及答案(2024)

1、描述一个秒杀系统的基本架构&#xff0c;并解释其中的关键组件 一个基本的秒杀系统架构通常由以下关键组件构成&#xff1a; 前端界面&#xff1a;用户与系统交互的界面&#xff0c;提供产品页面、秒杀开始倒计时、按钮等&#xff0c;用于发起秒杀请求。 反向代理和负载均…

【Linux】Linux系统编程——Linux常用快捷键

在 Linux 中&#xff0c;特别是在使用命令行界面时&#xff0c;有许多快捷键可以提高你的工作效率。以下是一些常用的快捷键&#xff1a; 命令行编辑&#xff1a; Ctrl A&#xff1a;移动光标到行首。Ctrl E&#xff1a;移动光标到行尾。Ctrl U&#xff1a;删除光标之前到行…

PLC期末速成——顺序功能图转梯形图

一、根据顺序功能图写出梯形图程序 顺序功能图&#xff1a; 梯形图&#xff1a; 1、程序段1&#xff0c;系统运行标志M0.0的启-保-停控制电路。 2、程序段2&#xff0c;PLC上电与逆行&#xff0c;初始化脉冲M1.0激活初始化步M2.0。 3、程序段3&#xff0c;当M2.0初始化步为活…

使用Dependency Walker和Process Explorer排查瑞芯微工具软件RKPQTool.exe启动报错的问题

目录 1、问题说明 2、使用Dependency Walker查看工具程序的库依赖关系

jupyter内核错误

1、在dos窗口输入以下命令激活环境&#xff1a;anaconda activate 【py环境名&#xff0c;比如py37】&#xff08;目的是新家你一个虚拟环境&#xff09; 2、在虚拟环境py37下安装jupyter notebook&#xff0c;命令&#xff1a;pip install jupyter notebook 3、安装ipykerne…