rsqldb

rsqldb 为 Rocketmq Streams 的开发提供了基于SQL的开发体验， 让基于消息队列的流式开发更加容易；

Features

• 采用标准的流式SQL规范，可以与其他的流计算框架如Flink完美兼容；
• 兼容Flink自带的udf、udaf和udtf，除此之外，用户还可以通过实现相关接口来轻松扩展函数；

如果您希望更详细的了解rsqldb的相关内容， 请点击这里

Quickstart

运行环境

• JDK 1.8及以上
• Maven 3.2及以上

在本地安装RocketMQ-Streams

rsqldb依赖的RocketMQ-Streams版本为1.0.2-preview-SNAPSHOT（RocketMQ-Streams近期会做一次发版，发版之后省略该步骤）。

git clone https://github.com/apache/rocketmq-streams.git
#切换到main分支
mvn clean install -DskipTest -U

下载rsqldb工程并本地构建

git clone https://github.com/alibaba/rsqldb.git

mvn clean package -DskipTest -U

拷贝安装压缩包并解压

进入rsqldb-disk模块下，将rsqldb-distribution.tar.gz安装包拷贝到任意目录，并执行命令解压并进入解压目录：

tar -zxvf rsqldb-distribution.tar.gz;cd rsqldb

启动rsqldb服务端

chmod +x bin/startAll.sh;sh bin/startAll.sh

配置sql文件

sendDataFromFile.sql中创建的任务，需要从本地文件指定位置读取数据，所以需要修改sendDataFromFile.sql中filePath变量的位置，修改为数据文件data.txt的绝对路径。

提交任务

执行路径依然在rsqldb解压目录下

chmod +x client/clientExector.sh;sh client/clientExector.sh submitTask sendDataFromFile.sql

sendDataFromFile.sql会从本地文件data.txt中读取数据，过滤出只含有field_1=1的数据，并将结果数据输出到日志中。

启动任务

在rsqldb解压目录下执行，tail运行日志，为查看结果做准备。

tail -f log/rsqldb-runner.log

另开一个shell窗口，进入解压后的rsqldb目录，执行以下命令启动任务，1分钟后，查看日志输出，会将执行结果打印到日志中。

sh client/clientExector.sh startTask

观察rsqldb-runner.log输出，输出结果中，只包含field_1=1的数据。

查询任务

在rsqldb解压目录下执行

sh client/clientExector.sh queryTask

返回已经提交的任务列表。

停止任务

在rsqldb解压目录下执行

sh client/clientExector.sh stopTask

从RocketMQ中读取数据并处理

上述示例为从本地文件data.txt中读取数据，更为常用的用法是从RocketMQ中读取数据处理，下面给出具体步骤：

• 本地安装并启动RocketMQ，安装文档
• 启动rsqldb服务端

  chmod +x bin/startAll.sh;sh bin/startAll.sh

• 提交任务

  chmod +x client/clientExector.sh;sh client/clientExector.sh submitTask rocketmq.sql

rocketmq.sql会从RocketMQ的rsqldb-source中读取数据，过滤出field_1=1的数据，并将结果输出到日志文件中。

• 查看输出

tail -f log/rsqldb-runner.log

• 另开一个窗口，启动任务

sh client/clientExector.sh startTask

• 向RocketMQ中生产数据：topic为rsqldb-source，与rocketmq.sql任务中的topic名称保持一致，向该topic写入data.txt文件中的数据。

• 观察输出，在输出结果中，只包含field_1=1的数据。