RocketMQ

首页 标签 RocketMQ
# RocketMQ #
关注
6631内容
深入剖析RocketMQ2-实战案例
本文介绍了一个基于电商场景的订单和支付系统实现方案。系统采用SpringBoot+Dubbo+Zookeeper+RocketMQ技术栈,重点解决分布式系统中的数据一致性问题。在订单模块,通过预订单生成、库存扣减、优惠券使用、余额扣减等步骤完成下单流程,并利用RocketMQ实现失败补偿机制。支付模块处理第三方支付回调,通过消息队列异步更新订单状态。系统通过分布式事务保证数据一致性,采用线程池优化消息发送性能,并提供完整的测试方案验证系统功能。本文详细阐述了技术架构、数据库设计、核心业务流程以及异常处理机制
深入剖析RocketMQ1-基础使用
本文介绍了RocketMQ消息队列的核心概念、集群部署及消息发送示例。首先阐述了消息队列的作用包括应用解耦、流量削峰和数据分发,并对比了不同MQ产品的优缺点。重点讲解了RocketMQ的集群架构模式,详细演示了双主双从集群(2m-2s同步双写)的搭建过程,包括环境配置、Broker参数设置和集群启动。最后通过代码示例展示了基本消息发送接收、顺序消息、延迟消息、批量消息、消息过滤和事务消息的实现方式,为开发者提供了RocketMQ的实用指南。
|
9天前
|
RocketMQ 两大核心特性深度拆解:事务消息与延时消息,从原理到实战全打通
RocketMQ作为阿里开源的金融级消息中间件,以高可靠、高吞吐、低延迟著称。其事务消息通过两阶段提交+回查机制,解决本地事务与消息发送的原子性问题;延时消息在5.x中升级为毫秒级任意时间定时消息,基于TimerStore与时间轮实现高性能调度,二者共同支撑分布式系统核心一致性与定时场景。
|
9天前
|
消息队列选型终极指南:Kafka、RocketMQ、RabbitMQ 底层原理与场景化选型全解
本文深度解析消息队列核心原理与三大主流MQ(RabbitMQ、RocketMQ、Kafka)的架构、特性、代码实现及选型策略。涵盖异步解耦、流量削峰、数据分发三大价值,At-most/least/exactly-once投递语义,推拉模式差异,事务消息实现对比,并提供场景化选型指南与生产避坑实践。
|
11天前
|
AI 推理精细化流量治理实战:RocketMQ LiteTopic 的“千人千面”流控方案
AI推理场景下,传统消息队列面临队列头部阻塞与并发效率受损两大挑战。RocketMQ 5.x推出LiteTopic轻量主题模型,支持百万级物理隔离、毫秒级实时限流与分钟级忙闲调度,通过消费挂起等创新机制,实现“千人千面”的精细化流量治理。
|
20天前
| |
来自: 云原生
AI 原生应用开源开发者沙龙·上海站精彩回顾 & PPT 下载
近日,AI 原生应用开源开发者沙龙·上海站圆满落幕。本场活动吸引了 120+ 名技术从业者深度参与,聚焦 AI 原生应用架构领域的开源技术与落地实践, 围绕 AgentScope Java 1.0 发布、HiMarket、Higress、LoongSuite、RocketMQ 等议题展开深度分享,并设置了动手实操环节。
|
26天前
|
吃透 RocketMQ
本文全面介绍Apache RocketMQ分布式消息中间件的核心架构、底层原理和生产实践。首先解析RocketMQ四大核心组件(NameServer、Broker、Producer、Consumer)的职责与协作机制,重点剖析其高性能存储设计(CommitLog、ConsumeQueue、IndexFile)、刷盘策略和主从复制原理。随后详细讲解基于Dledger Raft协议的高可用集群部署方案,包含环境准备、配置优化和监控部署。
【云故事探索】NO.20:古茗奶茶背后的云原生力量
古茗携手阿里云,以云原生架构(微服务+DevOps)和RocketMQ Serverless实现“大促自由”:秒级弹性扩容、事务消息保障一致性、全链路可观测护航稳定。从万店扩张到AI原生探索,技术正成为新茶饮核心竞争力。
|
1月前
| |
来自: 弹性计算
【云故事探索】NO.20:古茗奶茶背后的云原生力量
古茗依托阿里云云原生架构,以微服务+DevOps实现敏捷迭代,通过RocketMQ Serverless应对“周三会员日”十万级TPS洪峰,弹性降本超40%;结合全链路可观测体系保障稳定,并迈向AI原生演进,让技术真正赋能业务创新。
|
1月前
|
百万消息积压 4 小时,我靠这套方案快速止血
本文针对分布式系统中百万级消息积压问题,提出了一套完整的解决方案。首先分析了消息积压的本质是生产速度超过消费速度,并阐述了积压的危害。随后详细介绍了"紧急止血→根源排查→彻底解决→复盘优化"的四步处理流程:通过暂停非核心生产者、扩容消费者、消息分流和跳过无效消息快速缓解积压;从消费端、生产端和队列配置三个维度排查根本原因;从架构、配置和代码层面提出长期优化方案;最后强调建立监控预警体系的重要性。文章提供了大量生产环境验证的代码示例和技术方案,帮助开发者系统性地解决消息积压问题。
免费试用