一、前言[https://mp.weixin.qq.com/s?__biz=MzUzMTA2NTU2Ng==&mid=2247487551&id...
一、背景 作为Apache 顶级项目(TLP),Apache RocketMQ 是国内首个非 Hadoop 生态体系的顶级项目,开源至今被全球广...
在分布式消息队列中,目前唯一提供完整的事务消息的,只有 RocketMQ 。关于这一点,还是可以鼓吹下的。 可能会有胖友怒喷艿艿,RabbitM...
RocketMQ 提供了两种方式给 Consumer 进行消息的过滤: 基于 Tag 过滤标签(Tag):为消息设置的标志,用于同一主题下区分不...
RocketMQ 提供了两种顺序级别: 普通顺序消息:Producer 将相关联的消息发送到相同的消息队列。 完全严格顺序:在【普通顺序消息】的...
在上述的示例中,我们看到的都是使用集群消费,也是最常用的消费模式。而在一些场景下,我们需要使用广播消费。 广播消费模式下,相同 Consumer...
在 Spring Cloud Stream 中,提供了通用的消费异常处理机制,可以拦截到消费者消费消息时发生的异常,进行自定义的处理逻辑。 4....
RocketMQ 提供消费重试的机制。在消息消费失败的时候,RocketMQ 会通过消费重试机制,重新投递该消息给 Consumer ,让 Co...
一、 概述 本文我们来学习 Spring Cloud Alibaba 提供的 Spring Cloud Stream RocketMQ 组件,基...
文集作者