Java17 --- RabbitMQ之常规使用

目录

一、实现消息可靠性投递

1.1、消息生产者端确认机制

1.2、备份交换机 

1.3、消费端确认机制

二、消费端限流设置

三、消息超时设置

3.1、从队列设置全局超时时间 

3.2、设置消息本身超时时间 

四、死信 

4.1、消费端拒绝接收消息

4.1.1、创建死信交换机与队列 

4.1.2、创建常规交换机与队列

 4.2、消息数量超过队列容纳限度

五、延迟队列

5.1、使用死信队列实现

5.2、使用插件实现 

5.3、创建交换机与队列 

六、事务消息 

七、优先级队列

一、实现消息可靠性投递

1.1、消息生产者端确认机制

修改yml

spring:rabbitmq:host: 192.168.200.110port: 5672username: guestpassword: 123456virtual-host: / publisher-confirm-type: correlated #交换机确认publisher-returns: true #队列确认
@Configuration
@Slf4j
public class RabbitMQConfig implements RabbitTemplate.ConfirmCallback,RabbitTemplate.ReturnsCallback {@Autowiredprivate RabbitTemplate rabbitTemplate;@PostConstructpublic void initRabbitTemplate(){rabbitTemplate.setConfirmCallback(this);rabbitTemplate.setReturnsCallback(this);}//消息发送到交换机成功或失败都会调用@Overridepublic void confirm(CorrelationData correlationData, boolean ack, String cause) {log.info("correlationData:" + correlationData);log.info("ack:" + ack);log.info("cause:" + cause);}//发送到队列失败调用@Overridepublic void returnedMessage(ReturnedMessage returnedMessage) {log.info("消息主体：" + new String(returnedMessage.getMessage().getBody()));log.info("应答码:" + returnedMessage.getReplyCode());log.info("描述：" + returnedMessage.getReplyText());log.info("使用交换机:" + returnedMessage.getExchange());log.info("消息使用的路由键:" + returnedMessage.getRoutingKey());}
}
@SpringBootTest
public class MQTest {public static final String EXCHANGE_DIRECT = "exchange.direct.order";public static final String ROUTING_KEY = "order";@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void test1(){rabbitTemplate.convertAndSend(EXCHANGE_DIRECT,ROUTING_KEY,"你好，美羊羊");}
}

1.2、备份交换机 

创建备份交换机

 

创建绑定队列

 

将原交换机与备份交换机绑定

 

1.3、消费端确认机制

修改yml

 

spring:rabbitmq:host: 192.168.200.110port: 5672username: guestpassword: 123456virtual-host: /listener:simple:acknowledge-mode: manual #手动确认

    @RabbitListener(queues = {QUEUE_NAME})public void getMessage(String date, Message message, Channel channel) throws IOException {//获取当前deliveryTagIDlong deliveryTag = message.getMessageProperties().getDeliveryTag();try {log.info(" "+1 / 0);//成功返回ACK信息channel.basicAck(deliveryTag,false);log.info("接收消息为：" + date);} catch (Exception e) {//获取消息是否重复投递Boolean redelivered = message.getMessageProperties().getRedelivered();//失败返回NACK信息if (redelivered){//long var1,// boolean var3,// boolean var4 控制消息是否重新放回队列channel.basicNack(deliveryTag,false,false);}else {channel.basicNack(deliveryTag,false,true);}throw new RuntimeException(e);}}
}

二、消费端限流设置

只需要修改yml

spring:rabbitmq:host: 192.168.200.110port: 5672username: guestpassword: 123456virtual-host: /listener:simple:acknowledge-mode: manual #手动确认prefetch: 1 #设置每次从队列中读取消息数

三、消息超时设置

3.1、从队列设置全局超时时间 

 

3.2、设置消息本身超时时间 

@Testpublic void test4(){//创建消息后置处理器MessagePostProcessor messagePostProcessor = message -> {//设置过期时间，单位毫秒message.getMessageProperties().setExpiration("10000");return message;};rabbitTemplate.convertAndSend(EXCHANGE_DIRECT,ROUTING_KEY,"a",messagePostProcessor);}

四、死信 

4.1、消费端拒绝接收消息

4.1.1、创建死信交换机与队列 

正常创建绑定即可 

4.1.2、创建常规交换机与队列

创建常规队列注意事项

 

 4.2、消息数量超过队列容纳限度

 @Testpublic void test5(){for (int i = 1; i <=20 ; i++) {rabbitTemplate.convertAndSend(EXCHANGE_DIRECT_NORMAL,ROUTING_KEY_NORMAL,"a"+i);}}

五、延迟队列

5.1、使用死信队列实现

5.2、使用插件实现 

 docker inspect rabbitmq

下载的插件放入source后的目录 

进入容器内部

docker exec -it rabbitmq /bin/bash 

启动插件

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

退出容器

exit

重启容器

docker restart rabbitmq

5.3、创建交换机与队列 

 

队列正常创建，无需参数设置 

测试代码：

 public static final String EXCHANGE_DIRECT_DELAY = "exchange.delay";public static final String ROUTING_KEY_DELAY = "delay";
@Testpublic void test6(){//创建消息后置处理器MessagePostProcessor messagePostProcessor = message -> {//设置过期时间，单位毫秒//必须安装启动延迟插件设置才生效message.getMessageProperties().setHeader("x-delay","10000");return message;};rabbitTemplate.convertAndSend(EXCHANGE_DIRECT_DELAY,ROUTING_KEY_DELAY,"你好，插件" + new SimpleDateFormat("HH:mm:ss").format(new Date()),messagePostProcessor);}
public static final String QUEUE_NAME_DELAY = "queue.delay";
@RabbitListener(queues = {QUEUE_NAME_DELAY})public void getMessageDelay(String date, Message message, Channel channel) throws Exception {//获取当前deliveryTagIDlong deliveryTag = message.getMessageProperties().getDeliveryTag();//成功返回ACK信息channel.basicAck(deliveryTag,false);log.info("接收消息为：" + date);log.info("当前时间为：" + new SimpleDateFormat("HH:mm:ss").format(new Date()));}

六、事务消息 

 在Java配置类进行设置

@Beanpublic RabbitTransactionManager transactionManager(CachingConnectionFactory cachingConnectionFactory){return new RabbitTransactionManager(cachingConnectionFactory);}@Beanpublic RabbitTemplate rabbitTemplate(CachingConnectionFactory cachingConnectionFactory){RabbitTemplate rabbitTemplate1 = new RabbitTemplate(cachingConnectionFactory);rabbitTemplate1.setChannelTransacted(true);return rabbitTemplate1;}
 @Test@Transactional@Rollback(value = false)public void test7(){rabbitTemplate.convertAndSend(EXCHANGE_DIRECT,ROUTING_KEY,"异常前");int var = 3 / 0;rabbitTemplate.convertAndSend(EXCHANGE_DIRECT,ROUTING_KEY,"异常后");}

七、优先级队列

 创建交换机与队列

@Testpublic void test8(){//创建消息后置处理器MessagePostProcessor messagePostProcessor = message -> {message.getMessageProperties().setPriority(3);return message;};rabbitTemplate.convertAndSend("exchange.priority","priority","第3级",messagePostProcessor);}

 

 

 

 

 

 

 

 

 

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

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

相关文章

LangChain入门学习笔记（一）——Hello World

LangChain入门学习笔记（一）——Hello World

什么是LangChain LangChain是一个开源&#xff08;github repo&#xff09;的大语言模型应用开发框架&#xff0c;提供了一整套的工具、方法和接口去帮助程序员构建基于大语言模型的端到端应用。LangChain是长链&#xff08;long chain&#xff09;的意思&#xff0c;它的一个…
阅读更多...
Linux驱动开发笔记（八）输入子系统

Linux驱动开发笔记（八）输入子系统

文章目录 前言一、输入子系统1. 子系统的引入2. 组成部分3. 事件处理流程4. 相关数据结构 二、程序编写1. 相关API函数1.1 input_allocate_device ( )1.2 input_free_device ( )1.3 input_register_device ( )1.4 input_unregister_device ( )1.5 input_event ( )1.6 input_rep…
阅读更多...
Prometheus写入influxDB：中间件remote_storage_adapter

Prometheus写入influxDB：中间件remote_storage_adapter

Prometheus写入influxDB&#xff1a;中间件remote_storage_adapter prometheus默认采用的是本地磁盘做数据存储&#xff0c;本地存储的优势就是运维简单但是缺点就是无法海量的metrics持久化和数据存在丢失的风险,数据写入可能造成wal文件损坏导致采集数据无法再写入的问题。 …
阅读更多...
【嵌入式DIY实例】-Nokia 5110显示DS18B20传感器数据

【嵌入式DIY实例】-Nokia 5110显示DS18B20传感器数据

Nokia 5110显示DS18B20传感器数据 文章目录 Nokia 5110显示DS18B20传感器数据1、硬件准备2、代码实现本文将介绍如何使用 ESP8266 NodeMCU 板和 DS18B20 数字温度传感器实现简单的温度测量站。 NodeMCU 微控制器 (ESP8266EX) 从 DS18B20 传感器读取温度值，并将其打印在诺基亚 …
阅读更多...
Nginx部署Vue项目css文件能加载但是不生效

Nginx部署Vue项目css文件能加载但是不生效

目录 问题描述问题解决 问题描述 Nginx部署打包后的Vue项目css文件能加载但是不生效&#xff0c; 问题解决 查看响应标头&#xff0c;发现不对劲&#xff0c; Content-Type: text/plain正确的应该是 Content-Type: text/css根本原因是nginx没有告诉浏览器正确的文件类型 所…
阅读更多...
Postman接口测试/接口自动化实战教程

Postman接口测试/接口自动化实战教程

一、API 自动化测试 Postman 最基本的功能用来重放请求&#xff0c;并且配合良好的 response 格式化工具。 高级点的用法可以使用 Postman 生成各个语言的脚本&#xff0c;还可以抓包&#xff0c;认证&#xff0c;传输文件。 仅仅做到这些还不能够满足一个系统的开发&#x…
阅读更多...
Python学习打卡：day05

Python学习打卡：day05

day5 笔记来源于&#xff1a;黑马程序员python教程&#xff0c;8天python从入门到精通&#xff0c;学python看这套就够了 目录 day538、函数的初体验39、函数的基础定义语法函数的定义注意事项 40、函数的基础定义案例练习41、函数的传入参数42、函数的传入参数案例练习——升…
阅读更多...
毕业年薪30W起！25届最近5年浙江大学自动化考研院校分析

毕业年薪30W起！25届最近5年浙江大学自动化考研院校分析

浙江大学 目录 一、学校学院专业简介 二、考试科目指定教材 三、近5年考研分数情况 四、近5年招生录取情况 五、最新一年分数段图表 六、历年真题PDF 七、初试大纲复试大纲 八、学费&奖学金&就业方向 一、学校学院专业简介 二、考试科目指定教材 1、考试科目…
阅读更多...
揭秘招生简章的制作方法

揭秘招生简章的制作方法

一年一度的招生季即将来临&#xff0c;各大院校纷纷摩拳擦掌&#xff0c;准备迎接新的学子。对于学校而言&#xff0c;招生简章是其对外宣传的重要窗口&#xff0c;它直接关系到学校的招生效果和声誉。那么&#xff0c;如何制作一份既吸引人又实用的招生简章呢&#xff1f;下面…
阅读更多...
【leetcode--字母异位词分组】

【leetcode--字母异位词分组】

class Solution:def groupAnagrams(self, strs: List[str]) -> List[List[str]]:np collections.defaultdict(list)for st in strs:name "".join(sorted(st))np[name].append(st)return list(np.values()) collections.defaultdict(list)创建字典类型&#xff…
阅读更多...
Git代码冲突原理与三路合并算法

Git代码冲突原理与三路合并算法

Git代码冲突原理 Git合并文件是以行为单位进行一行一行合并的&#xff0c;但是有些时候并不是两行内容不一样Git就会报冲突&#xff0c;这是因为Git会帮助我们进行分析得出哪个结果是我们所期望的最终结果。而这个分析依据就是三路合并算法。当然&#xff0c;三路合并算法并不…
阅读更多...
Flowable-决策表设计器

Flowable-决策表设计器

✨✨✨ 最好用的Flowable决策表设计器 ✨✨✨ 最好用的Flowable流程设计器 本文中内容和案例出自贺波老师的书《深入Activiti流程引擎&#xff1a;核心原理与高阶实战》&#xff0c;书中的介绍更全面、详细&#xff0c;推荐给大家。 深入Activiti流程引擎
阅读更多...
C++ 31 之 静态成员变量

C++ 31 之 静态成员变量

#include <iostream> #include <string.h> using namespace std;// 特点: // 1.在编译阶段就分配了内存空间 // 2.类内声明&#xff0c;在类外进行初始化 // 3.所有对象共享一份静态成员数据 class Students01{ public:static int s_a; // 静态成员变量int s_b; };…
阅读更多...
LSS 和 BEVDepth算法解读

LSS 和 BEVDepth算法解读

前言 当前BEV的研究大都基于深度学习的方法&#xff0c;从组织BEV特征信息的方式来看&#xff0c;主流方法分属两类&#xff1a;自底向上方法和自顶向下方法。 自底向上方法比较早的代表工作是LSS&#xff0c;后来BEVDet、BEVDepth等也是基于LSS的框架来进行优化。自底向上方…
阅读更多...
电子画册制作与传统画册相比，有哪些优势？

电子画册制作与传统画册相比，有哪些优势？

在当今数字化时代&#xff0c;电子画册作为一种新兴的媒体形式&#xff0c;其制作与传统画册相比具有显著的优势。以下是对这些优势的详细探讨。 首先&#xff0c;电子画册的制作过程通常更加便捷和经济。相较于传统画册需要经历的繁琐的印刷过程&#xff0c;电子画册的制作大多…
阅读更多...
【C++课程学习】：类和对象（拷贝构造和运算符重载）

【C++课程学习】：类和对象（拷贝构造和运算符重载）

&#x1f381;个人主页&#xff1a;我们的五年 &#x1f50d;系列专栏&#xff1a;C课程学习 &#x1f389;欢迎大家点赞&#x1f44d;评论&#x1f4dd;收藏⭐文章 目录 ✍拷贝构造&#xff1a; &#x1f349;特点一&#xff1a; &#x1f349;特点二&#xff1a; &…
阅读更多...
（三十）Flask之wtforms库【剖析源码上篇】

（三十）Flask之wtforms库【剖析源码上篇】

每篇前言&#xff1a; &#x1f3c6;&#x1f3c6;作者介绍&#xff1a;【孤寒者】—CSDN全栈领域优质创作者、HDZ核心组成员、华为云享专家Python全栈领域博主、CSDN原力计划作者 &#x1f525;&#x1f525;本文已收录于Flask框架从入门到实战专栏&#xff1a;《Flask框架从入…
阅读更多...
45.Python-web框架-Django - 开始建立第一个项目

45.Python-web框架-Django - 开始建立第一个项目

目录 1.django是什么&#xff1f; 2.Pycharm 社区版&#xff0c;还是专业版&#xff1f; 3.开始django&#xff0c;Pycharm专业版 创建一个Django项目 运行一个Django项目 运行方法一&#xff0c;命令行的方式 运行方法二&#xff0c;配置Django Server的方式 4.django尊…
阅读更多...
gpio-0设置成输出失败的原因

gpio-0设置成输出失败的原因

原因 spi驱动先设置gpio-0成了输出&#xff1b; 但是后面其他驱动&#xff0c;使用of_property_read_u32获取设备树节点的属性时&#xff0c;没去判断返回值&#xff1b;而直接使用参数返回的0&#xff0c;导致gpio-0又被设置成了输入 实例 正常的如下&#xff0c;gpio显示…
阅读更多...
入职3年-我如何做一名AI产品经理（文末福利）

入职3年-我如何做一名AI产品经理（文末福利）

引言 从2021年校招加入京东开始&#xff0c;我一直从事AI产品经理的工作&#xff0c;有幸见证了AI行业的热情从一台台服务器烧到了全世界各个角落&#xff0c;也见证了京东AI中台团队的影响力如何一步步的扩大。从21年的迷茫到24年的坚定&#xff0c;很庆幸我正走在适合自己的…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023