导言
Apache RocketMQ 诞生至今，历经十余年大规模事务稳定性打磨，服务了 100% 阿里集团内部事务以及阿里云数以万计的企业客户。作为金融级牢靠的事务音讯计划，RocketMQ 从创立之初就一向专心于事务集成范畴的异步通讯才能构建。本篇将从事务集成场景的诉求开端，介绍 RocketMQ 作为事务音讯集成计划的中心才能和优势，经过功用场景、运用事例以及最佳实践等角度介绍 RocketMQ 一般音讯类型的运用。
重视【阿里如此原生】大众号，回复关键词【一般音讯】获取完好 PPT 下载地址！
说起事务集成场景，RocketMQ 最初的运用场景便是典型代表。RocketMQ 诞生于阿里的电商体系，电商体系经常需求做各种大促活动，在这类杂乱需求场景下对音讯体系的吞吐功用、端到端推迟、削峰填谷等才能有着极高的要求。
一句话概括今日的中心问题，跑在中心交易事务链路的音讯有什么特色，有什么要求，和跑在离线剖析等场景的音讯有什么不同。下面和咱们一起来讨论～
事务集成 vs数据集成
集成方针不同
做事务中心架构规划时，许多时分需求面向上层需求去完结事务逻辑的规划。以电商交易场景为例，经过微服务的拆分，或许在整个链路中会拆成许多个环节，不同运用之间经过音讯去集成时，更多的是重视用户订单的流转进程，重视这个事务逻辑是否会正常的处理，这个便是事务集成。
比照一下，数据集成是以数据为中心，更多的是重视事务集成产生的数据，去剖析这些事务数据的价值。数据集成并不关怀这个数据是从哪里来，只关怀数据本身的特色和数据之间的关系。
重视重点不同
在事务集成里跟着企业事务逻辑的拓宽和杂乱度的提升，调用和被调用方之间的耦合性会逐渐增加，链路的拓扑也会变得越来越杂乱。经常会出现一条音讯的上游是另一条音讯的下流，一个服务或许既是发送方也是消费方，等等。
而在数据集成的场景里面，并不重视上述链路，更多是重视数据的多样性。也便是说，在做数据集成剖析时，更多的是从各种异构的数据源里去提取、会聚这些数据，然后把这些异构体系的数据聚合在一起做清洗，终究会聚成结构化的数据或报表去做剖析。数据集成更多是重视数据的异构性和多样性。
实时性不同
事务集成简略理解便是一种在线的逻辑，或许是一种强实时的逻辑。在这个事务集成范畴，无论同步调用仍是异步调用，都对调用和被调用之间的呼应协同机制有一定的要求。举个比方，一个订单的处理有必要是要在毫秒级完结，否则用户的体会会十分的差。
但是在数据集成范畴，更多的或许是近实时乃至是离线非实时的场景，也便是说经过批、实时流或近实时流的 场景去爬取数据之后做剖析，具体链路关于用户来说并不是可见的，这也是数据集成和事务集成侧重点的差异。
事务集成对音讯体系的中心诉求
音讯行列是企业事务集成的首要形式之一，它是一种异步通讯形式。异步形式供给了低耦合、高牢靠、可观测的异步通讯才能。那么事务集成链路里运用音讯之后会带来什么效果呢？这儿稍微罗列一下。
上图便是一个比较典型的上层的运用链路，从运用 A 到基层的运用 B 的一个单链路，经过发送初始化或许结构化一个音讯，作为调用事情发送到事情通道，这个通道便是音讯体系，比方 RocketMQ、RabbitMQ 等。在时刻通道里存储后经过过滤路由的分发组件匹配到下流，然后推送处理。与此一起，还会有可观测、运维、监控的一些体系去支撑这个链路的牢靠运转。
完好的功用需求十分多，这儿提炼事务集成对音讯体系的四个中心诉求：
1）多类型音讯传输：支撑多样事务场景集成诉求，首要包含一般音讯、守时音讯、事务音讯、顺序音讯等；
2）丰厚路由分发才能：支撑多种分发路由条件，包含 Tag 过滤、音讯特色过滤，一对多、1对1分发等；
3）多样交互形式：支撑收发音讯多样交互方法，支撑同步、异步发送，支撑自动消费、被动推送消费，支撑流式应对、单条应对；
4）可观测体系：支撑 Metrics、Trace、Events 剖析，支撑单链路、全链路轨迹追寻，支撑 Metrics 剖析和监控告警，支撑体系运转事情、事务事情透出处理。
RocketMQ 作为十分典型的事务音讯计划，正是对应上述事务集成的诉求，供给了完善的音讯功用、丰厚的客户端接口以及完善的可观测体系和稳定性保障机制。
接下来就开端逐渐拆解 RocketMQ 的多类型音讯，本篇首要介绍一般音讯。
一般音讯原理介绍
功用简介
在多种音讯类型中，一般音讯是最简略也最为重要。一般音讯是 RocketMQ 的根本音讯类型，供给高吞吐、扩展、低推迟、异步的通讯才能。其他高级音讯类型根本都是在这种一般音讯类型的基础上叠加了独有的控制特性，或许是特定的运用的方法。
下面这张图便是一般音讯的一个典型的拓扑，和音讯行列典型场景一样，生产者发送音讯，发送一般音讯到服务端去存储，存储完之后，会把音讯依照订阅关系的匹配，最后推送给下流的消费方去做消费。
一般音讯的特色
1）原子性：音讯之间没有关联关系，收发处理逻辑原子；
2）扩展性：一般音讯容量、才能可扩展，支撑多行列存储、水平拆分、并发消费；
3）低推迟：一般音讯链路短，交互简略，状况简略，链路极简，毫秒级低推迟通讯。
音讯的生命周期
一般音讯从初始化发送开端到终究被处理的进程中会经历多个状况和进程，而了解音讯的生命周期，能够协助咱们去判断线上出现问题后如何快速定位和处理。
简略来说音讯的生命周期能够抽象成五个状况：
-
初始化：一般音讯被生产者构建初始化完结，待发送到服务端的状况；
-
待消费：音讯被传输到服务端，对下流可见，等待顾客获取处理的状况；
-
消费中：音讯被顾客获取，并依照事务逻辑处理进程，此时服务端会等待消费完结，假如一守时刻后没有收到消费提交的事情，音讯还会重试处理；
-
消费提交：顾客完结音讯处理，并提交应对事情到服务端，服务端符号当前音讯已经被处理（包含消费成功和失利）。RocketMQ默许支撑一切音讯保留，此时音讯数据并不会当即被删去，只是逻辑符号完结，在音讯被物理删去之前，顾客依然能够回溯重新处理音讯；
-
音讯删去：RocketMQ 依照音讯保存时刻机制滚动整理最早的音讯数据，将音讯从物理文件中删去。
一般音讯运用场景和事例
简略的了解原理和根本介绍之后，那一般音讯首要用在哪里呢？一般音讯是RocketMQ运用最广泛，运用规模最大的一种音讯类型，它首要集中在服务间的解耦调用，一起还有一些批量数据的收集传输等场景。
运用场景
1）微服务调用解耦
- 异步化解耦：一般音讯完结微服务异步调用，缩短事务流和呼应时刻。
- 流量削峰填谷：一般音讯海量堆积才能，处理流量峰值下流处理才能缺乏的稳定性危险。
2）实时数据传输
- 高吞吐传输：一般音讯能够完结无限水平扩展，数据传输吞吐高，处理收集上报问题。
- 实时传输：一般音讯实时传输投递，下流能够及时消费完结核算和剖析。
事例介绍
1）场景简介
交易平台是买卖家在线上依据约定的契约完结钱货交换的进程涉及的体系。交易平台涉及到和付出、物流、下单、运营等多个子体系的交互大多运用 RocketMQ 一般音讯做异步解耦，音讯的牢靠处理是电商大促保障的中心。
2）中心痛点
订单状况机杂乱，需求缩短链路时刻：订单生命周期长，涉及下流多个子体系流转，同步调用耗时长，用户体会差。
大促场景海量订单处理，下流压力大：大促场景订单流量大，各子体系处理才能缺乏导致体系溃散。
分布式场景订单改变持久化和下流调用事务性：订单状况流转需求保证数据库状况变更和下流调用一起成功或许失利，即事务性。
快速上手收发音讯
说了这么多场景和事例，直接看一下代码怎样用。
发送一般音讯
发送音讯的流程十分简略，但这其间需求留意以下几点：
- 音讯初始化应尽或许完好：一般音讯初始化包含主题、Tag 标签、索引 Key 和负载。能够按实际情况设置完结。
- 音讯发送需求捕获成果和反常：音讯发送完结需求获取呼应成果，假如失利需求捕获反常并做重试处理。
消费一般音讯
RocketMQ 支撑的消费方法有多种，有自动获取的方法，也有被动消费监听器推送的方法。
被动消费方法只需求注册消费监听器，然后监听器内部去处理这个逻辑，终究回来消费成果。假如消费失利，期望 RocketMQ 再做重投，就要回来一个失利的成果；抛反常也是回来失利。类似于这样的成果，回来服务端就完结了整个消费的进程。
关于自动获取的方法，会更加灵活，由事务方自动调用获取音讯，能够依照自己的速率和并发取音讯，处理完结后，再回复 RocketMQ 服务端消费成果。
产品预告：新一代 RocketMQ 5.0版实例
最后预告一下，阿里云音讯行列 RocketMQ 版在八月份发布新版本，新版本具有更强弹性、更低本钱、更易运维等特色，欢迎坚持重视。
点击此处，进入官网了解更多详情～
