1. 死信队列 1.1 基本概念 死信即指无法被消费的消息。一般来说，producer 将消息投递到 broker 或者直接到 queue 里了，consumer 从 queue 取出消息进行消费，但某些时候由于特定的原因导致 queue 中的某些消息无法被消费，这样的消息如果没有后续的处理，就变成了死信，而死信队列则是专门用于处理死信的队列。 出现死信的原因有三种： 消息TTL过期（Time To Live生存时间），但没有被消费 队列达到最大长度，无法继续添加数据到MQ

源码在文章末尾👇🏻 前置学习知识 SpringAMQP 简单入门demo FanoutExchange交换机代码教程 DirectExchange交换机简单入门demo 1. 配置文件 logging: pattern: dateformat: MM-dd HH:mm:ss:SSS spring: rabbitmq: host: localhost # rabbitMQ的ip地址 port: 5672 # 端口 username: gue

RabbitMQ版本升级 将rabbitmq server 从3.8.1升级到3.10.0 ，需要同时升级erlang 服务 使用rabbitmq用户停止rabbitmq服务 rabbitmqctl stop 使用root用户升级erlang服务 rpm -Uvh erlang-23.3.4.8-1.el7.x86_64.rpm 使用root用户升级rabbitmq-server服务 rpm -Uvh rabbitmq-server-3.10.0-1.el7.noarch.rpm

𝑰’𝒎 𝒉𝒉𝒈, 𝑰 𝒂𝒎 𝒂 𝒈𝒓𝒂𝒅𝒖𝒂𝒕𝒆 𝒔𝒕𝒖𝒅𝒆𝒏𝒕 𝒇𝒓𝒐𝒎 𝑵𝒂𝒏𝒋𝒊𝒏𝒈, 𝑪𝒉𝒊𝒏𝒂. 🏫 𝑺𝒉𝒄𝒐𝒐𝒍: 𝑯𝒐𝒉𝒂𝒊 𝑼𝒏𝒊𝒗𝒆𝒓𝒔𝒊𝒕𝒚 🌱 𝑳𝒆𝒂𝒓𝒏𝒊𝒏𝒈: 𝑰’𝒎 𝒄𝒖𝒓𝒓𝒆𝒏𝒕𝒍𝒚 𝒍𝒆𝒂𝒓𝒏𝒊𝒏𝒈 𝒅𝒆𝒔𝒊𝒈𝒏 𝒑𝒂𝒕𝒕𝒆𝒓𝒏, 𝑳𝒆𝒆𝒕𝒄𝒐𝒅𝒆, 𝒅𝒊𝒔𝒕𝒓𝒊𝒃𝒖𝒕𝒆𝒅 𝒔𝒚𝒔𝒕𝒆𝒎, 𝒎𝒊𝒅𝒅𝒍𝒆𝒘𝒂𝒓𝒆 𝒂𝒏𝒅 𝒔𝒐 𝒐𝒏. 💓 𝑯𝒐𝒘 𝒕𝒐 𝒓𝒆𝒂𝒄𝒉 𝒎𝒆：𝑽𝑿 📚 𝑴𝒚 𝒃𝒍𝒐𝒈: 𝒉𝒕𝒕𝒑𝒔://𝒉𝒉𝒈𝒚𝒚𝒅𝒔.𝒃𝒍𝒐𝒈.𝒄𝒔𝒅𝒏.𝒏𝒆𝒕/

RabbitMQ 学习（七）----发布确认 发布确认是一个保证RabbitMQ 可靠性的一个机制   保证生产者将信息成功的发送到 RabbitMQ的 server端了，那么broker就会回一个确认，如果没有收到或者收到拒绝信息，那么说明可能网络不好没有发送成功，server端宕机了，broker拒绝接收等情况，如果不进行后续处理，那么信息就会丢失，生产者收到失败的消息使用回调函数在进行处理。   生产者将信道设置成 confirm 模式，所有在该信道上发布的消息都会指定一个

svbadmin学习日志 本学习日志是使用Springboot和Vue来搭建的后台管理系统： 演示地址：http://118.31.68.110:8081/index.html 账号：root 密码：123 所有代码可以在gitbub上找到，切换到相应分支即可。【代码传送门】 正篇 第一节 spring boot 模块化构建项目第二节 整合mybatisplus完成用户增删改查第三节 整合springsecurity实现基于RBAC的用户登录第四节 springsecurit

📃个人主页:不断前进的皮卡丘 🌞博客描述:梦想也许遥不可及，但重要的是追梦的过程，用博客记录自己的成长，记录自己一步一步向上攀登的印记 🔥个人专栏:消息中间件 1.死信队列 1.1死信队列基本介绍 队列中不能被消费的消息称为死信队列 有时候因为特殊原因，可能导致队列中的某些信息无法被消费，而队列中这些不能被消费的消息在后期没有进行处理，就会变成死信队列，死信队列中的消息称为死信。 应用场景:未来保证订单业务的消息数据不丢失，我们需要使用到RabbitMQ的死

大家好，我是工藤学编程 🦉 一个正在努力学习的小博主，期待你的关注 作业侠系列最新文章😉 Java实现聊天程序 SpringBoot实战系列🐷 【SpringBoot实战系列】RabbitMQ实现消息发送并实现邮箱发送异常监控报警实战 环境搭建大集合 环境搭建大集合(持续更新） 在本栏中，我们之前已经完成了:【SpringBoot实战系列】之发送短信验证码【SpringBoot实战系列】之从Async组件应用实战到ThreadPoolTaskExecutor⾃定义线程池

序章 首先网上有很多的总结和demo ，但是都是比较简单和不符合生产情况的，也没有对数据库的操作，基本上得到消息后也就是直接打印出来，基本上没啥参考价值，废话不多说直接讲解思路。 docker 部署的 参考我另外一遍博客 docker部署rabbitmq 1.总体思路 首先我要保证的是项目在启动之初，就要同时启动队列，并进行消费 队列的各种配置与RabbitMQ连接对象必须保证单例且必须全局注入 支持扩展也就是多个消费者，共同消费一个队列。 把方法独立出来，利于以后的扩展和业务增加