wso2-ei 编译

在众多规则引擎中，找到了 siddhi 能处理流式数据，支持 etl 等功能，但其为基础的单机版本，除非启动多个实例，网上有 siddhi-storm 的版本，将 siddhi 作为 storm 中的 Bolt 进行执行。wso2 公司自己的实现也是依赖 storm 实现分布式实时流处理。

在 wso2 众多产品中 wso2-ei(product-ie) 是依赖 siddhi 实现的 carbon-event-processing 来执行所有流式规则，如下以源码的方式进行编译:

# 注：使用 openjdk-8 进行编译，否则会出现 xml.binder 类似的异常
$ mvn clean install -Dmaven.test.skip=true

# 编译完成之后，生成的文件存放在 distribution/target 目录下
$ cd distribution/target && unzip wso2ei-6.7.0-SNAPSHOT.zip && cd wso2ei-6.7.0-SNAPSHOT

# 以集成的方式启动服务
$ ./bin/integrator.sh

注 根据日志提示即可访问 https://10.1.2.3:9443/carbon/ 直接进行访问，默认用户为 admin / admin

wso2-ei 介绍

WSO2 ESB 允许系统管理员和SOA架构师轻松的配置消息路由, 虚拟化, 中介, 转换, 日志记录, 任务调度, 负载均衡, 失败路由, 事件中介等等. 运行时被设计为完全异步, 非阻塞 、连续的。基于 Apache Synapse 中介引擎，Apache Synapse是使用Apache Axis2创建的。

数据流

carbon-event-processing 介绍

各种数据通过 receiving 获取数据，然后通过 SiddhiSpout 接收数据，发射到后端 siddhiBolt 中逐步执行，并完成所有的规则：

基于 cep 处理流程