RocketMQ为什么同一个消费组设置不同tag 消费一半的问题_rocketmq 读写队列消费一半...
2023-10-14 01:24 阅读 阅读全文文章浏览阅读120次。转载自:https://www.toutiao.com/a6835827132212445709/?log_from=90178c0a332fb_1633014549693简述消息中间件作为分布式系统的重要成员,各大公司及开源均有许多解决方案。目前主流的开源解决方案包括RabbitMQ、RocketMQ、Kafka、Ac......
2024-01-23 02:14 阅读 阅读全文从整体技术架构上学习 RocketMQ 5.0 的云原生架构、一体化架构,最后再分别从业务场景切入,详细介绍 RocketMQ 5.0 在不同的业务场景提供的能力和关键技术原理,包括业务消息、流处理、物联网以及面向云时代的事件驱动场景。...
2024-05-05 17:06 阅读 阅读全文文章浏览阅读360次。首先,在 RocketMQ 集群中创建一个 Topic,叫做 MyTestTopic,配置如下图:这里解释一下图中的几个参数:writeQueueNums:客户端在发送消息时,可以向多少个队列进行发送;readQueueNums:客户端在消费消息时,可以......
2024-01-23 23:04 阅读 阅读全文文章浏览阅读7.8k次,点赞9次,收藏49次。前言在使用消息队列时不可避免的会遇到顺序消费、重复消费、消息丢失三个问题。在一次面试字节的时候,面试官问到如何保证顺序消费,当时回答不太准确,特意此文回顾如何解决......
2023-11-11 14:02 阅读 阅读全文文章浏览阅读2.5k次。对于需要重试消费的消息,并不是Consumer在等待了指定时长后再次去拉取原来的消息进行消费,而是将这些需要重试消费的消息放入到了一个特殊Topic的队列中,而后进行再次消费的。对于顺序消息,当Consume......
2024-01-23 23:06 阅读 阅读全文文章浏览阅读607次。title: “自定义脚本启动搭建的RocketMQ伪集群”date: 2022-04-02T10:47:11+08:00draft: true引言工欲善其事,必先利其器。因为只有一台电脑,只能搭建伪集群来学习了,但是,本身又是个偷懒的人,启动伪集群 RocketMQ ......
2024-01-24 21:28 阅读 阅读全文文章浏览阅读3.7k次,点赞2次,收藏5次。RocketMQ中两个重要的组成部分就是NameServer和BrokerNameServer:相当于是Broker的注册中心,能够管理Broker节点,为生产者和消费者提供路由信息。Broker:则是背后真正的消息服务器。Broker在启......
2024-01-24 21:28 阅读 阅读全文文章浏览阅读1.5w次,点赞10次,收藏100次。MQ消息堆积是指生产者发送的消息短时间内在Broker端大量堆积,无法被消费者及时消费,从而导致业务功能无法正常使用。 消息堆积常见于以下几种情况:(1)新上线的消费者功能......
2024-06-26 03:26 阅读 阅读全文