Storm0.9.5单机版

柔光的暖阳◎ 2022-07-21 01:53 71阅读 0赞

> 一、安装JDK   
>  jdk安装略去。。  
> 
> 
> 二、安装zookeeper
> 
> 1.下载解压。。
> 
>     wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
>     tar -zxvf zookeeper-3.4.6.tar.gz
>     mv zookeeper-3.4.6 zookeeper
>     cd zookeeper
>     cp conf/zoo_sample.cfg conf/zoo.cfg
> 
> 2.配置环境变量
> 
>     vim /etc/profile
>     export ZOOKEEPER_HOME=/usr/local/zookeeper
>     export PATH=$ZOOKEEPER_HOME/bin:$PATH
> 
> 三、安装Storm
> 
> 1.下载解压。。
> 
>     wget http://mirrors.cnnic.cn/apache/storm/apache-storm-0.9.5/apache-storm-0.9.5.tar.gz
>     tar -zxvf apache-storm-0.9.5.tar.gz
>     mv apache-storm-0.9.5 storm
>     cd storm
> 
> 2.配置环境变量
> 
>     vim /etc/profile
>     export STORM_HOME=/usr/local/storm
>     export PATH=$STORM_HOME/bin:$PATH
>     
>     source /etc/profile
> 
> 3.修改配置文件  
> 
> 
>     vi conf/storm.yaml
>     #storm.zookeeper.servers: Storm集群使用的Zookeeper集群地址
>     storm.zookeeper.servers:
>          - "127.0.0.1"
>     #     - "server2"
>     storm.zookeeper.port: 2181      //zookeeper端口默认就是 2181
>     
>     #nimbus.host: Storm集群Nimbus机器地址，各个Supervisor工作节点
>     #需要知道哪个机器是Nimbus，以便下载Topologies的jars、confs等文件
>     nimbus.host: "127.0.0.1"
>     # 
>     # 
>     #storm.local.dir: Nimbus和Supervisor进程用于存储少量状态，如jars、confs等的本地磁盘目录，
> 
>     #需要提前创建该目录并给以足够的访问权限。然后在storm.yaml中配置该目录
>     storm.local.dir: "/usr/local/storm/tmpdata"
>     ui.port: 8088
>     #supervisor.slots.ports: 对于每个Supervisor工作节点，需要配置该工作节点可以运行的worker数量。
>     #每个worker占用一个单独的端口用于接收消息，该配置选项即用于定义哪些端口是可被worker使用的。
>     #默认情况下，每个节点上可运行4个workers，分别在6700、6701、6702和6703端口：
>     supervisor.slots.ports:    
>     	- 6700    
>     	- 6701    
>     	- 6702     
>     	- 6703
> 
> 4.启动Storm
> 
>     zkServer.sh start
>     storm nimbus		//在Storm主控节点上运行
>     storm supervisor	//在Storm各个工作节点上运行
>     storm ui		//在Storm主控节点上运行
> 
> 5.打开浏览器访问8088端口，如下图
> 
> ![20160712184846607][]  
> 
> 
> 6.运行实例
> 
>     cd examples/storm-starter
>     提交任务
>     storm jar storm-starter-topologies-0.9.5.jar storm.starter.WordCountTopology wordcountTop
>     
>     杀掉topology命令
>     storm kill wordcountTop
> 
> 7.UI如下图
> 
> ![20160712185124532][]  
>

[20160712184846607]: /images/20220720/2d5155b5fe67482996234f898d0b545f.png
[20160712185124532]: /images/20220720/cbd4a33cc30949448b238a79925f6c6e.png