Storm1.0集群部署
2016-07-27 18:01
239 查看
部署前准备
下载V1.0.0
http://mirrors.cnnic.cn/apache/storm/apache-storm-1.0.0/apache-storm-1.0.0.tar.gz
zookeeper信息
192.168.7.108:2181
192.168.7.109:2181
192.168.7.110:2181
Storm部署
Nimbus:192.168.7.111(active),192.168.7.112
Supervisor:192.168.7.111,192.168.7.112,192.168.7.113
检查python
storm@ydt-dsp-poc08:/ztapp/usr/storm >python -V Python 2.6.6 |
0、在3台服务器上配置hosts
vi /etc/hosts192.168.7.111 storm01
192.168.7.112 storm02
192.168.7.113 storm03
1、将apache-storm-1.0.0.tar.gz上传到storm安装目录
假设为:/home/usr/storm
2、解压
将apache-storm-1.0.0.tar.gz解压:tar -zxvf apache-storm-1.0.0.tar.gz
3、重命名(非必需)
将解压后的目录命名为stormmv apache-storm-1.0.0 storm
4、配置storm.yaml
进入storm/conf目录,修改storm.yaml配置文件为如下内容:# zookeeper ip storm.zookeeper.servers: - "192.168.7.108" - "192.168.7.109" - "192.168.7.110" storm.zookeeper.port: 2181 storm.zookeeper.root: "/storm" #Nimbus H/A nimbus.seeds: ["storm01","storm02"] #Nimbus dir storm.local.dir: "/ztapp/usr/storm/wkdir" #supervisor worker port, 4 workers example supervisor.slots.ports: - 6700 - 6701 - 6702 - 6703 |
绝大多数配置信息都是使用默认值,具体参考:
https://github.com/apache/storm/blob/v1.0.0/conf/defaults.yaml
在storm nimbus启动之后,wkdir目录结构如下:
storm@ydt-dsp-poc08:/ztapp/usr/storm/wkdir >du 4 ./nimbus/history 4 ./nimbus/inbox 12 ./nimbus 4 ./blobs 12 ./supervisor/isupervisor 4 ./supervisor/tmp 20 ./supervisor/localstate 40 ./supervisor |
5、进程启动
在192.168.7.111、192.168.7.112、192.168.7.113完成前面4步之后,按nimbus、supervisor的分布情况启动storm进程:192.168.7.111启动nimbus、supervisor、ui
./storm/bin/storm nimbus & ./storm/bin/storm supervisor & ./storm/bin/storm ui & |
192.168.7.112启动nimbus、supervisor、ui
./storm/bin/storm nimbus & ./storm/bin/storm supervisor & ./storm/bin/storm ui & |
192.168.7.113启动supervisor
./storm/bin/storm supervisor & |
6、验证
http://192.168.7.111:8080其他参考:
http://storm.apache.org/releases/1.0.0/Setting-up-a-Storm-cluster.html
http://storm.apache.org/releases/1.0.0/javadocs/org/apache/storm/Config.html
https://github.com/apache/storm/blob/v1.0.0/conf/defaults.yaml
相关文章推荐
- Gradle常用命令操作及配置说明
- Linux 下IO端口编程访问
- 三、腾讯统计和bugly追踪集成
- LinkList 单链表的实现
- Java高级-线程同步lock与unlock使用
- JQuery 网页选项卡制作
- JQuery 网页选项卡制作
- wps for linux 不能正常使用中文输入法
- Android应用setContentView与LayoutInflater加载解析机制源码分析
- Java的4种单例模式
- 对程序员来说,提高薪水最好的建议是什么?
- UVALive 3635 Pie (二分)
- Swift 流程控制
- ssh第一次输入免yes 和ssh-keygen免交互
- volatile关键字
- winform版弹框操作
- ios Byte *bt 输出 输出指针对应的内容
- 《nodejs实战》一
- JQuery学习之旅(3)
- pytho序列,字符串,元组---学习笔记