- 今天介绍下如何在 Spring Boot 3 中与 RocketMQ 整合实现分布式事务。RocketMQ 提供了类似 X/Open XA 的分布式事务功能，通过事务消息能达到分布式事务的最终一致。XA 是一种分布式事务解决方案，一种分布式事务处理模式。下面详细介绍下 RocketMQ 如何实现事务消息。 今天介绍下如何在 Spring Boot 3 中与 RocketMQ 整合实现分布式事务。RocketMQ 提供了类似 X/Open XA 的分布式事务功能，通过事务消息能达到分布式事务的最终一致。XA 是一种分布式事务解决方案，一种分布式事务处理模式。下面详细介绍下 RocketMQ 如何实现事务消息。
- Spring Boot 3 与 RocketMQ 整合，可以通过 Spring Messaging 结合 RocketMQ 的 rocketmq-spring-boot-starter 实现。在这个整合过程中，RocketMQ 作为消息队列系统，Spring Boot 负责提供应用框架，整合可以让开发者更加便捷地使用 RocketMQ 的生产和消费功能。今天就先介绍下SpringBoot3整合 Spring Boot 3 与 RocketMQ 整合，可以通过 Spring Messaging 结合 RocketMQ 的 rocketmq-spring-boot-starter 实现。在这个整合过程中，RocketMQ 作为消息队列系统，Spring Boot 负责提供应用框架，整合可以让开发者更加便捷地使用 RocketMQ 的生产和消费功能。今天就先介绍下SpringBoot3整合
- RocketMQ（二）：揭秘发送消息核心原理（源码与设计思想解析）上篇文章主要介绍消息中间件并以RocketMQ架构展开描述其核心组件以及MQ运行流程本篇文章以Product的视角来看看发送消息的核心原理与设计思想，最后以图文并茂的方式描述出发送消息的核心流程 消息发送方式RocketMQ中普通消息提供三种发送方式：同步、异步、单向上篇文章中我们已经使用封装好的API延时过同步发送在使用三... RocketMQ（二）：揭秘发送消息核心原理（源码与设计思想解析）上篇文章主要介绍消息中间件并以RocketMQ架构展开描述其核心组件以及MQ运行流程本篇文章以Product的视角来看看发送消息的核心原理与设计思想，最后以图文并茂的方式描述出发送消息的核心流程 消息发送方式RocketMQ中普通消息提供三种发送方式：同步、异步、单向上篇文章中我们已经使用封装好的API延时过同步发送在使用三...
- 事务消息是 RocketMQ 的高级特性之一 。这篇文章，笔者会从应用场景、功能原理、实战例子三个模块慢慢为你揭开事务消息的神秘面纱。 1 应用场景举一个电商场景的例子：用户购物车结算时，系统会创建支付订单。用户支付成功后支付订单的状态会由未支付修改为支付成功，然后系统给用户增加积分。通常我们会使用普通消费方案，该方案能够发挥 MQ 的优势：异步和解耦 , 同时架构设计非常简单。用户购物车... 事务消息是 RocketMQ 的高级特性之一 。这篇文章，笔者会从应用场景、功能原理、实战例子三个模块慢慢为你揭开事务消息的神秘面纱。 1 应用场景举一个电商场景的例子：用户购物车结算时，系统会创建支付订单。用户支付成功后支付订单的状态会由未支付修改为支付成功，然后系统给用户增加积分。通常我们会使用普通消费方案，该方案能够发挥 MQ 的优势：异步和解耦 , 同时架构设计非常简单。用户购物车...
- RocketMQ（七）：消费者如何保证顺序消费？之前的文章已经描述过消费消息有并发、顺序两种方式，其中并发消费常用于无序消息中，而顺序消息用于有序消息顺序消费是确保消息严格有序的前提，当需要确保消息有序时需要采用顺序消费，否则会可能打破消息的有序性顺序消费较为复杂，会涉及到多种锁来保证顺序消费本篇文章就来描述顺序消费的原理，来看看RocketMQ是如何保证顺序消费的，导图如下：往期好文：R... RocketMQ（七）：消费者如何保证顺序消费？之前的文章已经描述过消费消息有并发、顺序两种方式，其中并发消费常用于无序消息中，而顺序消息用于有序消息顺序消费是确保消息严格有序的前提，当需要确保消息有序时需要采用顺序消费，否则会可能打破消息的有序性顺序消费较为复杂，会涉及到多种锁来保证顺序消费本篇文章就来描述顺序消费的原理，来看看RocketMQ是如何保证顺序消费的，导图如下：往期好文：R...
- 图文并茂、深入浅出解析RocketMQ Consumer Rebalance机制 图文并茂、深入浅出解析RocketMQ Consumer Rebalance机制
- 图文并茂、深入浅出揭秘RocketMQ高吞吐量并发消费原理 图文并茂、深入浅出揭秘RocketMQ高吞吐量并发消费原理
- RocketMQ（四）：消费前如何拉取消息？（长轮询机制）上篇文章从Broker接收消息开始，到消息持久化到各种文件结束，分析完消息在Broker持久化的流程与原理消费者消费消息前需要先从Broker进行获取消息，然后再进行消费为了流程的完整性，本篇文章就先来分析下消费者是如何获取消息的，文章内容导图如下： 获取消息的方式消费者并不是每次要消费一条数据就向Broker获取一条数据的，这样R... RocketMQ（四）：消费前如何拉取消息？（长轮询机制）上篇文章从Broker接收消息开始，到消息持久化到各种文件结束，分析完消息在Broker持久化的流程与原理消费者消费消息前需要先从Broker进行获取消息，然后再进行消费为了流程的完整性，本篇文章就先来分析下消费者是如何获取消息的，文章内容导图如下： 获取消息的方式消费者并不是每次要消费一条数据就向Broker获取一条数据的，这样R...
- RocketMQ（三）：面对高并发请求，如何高效持久化消息？上篇文章我们分析完RocketMQ发送消息的原理，得到结果客户端会通过RPC组件向Broker进行通信Broker收到请求后需要将消息进行持久化，一旦涉及到持久化，服务器的性能会急速降低，并且消费者进行消费时还需要读取消息，从磁盘的读取也是会大大降低性能的本篇文章就要来分析，RocketMQ的Broker在这种频繁读写的场景，是如... RocketMQ（三）：面对高并发请求，如何高效持久化消息？上篇文章我们分析完RocketMQ发送消息的原理，得到结果客户端会通过RPC组件向Broker进行通信Broker收到请求后需要将消息进行持久化，一旦涉及到持久化，服务器的性能会急速降低，并且消费者进行消费时还需要读取消息，从磁盘的读取也是会大大降低性能的本篇文章就要来分析，RocketMQ的Broker在这种频繁读写的场景，是如...
- 华为云分布式消息服务DMS是一款消息队列服务，适用于解决分布式架构中的系统解耦、跨系统跨地域数据流通、分布式事务协调等难题。 华为云分布式消息服务DMS是一款消息队列服务，适用于解决分布式架构中的系统解耦、跨系统跨地域数据流通、分布式事务协调等难题。
- RocketMQ（一）：消息中间件缘起，一览整体架构及核心组件消息队列MessageQueue，简称MQ在队列的基础上，加入生产者与消费者模型，使用队列作为载体就能够组成简单的消息队列，在队列中“运输”的数据被称为消息消息队列可以在单节点内存中使用，也可以作为分布式存储的中间件来使用由于项目的架构组织，目前常接触的消息队列往往是作为分布式存储的消息中间件来使用，比如：RabbitMQ、Ro... RocketMQ（一）：消息中间件缘起，一览整体架构及核心组件消息队列MessageQueue，简称MQ在队列的基础上，加入生产者与消费者模型，使用队列作为载体就能够组成简单的消息队列，在队列中“运输”的数据被称为消息消息队列可以在单节点内存中使用，也可以作为分布式存储的中间件来使用由于项目的架构组织，目前常接触的消息队列往往是作为分布式存储的消息中间件来使用，比如：RabbitMQ、Ro...
- 图文并茂、通俗易懂描述rocketmq轻量级拉取消费者原理 图文并茂、通俗易懂描述rocketmq轻量级拉取消费者原理
- 目前华为云官方文档还没有关于rocketmq对接php语言的最佳实践指导，经过调查与自测试，记录对接的过程 目前华为云官方文档还没有关于rocketmq对接php语言的最佳实践指导，经过调查与自测试，记录对接的过程
- 很多同学都在使用 RocketMQ 时，经常会遇到消息堆积的问题。这篇文章，我们聊聊消息堆积的概念，以及如何应对消息堆积。 1 基础概念消费者在消费的过程中，消费的速度跟不上服务端的发送速度，未处理的消息会越来越多，消息出现堆积进而会造成消息消费延迟。虽然笔者经常讲：RocketMQ 、Kafka 具备堆积的能力，但是以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不匹配造成的持... 很多同学都在使用 RocketMQ 时，经常会遇到消息堆积的问题。这篇文章，我们聊聊消息堆积的概念，以及如何应对消息堆积。 1 基础概念消费者在消费的过程中，消费的速度跟不上服务端的发送速度，未处理的消息会越来越多，消息出现堆积进而会造成消息消费延迟。虽然笔者经常讲：RocketMQ 、Kafka 具备堆积的能力，但是以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不匹配造成的持...
- 提到主从复制，我们可能立马会联想到 MySQL 的主从复制。MySQL 主从复制是 MySQL 高可用机制之一，数据可以从数据库服务器主节点复制到一个或多个从节点。这篇文章，我们聊聊 RocketMQ 的主从复制，希望你读完之后，能够理解主从复制的精髓。 1 同步与异步在 RocketMQ 的集群模式中，Broker 分为 Master 与 Slave，一个 Master 可以对应多个 Sl... 提到主从复制，我们可能立马会联想到 MySQL 的主从复制。MySQL 主从复制是 MySQL 高可用机制之一，数据可以从数据库服务器主节点复制到一个或多个从节点。这篇文章，我们聊聊 RocketMQ 的主从复制，希望你读完之后，能够理解主从复制的精髓。 1 同步与异步在 RocketMQ 的集群模式中，Broker 分为 Master 与 Slave，一个 Master 可以对应多个 Sl...
推荐直播
-
OpenHarmony应用开发之网络数据请求与数据解析2025/01/16 周四 19:00-20:30
华为开发者布道师、南京师范大学泰州学院副教授，硕士研究生导师，开放原子教育银牌认证讲师
科技浪潮中，鸿蒙生态强势崛起，OpenHarmony开启智能终端无限可能。当下，其原生应用开发适配潜力巨大，终端设备已广泛融入生活各场景，从家居到办公、穿戴至车载。 现在，机会敲门！我们的直播聚焦OpenHarmony关键的网络数据请求与解析，抛开晦涩理论，用真实案例带你掌握数据访问接口，轻松应对复杂网络请求、精准解析Json与Xml数据。参与直播，为开发鸿蒙App夯实基础，抢占科技新高地，别错过！
回顾中 -
Ascend C高层API设计原理与实现系列2025/01/17 周五 15:30-17:00
Ascend C 技术专家
以LayerNorm算子开发为例，讲解开箱即用的Ascend C高层API
回顾中
热门标签