-
strom要maven管理 http://archive.apache.org/dist/maven/binaries/查看全部
-
主从结构和对称结构的区别查看全部
-
批量计算和流式计算两者的区别查看全部
-
把任务拆解给多个任务,让多个计算机执行同一个任务查看全部
-
流式计算和批量计算的整合,CloudDataflow,summing bird查看全部
-
maven启动main方法,java程序查看全部
-
数据节点 Spout 计算节点 Bolt 数据流 Stream查看全部
-
StromAPI 拓扑 Topology查看全部
-
+2+2+2查看全部
-
+1+1+1查看全部
-
CloudDataflow查看全部
-
summing bird查看全部
-
流式计算和批量计算的整合查看全部
-
Grouping方式
查看全部 -
环境搭建:
1.下载安装zookeeper
2.生成一个新的配置文件 zoo.cfg
3.修改配置文件:vi zookeeper-3.4.6/conf/zoo.cfg
添加以下内容:
tickTime=2000
dataDir=/Users/dev/zookeeper-3.4.6/data
clientPort=2181
4.进入zookeeper目录: cd zookeeper-3.4.6
5.启动zookeeper服务: sh bin/zkServer.sh start
6.查看运行状态:echo stat | nc 127.0.0.1 2181
zookeeper集群版配置:
1.生成zoo.cfg.cluster文件,vi zoo.cfg.cluster
内容如下:
tickTime=2000
dataDir=/Users/dev/zookeeper-3.4.6/data
clientPort=2181
server.1=xx.xx.xx.xx:2182
server.2=xx.xx.xx.xx:2182
server.3=xx.xx.xx.xx:2182
syncLimit=2
initLimit=5
2.创建新文件 vi myid
内容如下:
1
3.在每台安装zookeeper的机器上启动服务即可
启动storm
1.进入storm文件:cd apache-storm-0.9.5
2.启动storm服务:
nohup bin/storm nimbus &
nohup bin/storm supervisor &
nohup bin/storm ui &
3.访问:http://localhost:8080/index.html
4.集群模式下,需要更改配置文件 vi conf/storm.yaml, 修改zk配置
提交一个jar包到storm:
1.查看文件:ls examples/storm-starter/
2.提交jar: ./bin/storm jar examples/storm-starter/storm-starter-topologies-0.9.5.jar storm.starter.WordCountTopology wordcount
3.访问http://localhost:8080/index.html 就能看到
4.关闭命令:./bin/storm kill wordcount
查看全部
举报