storm集群搭建Java客户端测试代码.zip

/*********************storm 环境搭建 **********************/ 1 安装jdk1.7 2 安装zookeeper集群环境 3 安装Python2.6.6 网址：https://www.python.org/ftp/python/2.6.6/ 4 安装storm0.9.1 解压三台机器： 命令：tar -zxvf apache-storm-0.9.2-incubating.tar.gz -C /usr/local/ 命令： mv apache-storm-0.9.2-incubating/ apache-storm-0.9.2 5 修改storm配置文件： 1 cd /usr/local/apache-storm-0.9.2/conf 修改命令：vim storm.yaml文件（三台zookeeper的地址） （1）storm.zookeeper.servers: - "192.168.80.1" - "192.168.80.2" - "192.168.80.3" （2）nimbus.host: "192.168.80.1" （3）创建data目录 添加到配置文件中：mkdir /usr/local/apache-storm-0.9.2/data storm.local.dir: "/usr/local/apache-storm-0.9.2/data" （4）配置ui.port ui.port: 18080 （5）配置supervisor的工作进程 supervisor.slots.ports: - 6700 - 6701 - 6702 - 6703 6 把apache-storm-0.9.2使用scp到各个集群的服务器中去。 7 修改配置文件 /etc/profile 把STORM配置到其中去 并 使用scp到各个集群的服务器中去。 命令：vim /etc/profile 修改内容： export STORM_HOME=/usr/local/apache-storm-0.9.2 export PATH=.:$JAVA_HOME/bin:$ZOOKEEPER_HOME/bin:$STORM_HOME/bin:$PATH 最后分别进行 source /etc/profile 8 首先启动zookeeper集群，然后分别启动运行storm： 192.168.80.1: 主机器（nimbus运行） storm nimbus & 192.168.80.2: 从机器（supervisor运行） storm supervisor & 192.168.80.3: 从机器（supervisor运行） storm supervisor & 192.168.80.1: 主机器（ui运行）storm ui & （查看ui） 192.168.80.1: 主机器（logviewer运行） storm logviewer &（查看工作日志） 9 然后在浏览器中输入主机器的ip，端口默认8080 （http://192.168.80.1:18080/） 这样可以看到storm的一些集群配置