飞道的博客

Strom 集群环境的搭建

328人阅读  评论(0)

上传并解压

apache-storm-1.1.0.tar.gz上传到centos01节点的/opt/softwares目录,然后将其解压到/opt/modules/目录:

tar -zxvf apache-storm-1.1.0.tar.gz -C /opt/modules

配置Storm

配置环境变量

sudo vim /etc/profile
export STORM_HOME=/opt/modules/apache-storm-1.1.0
export PATH=$PATH:$STORM_HOME/bin
source /etc/profile

编辑配置文件

修改$STORM_HOME/conf中的文件storm-env.sh

export JAVA_HOME=/opt/modules/jdk1.8.0_161
export STORM_CONF_DIR="/opt/modules/apache-storm-1.1.0/conf"

修改$STORM_HOME/conf中的文件storm.yaml

storm.zookeeper.servers:
    - "centos01"
    - "centos02"
    - "centos03"
supervisor.slots.ports:
    - 6700
    - 6701
    - 6702
    - 6703
storm.zookeeper.port: 2181
storm.local.dir: "/opt/modules/apache-storm-1.1.0/data"
nimbus.seeds: ["centos01"]
  • storm.zookeeper.servers:指定ZooKeeper节点的IP地址或主机名
  • supervisor.slots.ports:定义Worker用于通信的端口号,端口号的数量为每个Supervisor中Worker数量的最大值。对于每个Supervisor工作节点,需要配置该工作节点可以运行的最大Worker数量。每个Worker占用一个单独的端口,该配置属性即用于定义哪些端口是可被Worker使用的。默认情况下,每个节点上可运行4个Worker,分别运行在6700、6701、6702、6703端口。
  • storm.zookeeper.port:ZooKeeper节点的访问端口,如果不是默认值2181,则需要设置此属性。
  • storm.local.dir:Nimbus和Supervisor守护进程需要本地磁盘上的一个目录来存储少量的状态信息。
  • nimbus.seeds:Nimbus的后选节点,此处只配置一个。

复制安装信息到其他节点

scp -r /opt/modules/apache-storm-1.1.0/ centos02:/opt/modules/
scp -r /opt/modules/apache-storm-1.1.0/ centos03:/opt/modules/

启动ZooKeeper集群

bin/zkServer.sh start

启动Storm

centos01上执行以下命令,启动Nimbus和UI服务,且在后台运行:

storm nimbus >/dev/null 2>&1 &
storm ui >/dev/null 2>&1 &

jps查看进程:

查看Storm UI:

centos02centos03上启动Supervisor服务:

storm supervisor >/dev/null 2>&1 &

jps查看进程:

查看Storm UI:


转载:https://blog.csdn.net/qq_43613793/article/details/116084458
查看评论
* 以上用户言论只代表其个人观点,不代表本网站的观点或立场