作者：斜阳 高可用架构演进背景 在分布式系统中不可避免的会遇到网络故障，机器宕机，磁盘损坏等问题，为了向用户不中断且正确的提供服务，要求系统有一定的冗余与容错能力。RocketMQ 在日志，统计分析，在线交易，金融交易等丰富的生产场景中发挥着至关重要的作用，而不同环境对基础设施的成本与可靠性提出了不同的诉求。在 RocketMQ v4 版本中有两种主流高可用设计，分别是主备模式的无切换架构和基于

这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 假设目前我们的线上部署的RocketMQ部署的是一主一从，现在随着业务的发展，或者是我们需要做一些促销活动，会有突发流量高峰，现有的一主一从无法满足我们的性能，服务器的内存和cpu占用已经高达70-90%左右，所以我们需要对线上的RocketMQ集群进行无损扩容(不影响业务正常使用) 扩容 原有

前言 工作中很多种场景下会用到消息队列，消息队列简单来说就是 消息的传输过程中保存消息的容器。消息队列主要解决了应用耦合、异步处理、流量削峰等问题。今天我们来了解一下阿里开源的一款产品 RocketMQ。 RocketMQ简介 RocketMQ 是一款低延迟、高并发、高可用、高可靠的分布式消息中间件。具备异步通信的优势，系统拓扑简单、上下游耦合较弱，主要应用于异步解耦，流量削峰填谷等场景。 Nam

前言 众所周知，作为一个出色的分布式消息中间件，RocketMQ 在全球范围内获得了广泛的应用，那么作为一个分布式消息中间件，最重要的是什么？ 协议？持久化？消息分发实现？高可用？高可靠？ 好的协议可以保证通讯的稳定，持久化可以保证数据的存储，消息分发实现可以结合多场景加速业务，高可用可以保证业务大量运行，高可靠可以保证业务的持续运行。 今天，我们想谈一谈 RocketMQ 的高可用机制 常见的消

1、消息丢失问题 RabbitMQ解决消息丢失的问题： RabbitMQ通过消息持久化和消息确认机制来确保消息的可靠传递。生产者可以选择将消息标记为持久化，使得即使在消息队列服务器故障后，消息也能被保存并传递给消费者。 RabbitMQ还提供了多种消息确认机制，如发布确认（Publish Confirm）和事务机制（Transaction），生产者可以通过这些机制获取消息是否成功被RabbitMQ

1、应用场景 1.RabbitMQ： 适用于易用性和灵活性要求较高的场景 异步任务处理：RabbitMQ提供可靠的消息传递机制，适用于处理异步任务，例如将耗时的任务放入消息队列中，然后由消费者异步处理，提高系统的响应速度和可伸缩性。 解耦系统组件：通过使用RabbitMQ作为消息中间件，不同的系统组件可以通过消息进行解耦，实现松耦合的架构，提高系统的可维护性和灵活性。 事件驱动架构：RabbitM

这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 最近在使用RocketMQ的重置消费位点的时候经常出现报错，所以就打算研究下RocketMQ是如何重置消费者的消费位点的 RocketMQ版本 5.1.0 Dashboard: 最新github master分支代码 源码分析 dashboard 功能入口 该功能主要是在RocketMQ的das

近日，在 Apache RocketMQ 开发者社区的线下活动上，谐云科技首席架构师魏欢以《RocketMQ Operator In Kubernetes》为主题做了精彩分享，并和大家一起探讨关于 Apache RocketMQ 的未来改进计划。 概要 首先，什么是RocketMQ Operator？ 其次，RocketMQ Operator 有什么用？ 然后，从开发的角度，我们如何设计和实现一个

作者 | 凌楚   阿里巴巴开发工程师 导读：自 19 年底开始，支持 Apache RocketMQ 的 Network Filter 历时 4 个月的 Code Review（Pull Request），于本月正式合入 CNCF Envoy 官方社区（RocketMQ Proxy Filter 官方文档），这使得 RocketMQ 成为继 Dubbo 之后，国内第二个成功进入 Service

作者：老Z，云原生爱好者，目前专注于云原生运维，KubeSphere Ambassador。 Spring Cloud Alibaba 全家桶之 RocketMQ 是一款典型的分布式架构下的消息中间件产品，使用异步通信方式和发布订阅的消息传输模型。 很多基于 Spring Cloud 开发的项目都喜欢采用 RocketMQ 作为消息中间件。 RocketMQ 常用的部署模式如下： 单 Master