引言
Apache RocketMQ 诞生至今，历经十余年大规模业务稳定性打磨，服务了 100% 阿里团体外部业务以及阿里云数以万计的企业客户。作为金融级牢靠的业务音讯计划，RocketMQ 从创立之初就始终专一于业务集成畛域的异步通信能力构建。本篇将从业务集成场景的诉求开始，介绍 RocketMQ 作为业务音讯集成计划的外围能力和劣势，通过性能场景、利用案例以及最佳实际等角度介绍 RocketMQ 一般音讯类型的应用。
关注【阿里云云原生】公众号，回复关键词【一般音讯】获取残缺 PPT 下载地址！
说起业务集成场景，RocketMQ 最后的应用场景就是典型代表。RocketMQ 诞生于阿里的电商零碎，电商零碎常常须要做各种大促流动，在这类简单需要场景下对音讯零碎的吞吐性能、端到端提早、削峰填谷等能力有着极高的要求。
一句话概括明天的外围问题，跑在外围交易业务链路的音讯有什么特点，有什么要求，和跑在离线剖析等场景的音讯有什么不同。上面和大家一起来探讨～
业务集成 vs 数据集成
集成指标不同
做业务外围架构设计时，很多时候须要面向下层需要去实现业务逻辑的设计。以电商交易场景为例，通过微服务的拆分，可能在整个链路中会拆成很多个环节，不同利用之间通过音讯去集成时，更多的是关注用户订单的流转过程，关注这个业务逻辑是否会失常的解决，这个就是业务集成。
比照一下，数据集成是以数据为核心，更多的是关注业务集成产生的数据，去剖析这些业务数据的价值。数据集成并不关怀这个数据是从哪里来，只关怀数据自身的属性和数据之间的关系。
关注重点不同
在业务集成里随着企业业务逻辑的拓宽和复杂度的晋升，调用和被调用方之间的耦合性会逐渐减少，链路的拓扑也会变得越来越简单。常常会呈现一条音讯的上游是另一条音讯的上游，一个服务可能既是发送方也是生产方，等等。
而在数据集成的场景外面，并不关注上述链路，更多是关注数据的多样性。也就是说，在做数据集成剖析时，更多的是从各种异构的数据源里去提取、汇聚这些数据，而后把这些异构零碎的数据聚合在一起做荡涤，最终汇聚成结构化的数据或报表去做剖析。数据集成更多是关注数据的异构性和多样性。
实时性不同
业务集成简略了解就是一种在线的逻辑，或者是一种强实时的逻辑。在这个业务集成畛域，无论同步调用还是异步调用，都对调用和被调用之间的响应协同机制有肯定的要求。举个例子，一个订单的解决必须是要在毫秒级实现，否则用户的体验会十分的差。
然而在数据集成畛域，更多的可能是近实时甚至是离线非实时的场景，也就是说通过批、实时流或近实时流的 场景去爬取数据之后做剖析，具体链路对于用户来说并不是可见的，这也是数据集成和业务集成侧重点的差别。
业务集成对音讯零碎的外围诉求
音讯队列是企业业务集成的次要模式之一，它是一种异步通信模式。异步模式提供了低耦合、高牢靠、可观测的异步通信能力。那么业务集成链路里应用音讯之后会带来什么成果呢？这里略微列举一下。
上图就是一个比拟典型的下层的利用链路，从利用 A 到上层的利用 B 的一个单链路，通过发送初始化或者结构化一个音讯，作为调用事件发送到事件通道，这个通道就是音讯零碎，比方 RocketMQ、RabbitMQ 等。在工夫通道里存储后通过过滤路由的散发组件匹配到上游，而后推送解决。与此同时，还会有可观测、运维、监控的一些体系去撑持这个链路的牢靠运行。
残缺的性能需要十分多，这里提炼业务集成对音讯零碎的四个外围诉求：
1）多类型音讯传输：反对多样业务场景集成诉求，次要包含一般音讯、定时音讯、事务音讯、程序音讯等；
2）丰盛路由散发能力：反对多种散发路由条件，包含 Tag 过滤、音讯属性过滤，一对多、一对一散发等；
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 版在八月份公布新版本，新版本具备更强弹性、更低成本、更易运维等特点，欢送放弃关注。
点击此处，进入官网理解更多详情～