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