wso2 CEP集成storm实验
1.三台机子:192.168.225.1(manager,nimbus),
192.168.225.2(worker,supervisor),
192.168.225.3(worker,supervisor)
1.启zookeeper
1.(每台机子)在zookeeper工作目录配置myid文件,分别写入1,2,3.
2.bin目录下执行./zkServer.sh start
说明:可分布式也可单点
2.启storm
1.在STORM_HOME/conf/storm.yaml配置zookeeper节点和nimbus的地址,nimbus.host配置为192.168.225.1
2.在192.168.225.1的STORM_HOME/bin目录下启动./storm nimbus & 和./storm ui &,其他机子启动./storm supervisor &
说明:如果有报错要检查依赖,Python什么的是否有安装
3.启cep
1.将storm中的storm.yaml拷贝到CEP_HOME/repository/conf/cep/storm/目录下
2.将CEP_HOME/repository/conf/目录下的event-process配置文件配置distribute模式打开(改为true,ha模式为false),然后分别配置管理节点和工作节点
3.CEP_HOME/repository/conf/axis2/axis2.xml配置集群发现模式为wka,更改 domain为wso2.carbon.domain,同样配置本机ip,然后在members中写入cep集群所有节点,端口保留默认4000
4.分别在CEP_HOME/bin目录下用./wso2server.sh启动cep节点,观察日志是否与storm的工作节点串联起来
4.发布拓扑并测试
1.在cep的manager机子上访问9443端口进入程序界面,配置不同的流以及接收(receiver)发布(publisher)程序,cep会自动将配置好的拓扑发布到storm中
2.向工作节点发送数据,观察工作节点对数据处理
相关文章
- haproxy与nginx、zabbix集成
- EasyDSS高性能RTMP、HLS(m3u8)、HTTP-FLV、RTSP流媒体服务器功能简介---实时数据统计报表、视频文件上传、点播、分享、集成
- 1、Android Studio集成极光推送(Jpush) 报错 java.lang.UnsatisfiedLinkError: cn.jpush.android.service.PushProtoco
- SAP 电商云 Spartacus UI 和 CPQ Configurable Products 的集成
- 【SpringBoot笔记10】SpringBoot框架集成Druid数据源
- EL之AdaBoost:集成学习之AdaBoost算法的简介、应用、经典案例之详细攻略
- 专接本汇编开发工具【Masm for Winodws 集成实验环境】安装细则
- 用于高效高光谱图像分类的多尺度上下文感知集成深度 KELM(Matlab代码实现)
- Apache CarbonData 2.0 开发实用系列之一:与Spark SQL集成使用
- m基于多集成BP神经网络的matlab仿真,神经网络通过编程实现不使用工具箱
- jenkins+docker持续集成实验
- Jenkins+Maven+SVN快速搭建持续集成环境(转)
- 技术分享 | 单元测试体系集成
- 【2023最新教程】用Jenkins+Docker+Maven+Git实现持续集成 (超详细)
- Python+request+unittest实现接口测试框架集成实例
- 持续集成高级篇之Jenkins资源调度
- 云原生DevOps篇:Jenkins集成Kubernetes实现动态Agent构建机制