RabbitMQ 正在参加 2021 年度 OSC 中国开源项目评选,请投票支持!
RabbitMQ 在 2021 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
2021 年度 OSC 中国开源项目评选 正在火热进行中,快来投票支持你喜欢的开源项目!
2021 年度 OSC 中国开源项目评选 >>> 中场回顾
RabbitMQ 获得 2021 年度 OSC 中国开源项目评选「最佳人气项目」 !
授权协议 MPL
开发语言 ErLang 查看源码 »
操作系统 跨平台
软件类型 开源软件
开源组织
地区 不详
投 递 者 不详
适用人群 未知
收录时间 2008-11-09

软件简介

RabbitMQ 是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 写成,因此也是继承了这些优点。

AMQP 里主要要说两个组件:Exchange 和 Queue (在 AMQP 1.0 里还会有变动),如下图所示,绿色的 X 就是 Exchange ,红色的是 Queue ,这两者都在 Server 端,又称作 Broker ,这部分是 RabbitMQ 实现的,而蓝色的则是客户端,通常有 Producer 和 Consumer 两种类型:

展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (15)

加载中
这也是Spring 支持最好的,我们现在就在用,有些人说 文档不全的 是因为 这东西很多都是插件化的,要看插件文档
2019/01/03 10:44
回复
举报
不得不说,rocketmq的文档几乎等于没有
2018/07/05 16:59
回复
举报
谁有和其他对比的文章
2018/02/27 18:36
回复
举报
打分: 力荐
非常好用
2017/08/17 16:08
回复
举报
打分: 力荐
这个好用,但是目前还不能完全驾驭。
2017/07/27 16:04
回复
举报
打分: 力荐
可以尝试了解下阿里开源的消息中间件 RocketMQ。 博客介绍:http://www.yunai.me/categories/RocketMQ/?oschina&14
2017/08/05 01:47
回复
举报
打分: 力荐
希望能帮到大家 http://www.codeyyy.com/linux/149-191-157.html
2017/04/21 11:37
回复
举报
#RabbitMQ##ActiveMQ#哪个简单 ?
2017/04/14 16:11
回复
举报
10周年快乐
2017/04/07 18:31
回复
举报
安装了RabbitMQ ,小测一把。数据入下: send 10W 4.6s, reci 10W 6.7S, send 100W 198s, reci 100W 6分钟了,还没出来结果
2012/07/26 12:04
回复
举报
更多评论
发表了资讯
12/04 07:35

RabbitMQ 3.9.11 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,RabbitMQ 也继承了这些优点。 RabbitMQ 3.9.11 是 3.9.x 系列的一个维护版本,此版本至少需要 Erlang 23.2,并支持 Erlang 24,主要变更如下: 核心服务器(Core Server) Bug修复 当启用 TLS 的侦听器无法停止时,它会记录其所有可能包含敏感值的设置。 GitHub 问题:#3803 增强功能 仲裁队列在磁...

0
1
发表了资讯
11/21 07:34

RabbitMQ 发布 3.9.10 和 3.8.26 版本,修复 OAuth 2 插件 bug

RabbitMQ 在 11 月 20 日 发布了 3.9.10 和 3.8.26 版本,RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,RabbitMQ 也继承了这些优点。 RabbitMQ 3.9.10 RabbitMQ 3.9.10 是 3.9.x 系列的一个维护版本,此版本至少需要 Erlang 23.2,支持 Erlang 24。 Core Server Bug Fixes: 现在流协调器对于快速声明和删除周期更具防御能力。GitHub issue: #...

1
0
发表了资讯
11/16 07:20

RabbitMQ 3.8.25 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,RabbitMQ 也继承了这些优点。 RabbitMQ 3.8.25 是一个维护版本,建议所有用户升级到此版本。 普罗米修斯插件(Prometheus Plugin) 增强功能 #2653 新的 Prometheus 警报指标: rabbitmq_alarms_file_descriptor_limit 1|0 rabbitmq_alarms_free_disk_space_watermark 1|0 rabbitmq_alarms_memory...

0
0
11/12 07:23

RabbitMQ 3.9.9 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 RabbitMQ 3.9.9 正式发布,该版本更新内容如下: Core Server 错误修复 修正了一个问题:一个集群成员被重新启动时,节点监视器可能会产生一个错误的网络分区 消息存储弹性的改进 在选出新队列 Leader 的某些情况下,减少了日志噪音 队列 Leader 的重新平衡现在可以减少日...

2
0
发表了资讯
10/20 07:20

RabbitMQ 3.9.8 已发布,AMQP消息服务器

RabbitMQ 3.9.8 发布了,RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 RabbitMQ 3.9.8 是 3.9.x 系列的一个维护版本,如果从 3.9.0 之前的版本升级,请先升级到 3.9 版本。此版本最少需要 Erlang 23.2,支持最新的 Erlang 24.1.2,主要更新内容如下: 重点 bug 修复 如果发布到经典队列时用了强制性标志,即使发布者没...

2
0
发表了资讯
09/25 07:35

RabbitMQ 3.8.23 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 3.8.23 现已发布,这是一个维护版本,官方建议所有用户都进行升级。RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 更新内容如下: Core Server Bug Fixes Proxy protocol header 中传递的 TLS 信息现在附加到连接指标,就好像它是由非代理客户端提供的一样。 GitHub issue:#3175 Classic 队列关闭现在使用更...

0
0
08/10 07:30

RabbitMQ 3.8.20 & 3.9.2 发布

RabbitMQ 3.8.20 & 3.9.2 发布,上述两个版本至少需要 Erlang 23.2,并支持最新的 Erlang 24 版本。更新内容如下: CLI 工具(3.8.20 & 3.9.2) 错误修复 rabbitmq-upgrade drain 和 rabbitmq-upgrade revive 现在记录 warning 和 info 级别,而不是 alert; Shovel 插件(3.8.20 & 3.9.2) 错误修复 在某些涉及节点重启失败的情况下,可能会启动多个 Shovels; Federation 插件(3.8.20 & 3.9.2) 错误修复 在某些涉及节点重启...

0
2
发表了资讯
08/01 07:32

RabbitMQ 3.9.1 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 RabbitMQ 3.9.1 正式发布,该版本更新内容如下: Core Server 错误修正: 使用全局 QoS 预取的客户端(从 3.9.0 开始已废弃)在确认交付时遇到了一个异常; 改进了流协调器在某些情况下的弹性; 当主机名包含非 ASCII 字符时,节点无法启动; CLI 工具 错误修复: rabbit...

0
2
07/27 07:35

RabbitMQ 3.9.0 发布,支持 Erlang 24 并引入 Streams 数据结构

RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 RabbitMQ 3.9.0 正式发布,该版本更新内容如下: 重点更新: Streams Streams 是 RabbitMQ 中一种新的持久化和复制的数据结构(" queue 类型"),它是一种具有非破坏性消费者语义的 append-only 日志模型。 它们可以作为常规 AMQP 0.9.1 队列使用,也可以通过新的二进制协...

0
2
07/07 06:16

RabbitMQ 3.8.19 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 RabbitMQ 3.8.19 正式发布,该版本更新内容如下: Erlang/OTP 兼容性说明: 此版本需要 Erlang 23.2 并支持 Erlang 24; Core Server: 增强: 节点启动时的绑定恢复现在更加有效,这意味着在有大量的队列和/或绑定的集群中,节点启动更快; 插件目录路径现在被重复利用了...

0
1
05/06 07:00

RabbitMQ 3.8.16 发布,引入了对 Erlang 24 的支持

RabbitMQ 3.8.16 已发布,RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 Core Server Erlang 新版本支持: 这个版本引入了对 Erlang 24 的支持,并放弃了对 Erlang 22 的支持。Erlang 24 为许多 RabbitMQ 安装和工作负载提供了显著的实际吞吐量改进,预计它将于 2021 年 5 月推出。 同时,请参见配置最新的 Erlang 版本...

0
1
05/04 07:03

RabbitMQ 3.8.15 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 3.8.15 已发布,RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 Core Server Bug 修复: 在某些配置中,Quorum 队列没有像预期的那样频繁地保留快照,这导致没有有效积压队列的磁盘空间使用峰值大大增加; Quorum 队列名称被无意中限制:虚拟主机和实际队列名称的长度被限制为 254 个字符。名字更长的 Quorum...

1
2
03/05 07:07

RabbitMQ 3.8.14 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 3.8.14 已发布,RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 本次更新值得一提的变化: 当用户从3.7.15或较旧版本升级到此版本时,必须格外小心。因为较旧的 RabbitMQ CLI 工具可能与 Erlang 22+ 不兼容,因此用户需要同时升级 RabbitMQ 与 Erlang。 Core 服务器 Bug 修复 Direct reply-to 在 Erlang 22.3 ...

3
3
03/01 07:01

RabbitMQ 3.8.13 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 3.8.13 已发布,RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 Core 服务器 Bug 修复 具有异常长名称(例如150个或更多字符)的节点可能会使用其生成的direct reply-to 标识符来溢出消息属性长度。现在,生成的值几乎完全与节点名称长度脱钩。 管理插件 Bug 修复 Consumer utilisation 指标已改名为 consumer...

0
0
发表于开发技能专区
01/21 07:09

RabbitMQ 3.8.10 发布

RabbitMQ 3.8.10 已发布,RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 主要更新内容包括: Core Server Bug Fixes 使用basic.get对仲裁队列进行重复轮询产生的空响应可能会导致磁盘上的日志段文件无限制增长 GitHub issue: rabbitmq/rabbitmq-server#2651 功能增强 仲裁队列 现在可以使用reject-publish最大长度溢出...

2
5
发表于软件架构专区
2020/09/28 07:44

RabbitMQ 3.8.9 发布

RabbitMQ 3.8.9 已发布,RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 3.8.9 是一个维护版本,专注于 Bugfix 和可用性改进。从该版本开始,结束对 Erlang 21.3 的支持。 主要变化: Core Server Bug Fixes 从3.8.0开始,无意中引入的一个断言可能会阻止经典镜像队列的镜像成功启动,以防主副本在启动时同时发生更改 ...

2
3
发表于软件架构专区
2020/09/04 07:48

RabbitMQ 3.8.8 发布,引入维护模式

RabbitMQ 3.8.8 已经发布。RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 此版本最大亮点是引入了一种新的节点操作模式,称为维护模式。 当将节点放下进行维护并处于维护模式时,该节点将无法用于服务客户端流量,并且将尝试尽可能实际地转移其职责使其安全。当前,这涉及以下步骤: 挂起所有客户端连接侦听器(不接受...

0
3
发表于AI & 大数据专区
2020/08/18 07:26

RabbitMQ 3.8.7 发布

RabbitMQ 3.8.7 发布了。RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 这是一个安全维护版本,主要解决了只针对 Windows 的二进制植入安全漏洞 CVE-2020-5419,该漏洞允许任意代码执行。不过该漏洞要求攻击者具有本地访问权限和提升的特权,并且无法远程执行。 此外修复了使用 rabbitmqctl export_definitions 将可选...

0
6
发表于软件架构专区
2020/08/06 08:08

RabbitMQ 3.8.6 发布,开源协议变更为 MPL 2.0

RabbitMQ 3.8.6 已经发布,这是一个维护版本,主要进行了 bug 修复与可用性改进。 值得关注的是,从这一版本开始,核心 RabbitMQ 服务器与所有 1 级插件使用的开源许可证将从 Mozilla Public License(MPL)1.1 变更为 MPL 2.0。 根据 Mozilla 官方说法,MPL 2.0 与 1.1 主要是进行了简化。例如,不指定源代码必须可用的时间量,而是必须在可执行文件可用时简单地使源代码可用。协议头部已缩短,通知要求也得到了简化。总体而言...

0
4
发表于运维专区
2020/07/26 07:59

RabbitMQ 3.7.27 发布,Erlang 编写的 AMQP 开源实现

RabbitMQ 3.7.27 发布了。RabbitMQ 是一个 Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 编写而成,因此它也继承了这些优点。 这是一个维护版本,包含了来自 3.8.x 的一些反向移植。 此版本不再支持 Erlang/OTP 20.3,现在,在节点启动时检查 Erlang 21.3+是一项硬性要求。 此前 3.8.1 中,针对 Core Server、CLI 工具、管理插件以及 STOMP 插件进行了一些 bug 修复和性能...

0
2
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表了博客
2019/05/28 16:38

软件-MQ-RabbitMQ:RabbitMQ

ylbtech-软件-MQ-RabbitMQ:RabbitMQ RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的,而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。 1.返回顶部 1、 中文名:消息队列 外文名:Message Queue 简 称:MQ 释 义:一种程序对程序的通信方法 目录 1 简介 2 历史 3 基本概念 4 主要特性 5 安装 6 ...

0
0
发表了博客
2019/12/03 10:02

【RabbitMQ】Centos7安装RabbitMQ

介绍   RabbitMQ 是一个在AMQP协议标准基础上完整的,可服用的企业消息系统。它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器。   ①、AMQP,即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同的开发语言等条...

0
0
发表于运维专区
2020/06/09 13:34

RabbitMQ-01-RabbitMQ安装

一、安装前准备 1.需要下载的安装包有 RabbitMQ依赖环境ERLANG和RabbitMQ 安装包; ERLANG安装包下载: 官网下载:https://www.erlang.org/ -- 比较慢 CSDN下载 otp_src_21.3 https://download.csdn.net/download/work201003/12505572 otp_src_21.1 https://download.csdn.net/download/work201003/12505337 otp_src_23 https://download.csdn.net/download/work201003/12505270 RabbitMQ 3.8需要 >=21.3 最好是23 R...

0
0
发表了博客
2020/04/03 08:31

RabbitMQ学习:安装RabbitMQ及RabbitMQ的初步配置(一)

## RabbitMQ基础含义 RabbitMQ是一种消息中间件,用于处理来自客户端的异步消息。服务端将要发送的消息放入到队列池中。接收端可以根据RabbitMQ配置的转发机制接收服务端发来的消息。RabbitMQ依据指定的转发规则进行消息的转发、缓冲和持久化操作,主要用在多服务器间或单服务器的子系统间进行通信,是分布式系统标准的配置。 ## 1、离线安装 #### 下载离线安装包文件 链接:https://pan.baidu.com/s/1akc-vbTrgbtsIDi1TsWofA 提...

0
11
发表了博客
2018/05/08 16:03

RabbitMQ

RabbitMQ部署 系统环境:CentOs7 1.由于RabbitMQ是基于Erlang语言开发,所以在安装RabbitMQ之前,需要先安装Erlang [root@localhost /]# cd usr/local/src/ [root@localhost src]# wget 2. 执行下面命令升级上步下载的rpm软件包 [root@localhost /]# rpm -ivh erlang-19.0.4-1.el7.centos.x86_64.rpm 3. 执行下面命令安装erlang [root@localhost /]# yum -y install erlang 4. 测试Erlang是否安装成功 [root@localhost /]# erl ...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
09/17 15:57

需要给kafka,xxl-job,rabbitmq单独出一个服务吗?

最近再纠结要不要给kafka单独出一个服务A,其它服务调用服务A然后服务A和kafka连接。xxl-job,rabbitmq同理。 如果需要单独出一个服务,这样做的好处和弊端是什么呢? 如果不需要单独出一个服务,这样的好处和弊端又是什么呢?

9
0
发表于开发技能专区
2019/06/21 17:12

rabbitMQ 的 模式不能同时使用吗? 一个消费者使用topic,一个消费者使用Fanout会报一些莫名其妙的错误;单独使用没问题?

channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'order.push' in vhost '/', class-id=50, method-id=10) Fatal exception on listener startup To display the conditions report re-run your application with 'debug' enabled. Caused by: java.io.IOException: null 错误很多,还很长很长;有找不到队列,有io异常,...

1
0
07/19 17:03

rabbitmq如何实现单节点同时只消费一个任务。

在单节点的情况下,如果保证一个客户端同时只消费一个,消费完成后再消费下一个。

2
0
2020/10/16 13:25

rabbitmq延迟队列时间两天,并且有几十万条数据,这样的还适合用延迟队列来做吗

有个功能需要处理客户数据,两天以后再做处理,并且有几十万条数据,这样的场景还适合用延迟队列吗,会不会存太久了

12
0
发表于大前端专区
2018/11/02 14:32

rabbitmq 事务消息是否支持?

想请教一下rabbitmq是否支持分布式事务消息? rocketmq4.3开始支持分布式事务消息. 如果rabbitmq不支持事务消息,一般采取什么机制?

1
0
发表于DevOps专区
2020/07/26 22:19

spring boot 运行中动态切换rabbitmq连接

spring boot 启动加载默认的rabbitmq配置,运行过程中通过接口获取新的rabbitmmq连接信息,连接新的rabbitmq。

4
0
发表于AI & 大数据专区
2018/10/12 12:08

rabbitmq持久化后,重启服务队列内容丢失

队列已经持久化了,也有内容了。 重启服务后,队列名称在,但是内容没了。 望指教!

2
0
2020/07/01 17:29

RabbitMQ怎么实现类似ActiveMQ topic模式 (websoket 集群实现场景)不知道怎么实现 ,求大佬指导

websoket 集群实现 但是发现 RabbitMQ 视乎没有 这种订阅发布模式 , 不熟悉 RabbitMQ 不知道怎么实现 ,求大佬指导

8
1
发表于AI & 大数据专区
2018/05/16 09:33

RabbitMQ 中的生产者指定的CorrelationData,在消费者怎么拿到?

rabbitTemplate.convertAndSend(exchange, routingKey, message, correlationData); 我们在send的时候指定了一个消息id 如何在接收时拿到呢? 求解答~扔个文档过来也行!!

6
0
发表于DevOps专区
2020/04/02 11:33

springboot在写单元测试的时候怎才能不创建真实的连接mock rabbitMQ

自己的项目在单元测试很多的情况下跑覆盖率时在MAC机器上100%会出现oom,以为创建的线程数超出了系统限制。怎么才能够降低创建的线程数量?我看单元测试日志会创建真实的连接去连接MQ,这样每一个class会创建几个连接,能不能把这个rabbitMQ连接在跑单元测试的时候mock掉,有没有什么办法?

5
0
2020/05/21 17:06

spring boot 之前集成了rabbitMq, 使用的是默认配置. 现需要新增一个mq. 如何在不更改之前的mq逻辑下, 把新的MQ集成上呢?

配置了 第二个MQ 以后, 之前代码里面的 第一个MQ 好像也被连到这个来了, 请问这个怎么处理呢?

2
0
发表于开发技能专区
2018/12/07 14:11

rabbitmq客户端一直报socket closed。

用spring 框架集成rabbitmq,作为消费者,服务启动时,一直报错,以前也是这么配置的没有问题。大家有遇到过吗? 2018-12-03 14:30:33,727 [AMQP Connection 192.168.145.174:5672] ERROR com.rabbitmq.client.impl.ForgivingExceptionHandler 124 log An unexpected connection driver error occured java.net.SocketException: socket closed at java.net.SocketInputStream.socketRead0(Native Method) at java.net.SocketI...

1
0
发表于软件架构专区
2020/04/09 10:09

请问rabbitmq为什么比kafka可靠啊

kafka我记得也有ack确认机制啊

5
0
发表于软件架构专区
2020/03/19 16:58

RabbitMq 如何保证一个进程内,多条消息的一致性?

我有一个应用场景 进程: 1.商品上架 i-- 商品上架成功 ii-- 发送 更新库存消息 iii-- 发送 发送提示有关人员消息         情况一: 商品上架失败,直接本地事物回滚 情况二: 发送库存更新失败,直接让事物回滚 情况三: 发送提示有关人员消息失败 ,但此时已经发送更新库存了, 如何让 更新库存回滚 如何让发送发送提示有关人员消息失败时,将更新库存的消息回退 遇到...

6
0
发表于开发技能专区
2018/05/18 17:30

RabbitMQ 延时队列的问题

想要实现类似以下的需要, 在订单系统中,一个用户下单之后通常有30分钟的时间进行支付,如果30分钟之内没有支付成功,那么这个订单将取消。 将消息设置过期时间,发送到死信队列,过期后转发到监听的队列。 参考 https://blog.csdn.net/i_vic/article/details/72742277 以上代码实现了,当单个消息大的时候,没有问题。 问题是多个消息,而且每个消息过期时间不一样,这时候问题就来了,如果第一个过期时间太久,那么第二消息要...

14
2
发表于运维专区
2018/12/05 22:20

rabbitmq spring boot 动态根据配置文件创建消费者监听器

因为现在用注解创建消费者监听器,都是通过:@RabbitListener 所有没有是很什么方法动态创建队列,比如我配置文件里面配置 了 队列名名称:queueTest1, queueTest2 然后在其他启动的时候得到启用的队列名称,动态的循环创建 消费者监听器? 而不是 事先写在类上面添加监听器注解

3
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
15 评论
631 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部