使用 RabbitMQ Streams 进行偏移量跟踪
RabbitMQ Streams 为消费者提供服务器端偏移量跟踪。此功能允许消耗应用程序在上次中断的地方恢复消耗。本文介绍偏移量跟踪的语义以及它在 Streams Java 客户端中的实现方式。
RabbitMQ Streams 为消费者提供服务器端偏移量跟踪。此功能允许消耗应用程序在上次中断的地方恢复消耗。本文介绍偏移量跟踪的语义以及它在 Streams Java 客户端中的实现方式。
《RabbitMQ Streams 概览》介绍了 RabbitMQ 3.9 的新功能 Streams,而《RabbitMQ Streams 第一个应用》则概述了 Streams Java 客户端的编程模型。本文将介绍如何在 RabbitMQ Streams 中去重已发布的消息。
由于去重是一个关键且复杂的问题,本文将一步步引导您了解这一机制,从一个简单且存在问题的发布应用程序,到一个优化且可靠的实现。
RabbitMQ Streams 概述 介绍了 Streams,这是 RabbitMQ 3.9 中的一项新功能。本文介绍客户端应用程序应如何连接到 RabbitMQ 节点,以在 Streams 协议 使用时,从 Streams 中获得最大的好处。
Streams 针对高吞吐量场景进行了优化,因此数据局部性等技术细节对于充分发挥 RabbitMQ 集群的性能至关重要。客户端库可以处理大部分细节,但当设置涉及容器和负载均衡器等额外层时,对底层工作原理的基本理解至关重要。如果您想了解有关 Streams 的更多信息,并避免在部署第一个 Streams 应用程序时遇到一些麻烦,请继续阅读!
RabbitMQ Streams 概述 介绍了 Streams,这是 RabbitMQ 3.9 中的一项新功能。本文将继续介绍如何使用 Java 客户端处理 Streams。我们将编写我们的第一个应用程序,该应用程序将消息发布到流,然后进行消耗。
RabbitMQ 3.9 引入了一种新的数据结构:streams。Streams 能够解锁一系列使用“传统”队列实现起来可能很繁琐的用例。在这篇文章中,让我们一起探索 Streams 如何扩展 RabbitMQ 的功能。