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的队列模式：简单队列、工作队列、发布订阅模式、路由模式、主题 ... »
.NET为什么推荐它作为RabbitMQ消息队列的首选开发工具
支持.Net Core(2.0及以上)/.Net Framework(4.5及以上)，可以部署在Docker, Windows, Linux, Mac。 RabbitMQ作为一款主流的消息队列工具早已广受欢迎。相比于其它的MQ工具，RabbitMQ支持的语言更多、功能更完善。 本文提供一种市面上 »
我这.NET菜鸟，用它开发RabbitMQ消息队列后，竟被老板一夜提拔为架构师
【讲故事】 自2022年末推出此工具以来，相关文章已被圈内顶尖的几家.NET头条号转载，而且短短数月，已有超100个团队/个人开发者使用它来操控RabbitMQ消息队列，反响可谓十分火爆。故本次经典重现，以飨读者。 【正文】 支持.Net Core(2.0及以上)/.Net Framework( »
通过Nacos配置刷新进行RabbitMQ消费者在线启停
前提 公司在做一些金融相关业务，某些时候由于数据提供商定期维护或者特殊原因需要暂停某些服务的消费者。之前选用的消息队列技术栈是RabbitMQ，用于微服务之间的消息投递，对于这类需要暂停消费者的场景是选用注释掉消费者Bean中的相应Spring(Boot)注解重新发布来实现，后面需要重新启动消费就是 ... »
.Net Core对于`RabbitMQ`封装分布式事件总线
首先我们需要了解到分布式事件总线是什么； 分布式事件总线是一种在分布式系统中提供事件通知、订阅和发布机制的技术。它允许多个组件或微服务之间的协作和通信，而无需直接耦合或了解彼此的实现细节。通过事件总线，组件或微服务可以通过发布或订阅事件来实现异步通信。 例如，当一个组件完成了某项任务并生成了一个事件 ... »
RabbitMQ消息队列入门及解决常见问题
RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。 ... »
MQ系列11：如何保证消息可靠性传输（除夕奉上）
MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障MQ系列9：高可 »
如何利用rabbitMq的死信队列实现延时消息
目录 前言 mq基本的消息模型 mq死信队列的消息模型 maven依赖 配置普通队列和死信队列 死信队列消费者 发送消息测试 测试成功 总结 前言 使用mq自带的死信去实现延时消息要注意一个坑点，就是mq只会检测队首的消息的过期时间，假设先放入队列10s过期消息，再放入2s过期。 »
RabbitMQ交换机使用场景和消息可靠性总结分析
目录 RabbitMQ的一些基本组件 各种类型交换机的使用场景 扇形交换机（Fanout） 使用场景 直连交换机（Direct） 使用场景 主题交换机（Topic） 关于延时队列 消息监听 如何保证消息不重复消费 消息可靠性如何保证 RabbitMQ的一些基本组件 Pro »
docker-compose安装RabbitMQ及插件操作步骤
目录 准备工作 docker-compose脚本 操作步骤 执行命令 进入容器内，启动我们刚刚添加的插件 查看插件是否有安装成功 优化搭建步骤 目的 思路 步骤 准备工作 RabbitMQ默认不带延迟队列插件，可以到官网去下载指定版本的插件，并手动安装到RabbitMQ环境中， »
RabbitMQ实现Work Queue工作队列的示例详解
RabbitMQ Work Queue工作队列 工作队列(又称任务队列)的主要思想是避免立即执行资源密集型任务，而不得不等待它完成。 相反我们安排任务在之后执行。我们把任务封装为消息并将其发送到队列。在后台运行的工作进程将弹出任务并最终执行作业。当有多个工作线程时，这些工作线程将一起处理这些 »
使用java代码调用rabbitmq接口进行新增编辑mq用户、虚拟机vhost、动态创建交换机exchange、队列queue以及设置权限，绑定vhost与exchange等操作
使用java代码操作rabbitmq时，首先需要一个有创建用户等权限的管理员账号，需要在rabbitmq的后台管理页面手动创建这个账号，系统推荐的这几个tag可以让账号有rabbitmq后台管理页面的访问权限 »
MQ系列10：如何保证消息幂等性消费
MQ系列1：消息中间件执行原理 MQ系列2：消息中间件的技术选型 MQ系列3：RocketMQ 架构分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的发送模式 MQ系列6：消息的消费 MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障 M ... »
MQ系列9：高可用架构分析
MQ系列1：消息中间件执行原理 MQ系列2：消息中间件的技术选型 MQ系列3：RocketMQ 架构分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的发送模式 MQ系列6：消息的消费 MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障 1 ... »
1小时快速上手RabbitMQ(简介及安装过程)
目录 1.MQ的介绍 1.1 MQ的基本概念 1.2 MQ的优缺点 1.2.1 优点1：应用解耦 1.2.2 优点2：异步提速 1.2.3 优点3：削峰填谷 1.2.4 缺点 1.3常见的消息中间件 2.RabbitMQ的介绍与安装 2.1 RabbitMQ简介 2.2 JMS概念 »
netcore下RabbitMQ队列、死信队列、延时队列及小应用
关于安装rabbitmq这里一笔掠过了。 下面进入正题： 1.新建aspnetcorewebapi空项目，NormalQueue,删除controllers文件夹已经无关的文件，这里为了偷懒不用console控制台： public class Program { public static void ... »
什么是Rabbitmq消息队列？ (安装Rabbitmq,通过Rabbitmq实现RPC全面了解,从入门到精通)
Rabbitmq 一: 消息队列介绍 1.介绍 消息队列就是基础数据结构中的 "先进先出" 的一种数据机构。想一下，生活中买东西需要排队，先排队的人先买消费，就是典型的 "先进先出"。 # 扩展 redis: 可以作为简单的消息队列 celery: 本事就是基于消息队列进行的封装。 2.MQ解决了什 ... »