带有“新功能”标签的 66 篇文章
查看所有标签至少一次死信
RabbitMQ 3.10 中的仲裁队列 (Quorum queues) 提供了更安全的死信机制,该机制使用至少一次的保证来传输队列之间的消息。这篇博文将解释您开始使用至少一次死信所需了解的一切。
这篇帖子还介绍了 RabbitMQ 3.10 的另外两项功能:仲裁队列的消息生存时间 (TTL) 以及死信消息的 Prometheus 指标。
RabbitMQ Streams 中的互操作性
RabbitMQ Streams 允许应用程序通过其使用的强大消息格式传递详细信息。Streams 本身是一项功能,但它们也与 RabbitMQ 支持的现有资源和协议完全集成。这篇博文涵盖了 RabbitMQ Streams 的互操作性,并探讨了它带来的场景。
使用 RabbitMQ Streams 进行偏移量跟踪
RabbitMQ Streams 为消费者提供服务器端偏移量跟踪。此功能允许消耗应用程序在上次中断的地方恢复消耗。本文介绍偏移量跟踪的语义以及它在 Streams Java 客户端中的实现方式。
RabbitMQ Streams 消息去重
《RabbitMQ Streams 概览》介绍了 RabbitMQ 3.9 的新功能 Streams,而《RabbitMQ Streams 第一个应用》则概述了 Streams Java 客户端的编程模型。本文将介绍如何在 RabbitMQ Streams 中去重已发布的消息。
由于去重是一个关键且复杂的问题,本文将一步步引导您了解这一机制,从一个简单且存在问题的发布应用程序,到一个优化且可靠的实现。
连接到 Streams
RabbitMQ Streams 概述 介绍了 Streams,这是 RabbitMQ 3.9 中的一项新功能。本文介绍客户端应用程序应如何连接到 RabbitMQ 节点,以在 Streams 协议 使用时,从 Streams 中获得最大的好处。
Streams 针对高吞吐量场景进行了优化,因此数据局部性等技术细节对于充分发挥 RabbitMQ 集群的性能至关重要。客户端库可以处理大部分细节,但当设置涉及容器和负载均衡器等额外层时,对底层工作原理的基本理解至关重要。如果您想了解有关 Streams 的更多信息,并避免在部署第一个 Streams 应用程序时遇到一些麻烦,请继续阅读!
第一个使用 RabbitMQ Streams 的应用程序
RabbitMQ Streams 概述 介绍了 Streams,这是 RabbitMQ 3.9 中的一项新功能。本文将继续介绍如何使用 Java 客户端处理 Streams。我们将编写我们的第一个应用程序,该应用程序将消息发布到流,然后进行消耗。
RabbitMQ Streams 概述
RabbitMQ 3.9 引入了一种新的数据结构:streams。Streams 能够解锁一系列使用“传统”队列实现起来可能很繁琐的用例。在这篇文章中,让我们一起探索 Streams 如何扩展 RabbitMQ 的功能。
在 RabbitMQ 出现问题时通知我
如果您希望在 RabbitMQ 部署出现问题时收到通知,现在您可以通过我们提供的 RabbitMQ Cluster Operator 仓库设置 RabbitMQ 监控和告警。我们已将设置 RabbitMQ 监控和告警所需的一系列步骤合并到 一个命令 中,而不是要求您逐步操作。虽然这是一个 Kubernetes 特定的快速入门指南,但您也可以在 Kubernetes 外部使用这些 Prometheus 告警,只是设置将需要您更多的考虑和努力。我们分享的是一种快速简便的方法,对所有人免费开源。
如何监控身份验证尝试
自 3.8.0 版本引入原生 Prometheus 支持以来,我们一直在不断改进 RabbitMQ 内置的监控功能。监控代理及其客户端对于在问题影响其他环境并最终影响最终用户之前检测问题至关重要。
RabbitMQ 3.8.10 通过 Prometheus 端点和 HTTP API 暴露客户端身份验证尝试指标。




