RocketMQ Streams 1.1.0: 轻量级流处理再出发-CSDN博客

本文链接：https://blog.csdn.net/ApacheRocketMQ/article/details/128914383

RocketMQ Streams 1.1.0改进了面向用户API，支持泛型和自定义序列化，减少了代码冗余，优化了流处理逻辑。本文介绍了新版本的API使用、典型示例，包括WordCount、窗口聚合和双流JOIN，鼓励用户参与开源贡献。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

本文作者：倪泽，Apache RocketMQ committer、RSQLDB/RocketMQ Streams Maintainer

01 背景

RocketMQ Streams是一款基于RocketMQ为基础的轻量级流计算引擎，具有资源消耗少、部署简单、功能全面的特点，目前已经在社区开源。RocketMQ Streams在阿里云内部被使用在对资源比较敏感，同时又强烈需要流计算的场景，比如在自建机房的云安全场景下。

自RocketMQ Streams开源以来，吸引了大量用户调研和试用。但是也存在一些问题，在RocketMQ Streams 1.1.0中，主要针对以下问题做出了改进和优化。

1、面向用户API不够友好，不能使用泛型，不支持自定义序列化/反序列化；

2、代码冗余，在RocketMQ Streams中存在将流处理拓扑序列化反序列化模块，RocketMQ Streams作为轻量级流处理SDK，构建好流处理节点之后应该可以直接处理数据，不存在将流处理拓扑图本地保存或者网络传输需求。

3、流处理过程不容易理解，含有大量缓存、刷新逻辑；

4、存在大量支持SQL的代码，这部分和SDK方式运行流处理任务的逻辑无关；

在RocketMQ Streams 1.1.0中，对上述问题做出了改进，期望能带来更好的使用体验。同时，重新设计了流处理拓扑构建过程、去掉冗余代码，使得代码更容易被理解。

从今天起，将推出系列文章介绍RocketMQ Streams 1.1.0版本，本次文章主要介绍RocketMQ Streams 1.1.0的API如何使用，如何利用RocketMQ Streams快速构建流处理应用。

02 典型使用示例

本地运行下列示例的步骤：

1、部署RocketMQ 5.0；

2、使用mqAdmin创建topic；

3、构建示例工程，添加依赖，启动示例。RocketMQ Streams 坐标：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-streams</artifactId>
    <version>1.1.0</version>
</dependency>

4、向topic中写入相应数据，并观察结果。

更详细文档请参考：