跳至主内容

RabbitMQ Streams 的交付优化

·6 分钟阅读

RabbitMQ Streams 专为高吞吐量场景而设计,但当您的入口速率较低时会发生什么?较低的消息速率会严重影响交付性能,使消息消耗速率降低一个数量级。RabbitMQ 4.2 引入了一项优化,可显著提高低吞吐量流的交付速率,使所有支持的协议都受益。

RabbitMQ Streams 的代理端 SQL 过滤

·5 分钟阅读

RabbitMQ 4.2 为 引入了 SQL 过滤器表达式,支持强大的代理端消息过滤。

在我们的基准测试中,将 SQL 过滤器与布隆过滤器结合使用,在具有高入口速率的高度选择性场景中,过滤速率超过了每秒 400 万条消息。这意味着只有您的消费者真正关心的消息才会离开代理,大大降低了网络流量和客户端处理开销。

RabbitMQ 中 Khepri 作为默认元数据存储的路线图

·3 分钟阅读

Khepri,RabbitMQ 新的基于 Raft 的 元数据存储,在 RabbitMQ 4.0 中已获得完全支持。从下一个发布系列 RabbitMQ 4.2 开始,我们认为 Khepri 已足够成熟,可以成为默认的元数据存储,尤其考虑到其在数据安全性和恢复性方面相比 Mnesia 有了显著的改进。

我们进行了一系列基准测试,显示在许多元数据操作中性能得到了显著提升。下文附有对比表格。

Go Stream 客户端 1.5.8 发布,包含关键修复

·阅读 1 分钟

RabbitMQ Go Stream 客户端 1.5.8 是一个新 bug 修复版本,包含一项 关键修复

此修复回滚了 PR 393,该 PR 引入了一个危险的 bug,导致在通道达到最大容量时库会跳过数据块的传递。实际上,消息将停止分发给应用程序。

该 bug 在消费者长时间处于接近峰值传递压力时,或者在消费者持续处理传递缓慢时触发。

受影响的版本

该 bug 影响以下版本:1.5.51.5.61.5.7

我们强烈建议尽快将客户端更新到 1.5.8

© . This site is unofficial and not affiliated with VMware.