一个基于 JavaScript 脚本引擎的数据交换系统，用来验证和第三方系统集成的可行性方案。
这个项目最初是为了解决一个实际问题：我们有很多不同的业务系统需要对接，每次都要写大量的胶水代码。能不能让这个过程更灵活一点？于是就有了 ESM——用 JavaScript 脚本来处理数据流转，而不是每次都要重新编译部署。
- 监听数据库事件（MySQL、SQL Server、PostgreSQL、SQLite、Oracle 都支持）
- 用 JavaScript 写处理逻辑，热更新不用重启
- 自动把处理后的数据推送到外部 HTTP 接口
- 自带重试机制，失败自动重发
技术栈是 .NET 10 + Jint（JavaScript 引擎）+ React 前端。前后端打包在一起，部署比较简单。
说实话，这个项目功能都写完了，界面也做完了，但实际生产环境的测试还不够充分。我自己在几个场景跑过，但肯定还有很多边界情况没覆盖到。
如果你打算用在正式环境，建议：
- 先在测试环境跑一段时间，观察下内存和稳定性
- 从非核心业务开始接入，别一上来就接关键链路
- 开详细日志，方便出问题排查
已知可能不太稳的地方：
- 高并发下的表现还没充分验证
- 网络抖动、数据库断连后的恢复逻辑
- 长时间运行的内存占用情况
- JS 脚本的安全隔离（目前主要靠自觉）
EventStreamManager/
├── EventStreamManager.WebApi/ # Web API主项目（前端打包后放这里）
├── EventStreamManager.EventProcessor/ # 事件处理核心
├── EventStreamManager.Infrastructure/ # 基础设施
├── EventStreamManager.JSFunction/ # JS函数接口定义
├── EventStreamManager.JSFunction.Loader/ # 插件加载器
├── EventStreamManager.JSFunction.Sql/ # SQL操作插件
├── EventStreamManager.JSFunction.Standard/ # 标准工具函数
├── EventStreamManager.Probe/ # 服务探针（看门狗，可选）
└── EventStreamManager-UI/ # React前端
核心流程：
- EventScanner 定期扫数据库，找新事件
- ScriptExecutor 调用 Jint 执行你的 JS 脚本
- 脚本返回要不要发送、发什么内容
- InterfaceSender 负责 HTTP 推送，失败自动重试
- HandleRecorder 记录处理结果，方便排查问题
- .NET 10.0 SDK
- Node.js 16+（开发前端需要）
- pnpm（或者 npm/yarn 也行）
后端：
cd EventStreamManager.WebApi
dotnet restore
dotnet run
# 默认跑在 http://localhost:7138前端：
cd EventStreamManager-UI
pnpm install
pnpm run dev
# 跑在 http://localhost:3000推荐把前端打包进后端，单服务部署：
# 打包前端
cd EventStreamManager-UI
pnpm install
pnpm run build
# 复制到后端 wwwroot
cp -r dist/* ../EventStreamManager.WebApi/wwwroot/
# 发布后端（独立发布，无需目标机安装 .NET 运行时）
cd ../EventStreamManager.WebApi
dotnet publish -c Release -r win-x64 --self-contained
# 发布后执行文件在 bin/Release/net10.0/win-x64/publish/EventStreamManager.WebApi.exe然后直接访问 http://localhost:7138 就行。
每个处理器脚本需要返回一个 ProcessResult 对象：
class ProcessResult {
constructor() {
this.needToSend = true; // 要不要发HTTP请求
this.reason = ''; // 不发的话原因是什么
this.error = null; // 异常信息
this.requestInfo = null; // 要发送的数据（JSON字符串）
}
setSuccess(requestInfo) {
this.needToSend = true;
this.reason = '';
this.error = null;
this.requestInfo = requestInfo;
return this;
}
setFailure(reason, error) {
this.needToSend = false;
this.reason = reason;
this.error = error;
return this;
}
setNoSend(reason) {
this.needToSend = false;
this.reason = reason || '仅执行脚本，无需发送';
return this;
}
}function process(data) {
const result = new ProcessResult();
console_log('收到事件:', data.Context.EventName);
// 构造发送数据
const payload = {
eventId: data.Context.EventId,
type: data.Context.EventType,
timestamp: new Date().toISOString()
};
return result.setSuccess(JSON.stringify(payload));
}function process(data) {
const result = new ProcessResult();
// 查用户信息
const users = sql_query(
'mysql',
'Server=localhost;Database=test;Uid=root;Pwd=123456;',
'SELECT * FROM Users WHERE Id = @id',
{ '@id': data.Context.EventId }
);
if (users.length === 0) {
return result.setFailure('用户不存在');
}
// 更新状态
sql_execute(
'mysql',
'Server=localhost;Database=test;Uid=root;Pwd=123456;',
'UPDATE Users SET LastSync = NOW() WHERE Id = @id',
{ '@id': data.Context.EventId }
);
return result.setSuccess(JSON.stringify(users[0]));
}SQL 相关：
sql_query(dbType, conn, sql, params)- 查询，返回数组sql_execute(dbType, conn, sql, params)- 执行增删改sql_scalar(dbType, conn, sql, params)- 返回单个值sql_bulk_insert(...)- 批量插入sql_transaction(...)- 事务操作
日志：
console_log(...)/console_info(...)/console_warn(...)/console_error(...)/console_debug(...)
{
"rows": [
{ "field1": "value1", "field2": "value2" }
],
"database": { "type": "mysql" },
"context": {
"eventId": "123",
"strEventReferenceId": "REF001",
"eventType": "order.created",
"eventName": "订单创建",
"eventCode": "ORDER_001",
"operatorName": "admin",
"operatorCode": "ADMIN",
"createDatetime": "2024-03-28T10:00:00",
"extenData": ""
},
"processor": {
"id": 1,
"name": "订单处理器",
"enabled": true
}
}{
"needToSend": true, // 是否发送
"reason": "", // 原因说明
"error": null, // 错误信息
"requestInfo": "..." // 发送内容（JSON字符串）
}系统会监听这个表：
CREATE TABLE tblevent (
Id INT PRIMARY KEY AUTO_INCREMENT,
strEventReferenceId VARCHAR(100),
EventType VARCHAR(50),
EventName VARCHAR(200),
EventCode VARCHAR(50),
OperatorName VARCHAR(100),
OperatorCode VARCHAR(50),
CreateDatetime DATETIME,
ExtenData TEXT,
ProcessStatus INT DEFAULT 0
);ProcessStatus 字段用来标记处理状态：
0= 未处理1= 处理中2= 成功3= 失败
appsettings.json：
{
"Serilog": {
"MinimumLevel": {
"Default": "Information",
"Override": {
"Microsoft.AspNetCore": "Warning",
"System": "Warning"
}
}
},
"AllowedHosts": "*",
"urls": "http://localhost:7138;"
}日志同时输出到控制台和 logs/log-YYYYMMDD.txt，保留 30 天。
如果想加自定义 JS 函数，实现 IJsFunctionProvider 接口：
public class MyFunctions : IJsFunctionProvider
{
public string Name => "My Functions";
public string Description => "我的自定义函数";
public string Version => "1.0.0";
public IEnumerable<FunctionMetadata> GetFunctions()
{
yield return new FunctionMetadata
{
Name = "my_func",
Category = "Custom",
Description = "示例函数",
FunctionDelegate = new Func<string, int>(input => input.Length),
Parameters = new List<FunctionParameter>
{
new() { Name = "input", Type = typeof(string), Description = "输入字符串" }
},
ReturnType = typeof(int),
Example = "var len = my_func('hello');"
};
}
}EventStreamManager.Probe 是一个独立的看门狗进程，用于监控主服务（WebApi）的健康状态，发现服务无响应后自动重启。适用于长期无人值守的生产服务器。
- 每隔一段时间 HTTP 探测主服务
- 连续多次失败后自动 kill 并重启主服务
- 自身也支持日志持久化（
logs/probe-YYYYMMDD.txt）
探针和主服务发布到同一目录下：
C:\EventStreamManager\
├── EventStreamManager.WebApi.exe # 主服务
├── EventStreamManager.Probe.exe # 探针
├── probeSettings.json # 探针配置
└── Scripts\
├── start-service.bat # 手动启动主服务
├── run-probe.bat # 手动启动探针
├── install-service.bat # 注册主服务为 Windows 服务
├── install-probe-service.bat # 注册探针为 Windows 服务
└── ...
cd EventStreamManager.Probe
dotnet publish -c Release -r win-x64 --self-contained -o <你的部署目录>手动控制台运行（调试用）：
Scripts\start-service.bat # 窗口1：启动主服务
Scripts\run-probe.bat # 窗口2：启动探针注册为 Windows 服务（生产推荐）：
# 以管理员身份运行
Scripts\install-service.bat # 注册主服务，开机自启
Scripts\install-probe-service.bat # 注册探针，开机自启
# 然后启动
net start EventStreamManager
net start EventStreamManagerProbeprobeSettings.json：
{
"Probe": {
"TargetUrl": "http://localhost:7138",
"CheckIntervalSeconds": 30,
"FailureThreshold": 3,
"RestartCommand": "EventStreamManager.WebApi.exe",
"RestartArguments": "",
"WorkingDirectory": "."
}
}| 配置项 | 说明 |
|---|---|
TargetUrl |
探测目标地址 |
CheckIntervalSeconds |
探测间隔（秒） |
FailureThreshold |
连续失败几次后触发重启 |
RestartCommand |
重启时执行的命令 |
MIT
有什么使用问题或者建议，欢迎提 issue。