如何在 Spring 生态中玩转 RocketMQ？

做者 | 通融、洛夜
来源 | 阿里巴巴云原生公众号

RocketMQ 做为业务消息的首选，在消息和流处理领域被普遍应用。而微服务生态 Spring 框架也是业务开发中最受欢迎的框架，二者的完美契合使得 RocketMQ 成为 Spring Messaging 实现中最受欢迎的消息实现。本文展现了 5 种在 Spring 生态中文玩转 RocketMQ 的方式，并描述了每一个项目的特色和使用场景。文末能够直达在线体验。

前言

上世纪 90 年代末，随着 Java EE(Enterprise Edition) 的出现，特别是 Enterprise Java Beans 的使用须要复杂的描述符配置和死板复杂的代码实现，增长了广大开发者的学习曲线和开发成本，由此基于简单的 XML 配置和普通 Java 对象 (Plain Old Java Objects) 的 Spring 技术应运而生，依赖注入 (Dependency Injection)，控制反转 (Inversion of Control) 和面向切面编程 (AOP) 的技术更加敏捷地解决了传统 Java 企业及版本的不足。随着 Spring 的持续演进，基于注解 (Annotation) 的配置逐渐取代了 XML 文件配置。除了依赖注入、控制翻转、AOP 这些技术，Spring 后续衍生出 AMQP、Transactional、Security、Batch、Data Access 等模块，涉及开发的各个领域。

2014 年 4 月 1 日，Spring Boot 1.0.0 正式发布。它基于“约定大于配置”（Convention over configuration）这一理念来快速地开发，测试，运行和部署 Spring 应用，并能经过简单地与各类启动器（如 spring-boot-web-starter）结合，让应用直接以命令行的方式运行，不需再部署到独立容器中。Spring Boot 的出现能够说是 Spring 框架的第二春，它不但简化了开发的流程，目前更是事实标准。下面这幅图能够看出相同功能的 Spring 和 Spring Boot 的代码实现对比。

Apache RocketMQ 是一款是业界知名的分布式消息和流处理中间件，它主要功能是消息分发、异步解耦、削峰填谷等。RocketMQ 是一款金融级消息及流数据平台，RocketMQ 在交易、支付链路上用的不少，主要是对消息链路质量要求很是高的场景，可以支持万亿级消息洪峰。RocketMQ 在业务消息中被普遍应用，并衍生出顺序消息、事务消息、延迟消息等匹配各种业务场景的特殊消息。

本文的主角就是 Spring 和 RocketMQ，那几乎每一个 Java 程序员都会使用 Spring 框架与支持丰富业务场景的 RocketMQ 会碰撞出怎么样的火花？

RocketMQ 与 Spring 的碰撞

在介绍 RocketMQ 与 Spring 故事以前，不得不提到 Spring 中的两个关于消息的框架，Spring Messaging 和 Spring Cloud Stream。它们都可以与 Spring Boot 整合并提供了一些参考的实现。和全部的实现框架同样，消息框架的目的是实现轻量级的消息驱动的微服务，能够有效地简化开发人员对消息中间件的使用复杂度，让系统开发人员能够有更多的精力关注于核心业务逻辑的处理。

1. Spring Messaging

Spring Messaging 是 Spring Framework 4 中添加的模块，是 Spring 与消息系统集成的一个扩展性的支持。它实现了从基于 JmsTemplate 的简单的使用 JMS 接口到异步接收消息的一整套完整的基础架构，Spring AMQP 提供了该协议所要求的相似的功能集。在与 Spring Boot 的集成后，它拥有了自动配置能力，可以在测试和运行时与相应的消息传递系统进行集成。

单纯对于客户端而言，Spring Messaging 提供了一套抽象的 API 或者说是约定的标准，对消息发送端和消息接收端的模式进行规定，好比消息 Messaging 对应的模型就包括一个消息体 Payload 和消息头 Header。不一样的消息中间件提供商能够在这个模式下提供本身的 Spring 实现：在消息发送端须要实现的是一个 XXXTemplate 形式的 Java Bean，结合 Spring Boot 的自动化配置选项提供多个不一样的发送消息方法；在消息的消费端是一个 XXXMessageListener 接口（实现方式一般会使用一个注解来声明一个消息驱动的 POJO），提供回调方法来监听和消费消息，这个接口一样可使用 Spring Boot 的自动化选项和一些定制化的属性。

在 Apache RocketMQ 生态中，RocketMQ-Spring-Boot-Starter（下文简称 RocketMQ-Spring）就是一个支持 Spring Messaging API 标准的项目。该项目把 RocketMQ 的客户端使用 Spring Boot 的方式进行了封装，可让用户经过简单的 annotation 和标准的 Spring Messaging API 编写代码来进行消息的发送和消费，也支持扩展出 RocketMQ 原生 API 来支持更加丰富的消息类型。在 RocketMQ-Spring 毕业初期，RocketMQ 社区同窗请 Spring 社区的同窗对 RocketMQ-Spring 代码进行 review，引出一段罗美琪（RocketMQ）和春波特（Spring Boot）故事的佳话，著名 Spring 布道师 Josh Long 向国外同窗介绍如何使用 RocketMQ-Spring 收发消息。RocketMQ-Spring 也在短短两年时间超越 Spring-Kafka 和 Spring-AMQP（注：二者均由 Spring 社区维护），成为 Spring Messaging 生态中最活跃的消息项目。

2. Spring Cloud Stream

Spring Cloud Stream 结合了 Spring Integration 的注解和功能，它的应用模型以下：

Spring Cloud Stream 框架中提供一个独立的应用内核，它经过输入 (@Input) 和输出 (@Output) 通道与外部世界进行通讯，消息源端 (Source) 经过输入通道发送消息，消费目标端 (Sink) 经过监听输出通道来获取消费的消息。这些通道经过专用的 Binder 实现与外部代理链接。开发人员的代码只须要针对应用内核提供的固定的接口和注解方式进行编程，而不须要关心运行时具体的 Binder 绑定的消息中间件。

在运行时，Spring Cloud Stream 可以自动探测并使用在 classpath 下找到的 Binder。这样开发人员能够轻松地在相同的代码中使用不一样类型的中间件：仅仅须要在构建时包含进不一样的 Binder。在更加复杂的使用场景中，也能够在应用中打包多个 Binder 并让它本身选择 Binder，甚至在运行时为不一样的通道使用不一样的 Binder。 

Binder 抽象使得 Spring Cloud Stream 应用能够灵活的链接到中间件，加之 Spring Cloud Stream 使用利用了 Spring Boot 的灵活配置配置能力，这样的配置能够经过外部配置的属性和 Spring Boot 支持的任何形式来提供（包括应用启动参数、环境变量和 application.yml 或者 application.properties 文件），部署人员能够在运行时动态选择通道链接 destination（例如，RocketMQ 的 topic 或者 RabbitMQ 的 exchange）。

Spring Cloud Stream 屏蔽了底层消息中间件的实现细节，但愿以统一的一套 API 来进行消息的发送/消费，底层消息中间件的实现细节由各消息中间件的 Binder 完成。Spring 官方实现了 Rabbit binder 和 Kafka Binder。Spring Cloud Alibaba 实现了 RocketMQ Binder，其主要实现原理是把发送消息最终代理给了 RocketMQ-Spring 的 RocketMQTemplate，在消费端则内部会启动 RocketMQ-Spring Consumer Container 来接收消息。以此为基础，Spring Cloud Alibaba 还实现了 Spring Cloud Bus RocketMQ， 用户可使用 RocketMQ 做为 Spring Cloud 体系内的消息总线，来链接分布式系统的全部节点。经过 Spring Cloud Stream RocketMQ Binder，RocketMQ 能够与 Spring Cloud 生态更好的结合。好比与 Spring Cloud Data Flow、Spring Cloud Funtion 结合，让 RocketMQ 能够在 Spring 流计算生态、Serverless(FaaS) 项目中被使用。

现在 Spring Cloud Stream RocketMQ Binder 和 Spring Cloud Bus RocketMQ 做为 Spring Cloud Alibaba 的实现已登录 Spring 的官网，Spring Cloud Alibaba 也成为 Spring Cloud 最活跃的实现。

如何在 Spring 生态中选择 RocketMQ 实现？

经过介绍 Spring 中的消息框架，介绍了以 RocketMQ 为基础与 Spring 消息框架结合的几个项目，主要是 RocketMQ-Spring、Spring Cloud Stream RocketMQ Binder、Spring Cloud Bus RocketMQ、Spring Data Flow 和 Spring Cloud Function。它们之间的关系能够以下图表示。

如何在实际业务开发中选择相应项目进行使用？下面分别列出每一个项目的特色和使用场景。

1. RocketMQ-Spring

特色：

• 做为起步依赖，简单引入一个包就能在 Spring 生态用到 RocketMQ 客户端的全部功能。

• 利用了大量自动配置和注解简化了编程模型，而且支持 Spring Messaging API。

• 与 RocketMQ 原生 Java SDK 的功能彻底对齐。

使用场景：

• 适合在 Spring Boot 中使用 RocketMQ 的用户，但愿能用到 RocketMQ 原生 java 客户端的全部功能，并经过 Spring 注解和自动配置简化编程模型。

2. Spring Cloud Stream RocketMQ Binder

特色：

• 屏蔽底层 MQ 实现细节，上层 Spring Cloud Stream 的 API 是统一的。若是想从 Kafka 切到 RocketMQ，直接改个配置便可。

• 与 Spring Cloud 生态整合更加方便。好比 Spring Cloud Data Flow，这上面的流计算都是基于 Spring Cloud Stream；Spring Cloud Bus 消息总线内部也是用的 Spring Cloud Stream。

• Spring Cloud Stream 提供的注解，编程体验都是很是棒。

使用场景：

• 在代码层面能彻底屏蔽底层消息中间件的用户，而且但愿能项目能更好的接入 Spring Cloud 生态（Spring Cloud Data Flow、Spring Cloud Funtcion等）。

3. Spring Cloud Bus RocketMQ

特色：

• 将 RocketMQ 做为事件的“传输器”，经过发送事件（消息）到消息队列上，从而广播到订阅该事件（消息）的全部节点上，完成事件的分发和通知。

使用场景：

• 在 Spring 生态中但愿用 RocketMQ 作消息总线的用户，能够用在应用间事件的通讯，配置中心客户端刷新等场景。

4. Spring Cloud Data Flow

特色：

• 以 Source/Processor/Sink 组件进行流式任务处理。RocketMQ 做为流处理过程当中的中间存储组件。

使用场景：

• 流处理，大数据处理场景。

5. Spring Cloud Function

特色：

• 消息的消费/生产/处理都是一次函数调用，融合 Java 生态的 Function 模型。

使用场景：

• Serverless 场景。

本文总体介绍了在 Spring 生态中接入 RockeMQ 的 5 种方法，让各位开发者对几种经典场景有宏观的了解。后续会有专栏详细介绍上述各个项目的具体使用方法和应用场景，真正地在 Spring 生态中玩转 RocketMQ！