在本章中，我们将分析 RocketMQ 是如何 创建订阅组的。看看 RocketMQ 是如何实现的。

如何开启&关闭

在部署 RocketMQ 的 Broker 的时候，我们通常都会把

网上博客常说，kafka的topic数量过多会影响kafka，而RocketMQ不会受到topic数量影响。

消息存储

Broker收到消息后会调用

在怀疑是系统（服务器）问题前，先多考虑是否是程序本身的问题

大过年在家里，正玩王者，突然收到带的新人徒弟发来的微信消息，说线上mq数据统计错乱了，有的多，有的少，说可能RocketMq集群有问题。影响到了用户报表，十分紧急，无奈之下，只能坑队友一把（挂机），连上easyConnect，帮徒弟定位问题。

一、NameServer简介

消息中间件的设计思路一般是基于主题订阅发布的机制，消息生产者(Producer)发送某一个主题到消息服务器，消息服务器负责将消息持久化存储，消息消费者(Consumer)订阅该兴趣的主题，消息服务器根据订阅信息(路由信息)将消息推送到消费者(Push模式)或者消费者主动向消息服务器拉去(Pull模式)，从而实现消息生产者与消息消费者解耦。 为了避免消息服务器的单点故障导致的整个系统瘫痪，通常会部署多台消息服务器共同承担消息的存储。那消息生产者如何知道消息要发送到哪台消息服务器呢？如果某一台消息服务器宕机了，那么消息生产者如何在不重启服务情况下感知呢？NameServer就是为了解决以上问题设计的，下面这张图片展示了 NameServer和Broker和Producer(生产者)和Consumer(消费者)之间关系。

RocketMQ 发送普通消息有三种实现方式：可靠同步发送

一 背景

订单状态流转是交易系统的最为核心的工作，订单系统往往都会存在状态多、链路长、逻辑复杂的特点，还存在多场景、多类型、多业务维度等业务特性。在保证订单状态流转稳定性的前提下、可扩展性和可维护性是我们需要重点关注和解决的问题。

目录

1. RocketMQ介绍
2. RocketMQ概念
3. 为什么要用RocketMQ？异步解耦削峰填谷分布式事务最终一致性数据分发
4. RocketMQ架构
5. RocketMQ消息类型普通消息顺序消息定时消息事务消息
6. 最佳实践消息重试消息过滤消费模式消费幂等
7. 本地事务消息封装
8. 参考代码

RocketMQ 介绍

Apache RocketMQ 是一款 低延迟、高并发、高可用、高可靠的分布式消息中间件。消息队列 RocketMQ 可为分布式应用系统提供异步解耦和削峰填谷的能力，同时也具备互联网应用所需的海量消息堆积、高吞吐、可靠重试等特性。

1.前言

Coze Studio 开源版是字节跳动推出的Coze平台的一个开源版本，旨在为开发者和用户提供一个低代码、无代码的AI应用开发平台。Coze Studio 开源版的核心目标是简化AI机器人的开发流程，使用户能够快速构建基于AI模型的问答Bot、智能体、AI应用和插件，并将其部署到各种社交平台和即时通讯应用中。

背景

用