RocketMQ 之消息消费手动提交 ACK 实战【案例分享】
上一篇我们分享了 RocketMQ 消息重试的一些基本原理，本篇我们基于 Spring Boot 整合 RocketMQ 来分享一下 RocketMQ 消息基于手动提交的案例，在分享手动进行消息 ACK 中也会分享消息重试的使用。
面试题：消息积压怎么解决？RocketMQ与Kafka有哪些区别？Kafka性能优于RocketMQ的原因？
RocketMQ和Kafka在数据可靠性、消费失败重试、分布式事务消息、Broker端消息过滤、消息顺序性以及适用场景等方面也存在显著差异。消息积压是消息中间件中常见的问题，尤其是在高并发、大数据量的场景下。RocketMQ通过一系列机制来应对消息积压问题
Docker 部署 RocketMQ (图文并茂超详细)
使用 Docker 部署 RocketMQ 是一种高效便捷的方式，适合快速启动和管理分布式消息队列服务。首先，从 Docker Hub 拉取 RocketMQ 的官方镜像。RocketMQ 主要包括 NameServer 和 Broker 两个核心组件，因此需要分别启动对应的容器。通过命令行启动 N
消息队列详细介绍、工作原理，kafka与RocketMQ的比对
首先，我们可以给消费队列两端加入更多的消费者和生产者，提高请求产生和处理效率。其次，我们给消息队列进行分片，先将消息分类成不同的topic，每个topic被分配到对应的position，当单机存有多个position的时候，容易占用cpu和内存较高的情况，影响性能，这时候分给不同的机器，这每个机器对
消息中间件---初识（Kafka、RocketMQ、RabbitMQ、ActiveMQ、Redis）
消息中间件是一种支撑性软件系统，它在网络环境中为应用系统提供同步或异步、可靠的消息传输。消息中间件利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。它支持多种通信协议和数据格式，可以在不同的应用系统之间进行透明的消息传递。消息中间件的主要特点包括异步通信、持久
Kafka、RocketMQ 、RabbitMQ 是什么？
说白了，它其实是个链表，链表的每个节点就是一个消息。每个节点有一个序号，我们叫它Offset，记录消息的位置。服务依据自己的处理能力，消费链表里的消息。能处理多少是多少，不断更新已处理 Offset 的值。但这有个问题，来不及处理的消息会堆积在内存里，如果服务更新重启，这些消息就都丢了。这个好解决，
RocketMQTemplate 解析：简化与 RocketMQ 消息系统的交互
Apache RocketMQ 是一个分布式消息队列系统，支持高吞吐量和低延迟的消息处理。它主要用于异步通信、事件驱动架构、数据流处理、日志收集等场景。其核心概念包括生产者、消费者、消息队列和主题等。在分布式系统中，消息队列系统的重要性不言而喻。它们能够解耦应用、提高系统的弹性与容错能力。高性能：每
Spring Boot 结合 ES搜索引擎 实现数据库与 ES 索引同步
RocketMQ 是阿里巴巴开源的一款高性能、高可靠的分布式消息中间件，广泛应用于大规模分布式系统中。它支持多种消息模型，包括点对点、发布/订阅等，非常适合用于数据同步场景。通过使用 RocketMQ 实现 Elasticsearch 与数据库数据的实时同步，我们可以确保数据的一致性和实时性。本文详
重学SpringBoot3-集成RocketMQ（一）
Spring Boot 3 与 RocketMQ 整合，可以通过 Spring Messaging 结合 RocketMQ 的 `rocketmq-spring-boot-starter` 实现。在这个整合过程中，RocketMQ 作为消息队列系统，Spring Boot 负责提供应用框架，整合可以
MQ四兄弟：如何保证消息顺序性
尽管RabbitMQ、RocketMQ、Kafka和Pulsar这些消息队列系统虽然在实现细节上有所不同,但它们保证消息顺序性的核心思想都是相似的,即确保具有相同特征的消息被发送到同一队列或分区中,由于队列数据结构本身就是先进先出的结构,因此只需要消费者从该队列按顺序消费,就能够保证消息的有序性。
消息中间件 --Kafka
Kafka 是一个分布式流媒体平台,类似于消息队列或企业消息传递系统。生产者发送消息，多个消费者只能有一个消费者接收到消息生产者发送消息，多个消费者都可以接收到消息producer：发布消息的对象称之为主题生产者（Kafka topic producer）topic：Kafka将消息分门别类，每一类
Linux 下 RocketMQ 安装、配置与运维（详细讲解）
Linux 下 RocketMQ 安装、配置与运维 如果是内网IP外网是无法访问的，需要配置外网IP,云服务器如果使用默认配置一般是内网IP。broket 启动时默认启动脚本内存参数是使用8G内存。要更改 RocketMQ 的本地部署中的端口，您需要修改 RocketMQ 的配置文件。从上图中可以看
RocketMQ&Kafka重试队列
重试的主要流程：1、consumer消费失败，将消息发送回broker；2、broker收到重试消息之后，先存储到定时队列里；3、根据重试次数，经过一定延迟时间后，重新投递到retryTopic;4、consumer会拉取consumerGroup对应的retryTopic的消息；5、consume
RabbitMQ 和 RocketMQ 的区别
RabbitMQ 和 RocketMQ 都是流行的开源消息中间件，它们用于在分布式系统中异步传输消息。选择哪一个取决于具体的业务需求、性能要求、开发团队的熟悉度以及生态系统的支持。每种消息队列系统都有其优势和局限性，理解这些差异有助于做出更合适的技术选型。
RocketMQ 实战：在 macOS 上安装与前端访问全流程指南
通过本文的指导，您已经在 macOS 上成功安装并配置了 RocketMQ，并通过 RocketMQ 控制台实现了对 RocketMQ 集群的前端访问和管理。通过这种方式，您可以高效地管理消息队列的各种配置与状态，确保系统的高性能和稳定性。进一步的操作可以包括配置更多的 Broker 节点、优化消息
从零到一：Spring Boot 与 RocketMQ 的完美集成指南
从零到一：Spring Boot 与 RocketMQ 的完美集成指南
RocketMQ与RabbitMQ的区别：技术选型指南
在现代分布式系统和微服务架构中，消息队列（Message Queue，简称MQ）扮演着至关重要的角色。消息队列用于实现系统间的异步通信、解耦、削峰填谷等功能。目前常见的MQ实现包括ActiveMQ、RabbitMQ、RocketMQ和Kafka。本文将重点对比RocketMQ和RabbitMQ，帮助
RabbitMQ、Kafka对比（超详细），Kafka、RabbitMQ、RocketMQ的区别
RabbitMQ、Kafka对比（超详细），Kafka、RabbitMQ、RocketMQ的区别，设计目标、适用场景、吞吐量、消息存储和持久化、可靠性、集群负载均衡
Rocketmq-5.3.0和对应dashboard的最新版本Docker镜像，本人亲自制作，部署十分方便，奉献给大家
是否允许Broker自动创建Topic，建议线下开启，线上关闭autoCreateTopicEnable = false # 是否允许Broker自动创建订阅组，建议线下开启，线上关闭autoCreateSubscriptionGroup = false # 在发送消息时，自动创建服务器不存在的to
RocketMQ的详细讲解（四种mq的对比（activeMq、rabbitmq、rocketmq、kafka））
RocketMQ的详细讲解（四种mq的对比（activeMq、rabbitmq、rocketmq、kafka））
