一、为什么使用 MQ? 1.1 解耦 1.1.1 解耦 例如电商系统核心是交易服务,交易服务要调用另外三个服务,订...[作者空间]
RocketMQ 优异的性能表现,必然绕不开其优秀的存储模型 。 这篇文章,笔者按照自己的理解 , 尝试分析 Ro...[作者空间]
期望消失时,恐惧就产生。——格拉西安 大纲 案例介绍 1.业务分析 模拟电商网站购物场景中的【下单】和【支付】业务...[作者空间]
1 RocketMQ基本理论 1.1 发展历史 阿里巴巴消息中间件起源于2001年的五彩石项目,Notify在这期...[作者空间]
1、生产者 RocketMQ支持三种发送方式: 同步发送:适用于可靠性要求比较高的场景,如支付消息、短信通知等 异...[作者空间]
一、 概述 本文我们来学习 Spring Cloud Alibaba 提供的 Spring Cloud Strea...[作者空间]
在分布式消息队列中,目前唯一提供完整的事务消息的,只有 RocketMQ 。关于这一点,还是可以鼓吹下的。 可能会...[作者空间]
RocketMQ 提供了两种顺序级别: 普通顺序消息 :Producer 将相关联的消息发送到相同的消息队列。 完...[作者空间]
在上述的示例中,我们看到的都是使用集群消费。而在一些场景下,我们需要使用广播消费。 广播消费模式下,相同 Cons...[作者空间]
RocketMQ 提供消费重试的机制。在消息消费失败的时候,RocketMQ 会通过消费重试机制,重新投递该消息给...[作者空间]
在 RocketMQ 中,提供定时消息的功能。 定时消息,是指消息发到 Broker 后,不能立刻被 Consum...[作者空间]
在一些业务场景下,我们希望使用 Producer 批量发送消息,提高发送性能。在 RocketMQTemplate...[作者空间]
一、概述 RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与...[作者空间]
1、消息整体处理过程 这里我们将消息的整体处理阶段分为3个阶段进行分析: Producer发送消息阶段。 Brok...[作者空间]
一、集群搭建可选方式 RocketMQ的物理部署结构图如下: Producer和Consumer对应的是我们的应用...[作者空间]
系列 RocketMQ consumer 启动流程 RocketMQ consumer Rebalance过程 R...[作者空间]
延迟队列可以实现消息在投递到Exchange之后,经过一定的时间之后再投递到相应的Queue。再被消费者监听消费。...[作者空间]
本文参考石杉的架构笔记公众号, 总结了一下RabbitMQ的核心知识, 非常感谢 一、消息中间件选型 1. Act...[作者空间]
0. 前言 RocketMQ的消息投递分分为两种:一种是生产者往MQ Broker中投递;另外一种则是MQ bro...[作者空间]
前言 最近由于RocketMQ在使用过程中,发现在某些时候消息堆积,并且还是长时间堆积不消费,这种情况下没能及时发...[作者空间]