七、处理消息堆积和消息丢失
📦 Rocket版本 4.9.6 🏢 官方文档: https://rocketmq.apache.org/zh/docs/4.x/ 💻 使用的系统是 ubuntu22.04 🏆 处理消息堆积和消息丢失 ⭐️ 消息堆积 1️⃣ 什么是消息堆积? 当因为某些原因很多消息并没有被消费,还在在 M
📦 Rocket版本 4.9.6 🏢 官方文档: https://rocketmq.apache.org/zh/docs/4.x/ 💻 使用的系统是 ubuntu22.04 🏆 处理消息堆积和消息丢失 ⭐️ 消息堆积 1️⃣ 什么是消息堆积? 当因为某些原因很多消息并没有被消费,还在在 M
设计(design) 1 消息存储 消息存储是RocketMQ中最为复杂和最为重要的一部分,本节将分别从RocketMQ的消息存储整体架构、PageCache与Mmap内存映射以及RocketMQ中两种不同的刷盘方式三方面来分别展开叙述。 1.1 消息存储整体架构 消息存储架构图中主要有下面三个跟消
📦 Rocket版本 4.9.6 🏢 官方文档: https://rocketmq.apache.org/zh/docs/4.x/ 💻 使用的系统是 ubuntu22.04 🏆消息重复消费问题 什么是重复消费? BROADCASTING(广播)模式下,所有注册的消费者都会消费,而这些消费者通
📦 Rocket版本 4.9.6 🏢 官方文档: https://rocketmq.apache.org/zh/docs/4.x/ 💻 使用的系统是 ubuntu22.04 🏆 重复机制和死信消息 ⭐️ 重复机制 1️⃣ 生产者重复 // 失败的情况重发3次 producer.setRetr
📦 Rocket版本 4.9.6 🏢 官方安装文档: https://rocketmq.apache.org/zh/docs/4.x/ 💻 使用的系统是 ubuntu22.04 🏆 RocketMQ快速入门 ⭐️ 生产者的基本概念 在生产者一章的基本概念包括消息,Tag,Keys,队列和生产
📦 Rocket版本 4.9.6 🏢 官方安装文档: https://rocketmq.apache.org/zh/docs/4.x/quickstart/03quickstartWithDockercompose 💻 使用的系统是 ubuntu22.04 🏆 RocketMQ的消息的发送和
📦 Rocket版本 4.9.6 🏢 官方安装文档: https://rocketmq.apache.org/zh/docs/4.x/quickstart/03quickstartWithDockercompose 💻 使用的系统是 ubuntu22.04 🏆 RocketMQ安装之Dock
📦 本次学习的是 RocketMQ4.x版本 🏢 官方文档: https://rocketmq.apache.org/zh/docs/ 🏆 RocketMQ MQ作用 1.可以做到削峰限流的作用,设置一个流程一个缓冲池,如果消息达到了最大值,就将消息放入缓冲池中 2.异步,在程序中同步和异步的
⭐️ Redisinsight 界面安装 🏢 官方地址: https://redis.io/docs/latest/operate/redisinsight/install/ ⭐️ Redis字符串操作 SET/GET 设置/读取数据 redis数据是以键值对形式存储,使用 set可以设置一个键值