SpringBoot整合RocketMQ入门示例
环境:springboot2.3.9 + RocketMQ4.8.
MQ消息堆积百万条:消费者明明活着,消费位点就是不动
#头条我来了#凌晨一点告警群炸了:订单积分堆积120万条。打开控制台一看,消费者在线、rebalance正常、没有死信,一路绿灯,就是TPS明晃晃的零。这比消费者宕机难办多了——宕机是明牌,会报警、会重连、会触发重平衡;"假活着"是什么都正常,就是活不干。
实践出真知:topic数量对RocketMQ真的没有影响吗?
网上博客常说,kafka的topic数量过多会影响kafka,而rocketMQ不会受到topic数量影响。
面试必背:RocketMQ精选面试题
不会,每条消息都会持久化到CommitLog中,每个Consumer连接到Broker后会维持消费进度信息,当有消息消费后只是当前Consumer的消费进度更新了。
百炼网关实践:用 RocketMQ LiteTopic 让限流比降了 10 倍
作者:不铭、文婷、稚柳百炼是阿里云的大模型服务平台,承载百万级用户同时调用千问等数十种大模型。
百万用户 一人一 Topic 百炼资产中心用 RocketMQ LiteTopic 实现隔离与
海量用户,每人一条消息流,随时可能爆发的单用户流量风暴——这是百炼资产中心面对的消息链路。用户在百炼生成的图片、视频默认临时保存,要沉淀为长期资产,每条消息都要可靠处理。百炼资产中心的答案是 RocketMQ LiteTopic(轻量主题):一个用户一个 Topic。
RocketMQ源码分析,自动创建Topic机制
下载了 RocketMQ 源码,在本地 IDE 中正常启动了 Broker 服务 和 NameServer 服务。想到 Broker 有自动创建 Topic 的机制,可以通过在 Broker 的配置文件中添加如下配置:问题在于即使配置了这个参数,重启 Broker 服务之后,发送消息时还是如上的报错,因此打算仔细看看 RocketMQ 自动创建 Topic 的实现原理。
深度解读 RocketMQ 存储机制
RocketMQ 实现了灵活的多分区和多副本机制,有效的避免了集群内单点故障对于整体服务可用性的影响。
非常强悍的 RabbitMQ 总结,写得真好
来源 | Java技术栈 RabbitMQ是一套开源(MPL)的消息队列服务软件,是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 写成。
闯大祸了!记一次MQ消息乱序造成的重大业务事故
一、问题&分析1、案例深夜,小艾接到了一通突如其来的电话,是物流系统的负责人曹工焦急的声音。他火急火燎地反馈了一个严重的问题——大批用户投诉物流信息异常,订单状态与实际情况不符,用户已完成支付,但物流单还是待支付状态。