.NET Core中RabbitMQ使用死信队列的实现
在.NET Core中，可以使用RabbitMQ.Client库来实现与RabbitMQ的交互。 RabbitMQ死信队列（Dead Letter Queue）是一种用于存储和处理无法被正常消费或传递的消息的队列，也称为死信交换机（Dead Letter Exchange）。RabbitMQ死信队 »
SpringBoot 整合RabbitMq 自定义消息监听容器来实现消息批量处理
目录 SpringBoot 整合RabbitMq 自定义消息监听容器来实现消息批量处理 前言 添加依赖 配置文件 编写监听器 创建SimpleRabbitListenerContainerFactory 发送消息 SpringBoot 整合RabbitMq 自定义消息监听容器来实现消息批 »
SpringBoot 整合RabbitMq 自定义消息监听容器来实现消息批量处理
目录 SpringBoot 整合RabbitMq 自定义消息监听容器来实现消息批量处理 前言 添加依赖 配置文件 编写监听器 创建SimpleRabbitListenerContainerFactory 发送消息 SpringBoot 整合RabbitMq 自定义消息监听容器来实现消息批 »
一文带你了解RabbitMQ消息转换器
在SpringAMQP的发送方法中，接收消息的类型是Object，也就是说我们可以发送任意对象类型的消息，SpringAMQP会帮我们序列化为字节后发送。 我们以实际例子来做一个演示，首先在项目中的FanoutConfig配置类声明一个新的队列： package cn.itcast.mq.con »
一文带你了解RabbitMQ消息转换器
在SpringAMQP的发送方法中，接收消息的类型是Object，也就是说我们可以发送任意对象类型的消息，SpringAMQP会帮我们序列化为字节后发送。 我们以实际例子来做一个演示，首先在项目中的FanoutConfig配置类声明一个新的队列： package cn.itcast.mq.con »
一文看懂RabbitMQ消息丢失如何防止
目录 一.RabbitMQ消息丢失的三种情况 第一种： 第二种： 第三种： 二.RabbitMQ消息丢失解决方案 1.针对生产者 方案1 ：开启RabbitMQ事务 方案2： 使用confirm机制 2.针对RabbitMQ （1）消息持久化 （2）设置集群镜像模式 （3）消息补偿机 »
一文看懂RabbitMQ消息丢失如何防止
目录 一.RabbitMQ消息丢失的三种情况 第一种： 第二种： 第三种： 二.RabbitMQ消息丢失解决方案 1.针对生产者 方案1 ：开启RabbitMQ事务 方案2： 使用confirm机制 2.针对RabbitMQ （1）消息持久化 （2）设置集群镜像模式 （3）消息补偿机 »
Spring整合消息队列RabbitMQ流程
目录 搭建生产者工程 创建工程 添加依赖 配置整合 发送消息 搭建消费者工程 创建工程 添加依赖 配置整合 消息监听器 搭建生产者工程 创建工程 添加依赖 修改pom.xml文件内容为如下： <?xml version="1.0" encoding=" »
SpringBoot整合消息队列RabbitMQ
目录 简介 生产端 添加依赖 启动类 配置RabbitMQ 配置文件 绑定交换机和队列 搭建消费者工程 创建工程 添加依赖 启动类 配置RabbitMQ 消息监听处理类 测试 简介 在Spring项目中，可以使用Spring-Rabbit去操作RabbitMQ https:// »
Golang实现RabbitMQ中死信队列几种情况
目录 1、造成死信队列的主要原因 2、操作逻辑图 3、代码实战 3.1 针对原因1：消费者超出时间未应答 3.2 针对原因2：限制一定的长度 3.3 针对原因3：消费者拒绝的消息回到死信队列中 下面这段教程针对是你已经有一些基本的MQ的知识，比如说能够很清楚的理解queue、exchang »
Golang实现RabbitMQ中死信队列几种情况
目录 1、造成死信队列的主要原因 2、操作逻辑图 3、代码实战 3.1 针对原因1：消费者超出时间未应答 3.2 针对原因2：限制一定的长度 3.3 针对原因3：消费者拒绝的消息回到死信队列中 下面这段教程针对是你已经有一些基本的MQ的知识，比如说能够很清楚的理解queue、exchang »
GoLang RabbitMQ TTL与死信队列以及延迟队列详细讲解
目录 TTL 死信队列 延迟队列 Go实现延迟队列 TTL TTL 全称 Time To Live（存活时间/过期时间）。当消息到达存活时间后，还没有被消费，就会被自动清除。RabbitMQ可以设置两种过期时间： 对消息设置过期时间。 对整个队列（Queue）设置过期时间。 如何设置 »
GoLang RabbitMQ TTL与死信队列以及延迟队列详细讲解
目录 TTL 死信队列 延迟队列 Go实现延迟队列 TTL TTL 全称 Time To Live（存活时间/过期时间）。当消息到达存活时间后，还没有被消费，就会被自动清除。RabbitMQ可以设置两种过期时间： 对消息设置过期时间。 对整个队列（Queue）设置过期时间。 如何设置 »
三天吃透RabbitMQ面试八股文
本文已经收录到Github仓库，该仓库包含计算机基础、Java基础、多线程、JVM、数据库、Redis、Spring、Mybatis、SpringMVC、SpringBoot、分布式、微服务、设计模式、架构、校招社招分享等核心知识点，欢迎star~ Github地址：https://github.c »
Spring boot 整合RabbitMQ实现通过RabbitMQ进行项目的连接
目录 什么是RabbitMQ 消息队列：接受并转发消息，类似于快递公司 消息队列的优点 消息队列的特性 RabbitMQ特点 RabbitMQ核心概念 Producer :消息生产者 Message :消息 Exchange :交换机 Binding :绑定交换机和队列 Routing k »
RabbitMQ真实生产故障问题还原与分析
RabbitMQ生产故障问题分析 由某一次真实生产环境rabbitMQ故障引发血案，下面复盘问题发生原因以及问题解决方法。 1、 问题引发 由某个服务BI-collector-xx队列出现阻塞，影响很整个rabbitMQ集群服务不可用，多个应用MQ生产者服务出现假死状态，系统影响面较广 »
RabbitMQ 延迟消息实战
RabbitMQ 延迟消息实战 现实生活中有一些场景需要延迟或在特定时间发送消息，例如智能热水器需要 30 分钟后打开，未支付的订单或发送短信、电子邮件和推送通知下午 2:00 开始的促销活动。 RabbitMQ 本身没有直接支持延迟队列的功能，如果您搜索“如何在 RabbitMQ 中使用延迟消息” ... »
django+celery+RabbitMQ自定义多个消息队列的实现
关于django celery的使用网上有很多文章，本文就不多做更多的说明。 本文使用版本 python==3.8.15 Django==3.2.4 celery==5.2.7 celery.py from __future__ import absolute_import, unicod »
大曝光！从RabbitMQ平滑迁移至Kafka架构设计方案！
历史原因，公司存在多个 MQ 同时使用的问题，我们中间件团队在去年下半年开始支持对 Kafka 和 Rabbit 能力的进行封装，初步能够完全支撑业务团队使用。 鉴于在之前已经基本完全实施 Kafka 管控平台、以及 Kafka 集群迁移管控，我们基本可以认为团队对于 Kafka 的把控能力初具规模 ... »
ASP.NET Core知识之RabbitMQ组件使用（二）
近期，业务调整，需要内网读取数据后存入到外网，同时，其他服务器也需要读取数据,于是我又盯上了RabbitMQ。在展开业务代码前，先看下RabbitMQ整体架构，可以看到Exchange和队列是多对多关系。 下面，我们详细说说RabbitMQ的队列模式：简单队列、工作队列、发布订阅模式、路由模式、主题 ... »