Skip to main content
版本:v1.6.0

Eventmesh-runtime 快速入门说明

EventMesh Runtime 是 EventMesh 集群中有状态的 Mesh 节点,负责 Source Connector 与 Sink Connector 之间的事件传输,并可以使用 EventMesh Storage 作为事件的存储队列。

1 本地构建运行

1.1 源码启动

1.1.1 依赖

建议使用64位操作系统,建议使用Linux / Unix;
64位JDK 1.8+;
Gradle至少为7.0, 推荐 7.0.*

1.1.2 下载源码

EventMesh download 下载并提取最新版本的源代码。比如目前最新版,您将获得apache-eventmesh-1.9.0-source.tar.gz

1.1.3 本地启动

1.1.3.1 项目结构说明:

  • eventmesh-common : eventmesh公共类与方法模块
  • eventmesh-connector-api : eventmesh connector插件接口定义模块
  • eventmesh-connector-plugin : eventmesh connector插件模块
  • eventmesh-runtime : eventmesh运行时模块
  • eventmesh-sdk-java : eventmesh java客户端sdk
  • eventmesh-starter : eventmesh本地启动运行项目入口
  • eventmesh-spi : eventmesh SPI加载模块

注:插件模块遵循 eventmesh 定义的SPI规范, 自定义的SPI接口需要使用注解 @EventMeshSPI 标识. 插件实例需要在对应模块中的 /main/resources/META-INF/eventmesh 下配置相关接口与实现类的映射文件,文件名为SPI接口全类名. 文件内容为插件实例名到插件实例的映射, 具体可以参考 eventmesh-connector-rocketmq 插件模块

1.1.3.2 插件说明

1.1.3.2.1 安装插件

有两种方式安装插件

  • classpath加载:本地开发可以通过在 eventmesh-starter 模块 build.gradle 中进行声明,例如声明使用 rocketmq 插件
   implementation project(":eventmesh-connectors:eventmesh-connector-rocketmq")
  • 文件加载:通过将插件安装到插件目录,EventMesh 在运行时会根据条件自动加载插件目录下的插件,可以通过执行以下命令安装插件
./gradlew clean jar dist && ./gradlew installPlugin

1.1.3.2.2 使用插件

EventMesh 会默认加载 dist/plugin 目录下的插件,可以通过-DeventMeshPluginDir=your_plugin_directory来改变插件目录。运行时需要使用的插件实例可以在 confPath目录下面的eventmesh.properties中进行配置。例如通过以下设置声明在运行时使用rocketmq插件。

#connector plugin
eventMesh.connector.plugin.type=rocketmq

1.1.3.3 配置VM启动参数

-Dlog4j.configurationFile=eventmesh-runtime/conf/log4j2.xml
-Deventmesh.log.home=eventmesh-runtime/logs
-Deventmesh.home=eventmesh-runtime
-DconfPath=eventmesh-runtime/conf

注:如果操作系统为Windows, 可能需要将文件分隔符换成'\'

1.1.3.4 启动运行

运行org.apache.eventmesh.starter.StartUp的主要方法

1.2 本地二进制构建

1.2.1 依赖

建议使用64位操作系统,建议使用Linux / Unix;
64位JDK 1.8+;
Gradle至少为7.0, 推荐 7.0.*

Gradle 是 Apache EventMesh 使用的构建自动化工具。请参考 官方指南 安装最新版本的 Gradle。

1.2.2 下载源码

EventMesh download 下载并提取最新版本的源代码。比如目前最新版,您将获得apache-eventmesh-1.9.0-source.tar.gz

tar -xvzf apache-eventmesh-1.9.0-source.tar.gz
cd apache-eventmesh-1.9.0-src/

使用 Gradle 构建源代码。

gradle clean dist

编辑 eventmesh.properties 以更改 EventMesh Runtime 的配置(如 TCP 端口、客户端黑名单)。

cd dist
vim conf/eventmesh.properties

1.2.3 构建并加载插件

Apache EventMesh引入了 SPI 机制,使 EventMesh 能够在运行时发现并加载插件。有两种方式安装插件:

  1. Gradle 依赖项: 在 eventmesh-starter/build.gradle 中将插件声明为构建依赖项。
dependencies {
implementation project(":eventmesh-runtime")

// 示例: 加载 RocketMQ 插件
implementation project(":eventmesh-connectors:eventmesh-connector-rocketmq")
}
  1. 插件目录: EventMesh 会根据 eventmesh.properties 加载 dist/plugin 目录中的插件。Gradle 的 installPlugin 任务会构建插件并将其移动到 dist/plugin 目录中。
gradle installPlugin

1.2.4 启动Runtime

执行 start.sh 脚本启动 EventMesh Runtime 服务器。

bash bin/start.sh

查看输出日志:

tail -f logs/eventmesh.out

2 远程部署

2.1 依赖

建议使用64位操作系统,建议使用Linux / Unix;
64位JDK 1.8+;
Gradle至少为7.0, 推荐 7.0.*

2.2 下载

EventMesh download 页面选择1.5.0版本的 Binary Distribution 进行下载, 您将获得apache-eventmesh-1.9.0-bin.tar.gz

# 解压
tar -xvzf apache-eventmesh-1.9.0-bin.tar.gz
cd apache-eventmesh-1.9.0

2.3 部署

编辑 eventmesh.properties 以更改 EventMesh Runtime 的配置(如 TCP 端口、客户端黑名单)。

vim conf/eventmesh.properties

执行 start.sh 脚本启动 EventMesh Runtime 服务器。

bash bin/start.sh

如果看到"EventMeshTCPServer[port=10000] started....",则说明设置成功。

查看输出日志:

cd /root/apache-eventmesh-1.9.0/logs
tail -f eventmesh.out

停止:

bash bin/stop.sh