大数据分析处理中storm 相关的安装配置说明,linux 系统
1. 前提是已经安装好 JDK
2. 首选下载并安装 zookeeper
下载官网地址: http://hadoop.apache.org/zookeeper/releases.html
比如下载 zookeeper-3.4.6.tar.gz 版本,将该版本放入到 linux 服务器上,
进行解压: tar –zxvf zookeeper-3.4.6.tar.gz
设置环境变量
vi /etc/profile
export ZOOKEEPER_HOME=/opt/zookeeper-3.4.6
PATH=$ZOOKEEPER_HOME/bin:$PATH
export PATH
source /etc/profile
进入conf目录下的zoo_sample.cfg文件拷贝一份,命名为为“zoo.cfg” 修改 zoo.cfg 配置文件
修改zoo.cfg内容为:
# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
syncLimit=5
# 数据和日志存放路径.
dataDir=/urs/dpap/zookeeper/data
dataLogDir=/urs/dpap/zookeeper/logs
# 客户端端口号
clientPort=4180
# 2888,3888 are election port
server.1=zookeeper:2888:3888
server.2=zookeeper:2888:3888
其中,2888端口号是zookeeper服务之间通信的端口,而3888是zookeeper与其他应用程序通信的端口。而zookeeper是在hosts中已映射了本机的ip。 initLimit:这个配置项是用来配置 Zookeeper 接受客户端(这里所说的客户端不是用户连接 Zookeeper服务器的客户端,而是 Zookeeper 服务器集群中连接到 Leader 的 Follower 服务器)初始化连接时最长能忍受多少个心跳时间间隔数。当已经超过 10 个心跳的时间(也就是 tickTime)长度后 Zookeeper 服务器还没有收到客户端的返回信息,那么表明这个客户端连接失败。总的时间长度就是 5*2000=10 秒。 syncLimit:这个配置项标识 Leader 与 Follower 之间发送消息,请求和应答时间长度,最长不能超过多少个 tickTime 的时间长度,总的时间长度就是 2*2000=4 秒。 server.A=B:C:D:其中 A 是一个数字,表示这个是第几号服务器;B 是这个服务器的 ip 地址;C 表示的是这个服务器与集群中的 Leader 服务器交换信息的端口;D 表示的是万一集群中的 Leader 服务器挂了,需要一个端口来重新进行选举,选出一个新的 Leader,而这个端口就是用来执行选举时服务器相互通信的端口。如果是伪集群的配置方式,由于 B 都是一样,所以不同的 Zookeeper 实例通信端口号不能一样,所以要给它们分配不同的端口号。
注意:在配置server 中不需要配置 自己机器的IP 地址,如果是集群配置: server.A=B:C:D 每台机器的顺序要一直 ZooKeeper单节点以Standalone模式运行,不过它的长处在于通过分布式ZooKeeper集群(一个Leader,多个Follower) 集群状态:
./zkServer.sh status
JMX enabled by default
Using config: /opt/zookeeper-3.4.6/bin/../conf/zoo.cfg
Mode: follower
创建dataDir参数指定的目录(这里指的是“/urs/dpap/zookeeper/data”),并在目录下创建文件,命名为“myid”。
编辑“myid”文件,并在对应的IP的机器上输入对应的编号。如在zookeeper上,“myid”文件内容就是1。由于本次只在单点上进行安装配置,所以只有一个server.1。若还有其他服务器,比如地址为192.168.1.102,则在zoo.cfg文件中还需加入server.2=192.168.1.102:2888:3888。那么myid文件在192.168.1.102服务器上的内容就是2。 至此,如果是多服务器配置,就需要将zookeeper-3.4.6目录拷贝到其他服务器,然后按照上述的方法修改myid。
启动zookeeper
hadoop@ubuntu:~/zookeeper-3.4.6/bin$ ./zkServer.sh start #启动
hadoop@ubuntu:~/zookeeper-3.4.6/bin$ jps #查看启动的服务名称
hadoop@ubuntu:~/zookeeper-3.4.6/bin$ ./zkServer.sh stop #关闭
启动客户端脚本:zookeeper-3.3.6/bin/zkCli.sh -server localhost:2181
执行测试--创建节点:create /mytest test
列出节点 ls /
获取节点信息 get /mytest test
3. 安装ZeroMQ
下载地址:http://download.zeromq.org/ 选择zeromq-4.0.5.tar.gz
解压:tar –xzvf zeromq-4.0.5.tar.gz
进入:cd zeromq-4.0.5
执行:./configure
make
sudo make install
注意事项:
1. 如果安装过程报错uuid找不到,则通过如下的包安装uuid库:
# yum install uuid*
sudo yum install e2fsprogsl -b current
sudo yum install e2fsprogs-devel -b current
4. 安装JZMQ
下载地址:https://github.com/nathanmarz/jzmq jzmq-master.zip
解压: unzip jzmq-master.zip
进入: cd jzmq-master
执行: ./autogen.sh
./ configure
make
sudo make install
5. 安装Python
下载地址:https://www.python.org/ftp/python/3.5.0/ Python-3.5.0a3.tgz
解压: tar –zxvf Python-3.5.0a3.tgz
进入:cd Python-3.5.0a3
执行:./configure
make
make install
执行完成 查看版本信息:python -V
6. 安装淘宝: metamorphosis
下载地址: https://github.com/killme2008/Metamorphosis/tree/metamorphosis-all-1.4.6.2
Maven 下载:
<dependency>
<groupId>com.taobao.metamorphosis</groupId>
<artifactId>metamorphosis-client</artifactId>
<version>1.4.6.2</version>
</dependency>
学习资料:https://github.com/killme2008/Metamorphosis/wiki
解压: tar –zxvf metaq-server-1.4.6.2.tar.gz
进入: cd taobao/metamorphosis-server-wrapper/conf
编辑: vi server.ini这是meta服务器的配置文件
主要关注这几个配置项:
• brokerId 服务器ID,必须是集群内唯一
• numPartitions 默认每个topic的分区数目
• dataPath 数据文件的存放路径,默认在user.home/meta下
zookeeper配置:
以下为zk配置,可以为空,为空将从diamond获取(目前不提供),不为空则优先使用下列配置
zk.zkConnect=localhost:2181
;zk心跳超时,单位毫秒,默认30秒
zk.zkSessionTimeoutMs=30000
;zk连接超时时间,单位毫秒,默认30秒
zk.zkConnectionTimeoutMs=30000
;zk数据同步时间,单位毫秒,默认5秒
zk.zkSyncTimeMs=5000
metaq 和 zookeeper 集群配置:
zk.zkConnect=server1:2181,server2:2181,server3:2181
zookeeper的地址也可以通过diamond管理,如果本地不明确配置zookeeper,则设置diamond的dataId和group即可自动从diamond获取zookeeper配置(目前不提供,要注释掉):
;zk在diamond中配置存储的dataId
;diamondZKDataId=metamorphosis.zkConfig
;zk在diamond中配置存储的group
;diamondZKGroup=DEFAULT_GROUP
system:基本系统参数,包括唯一的brokerId、numPartition分片设置等;
zookeeper:图中配置了3台zookeeper,也就是zookeeper的集群;
topic:消息的主题订阅,发送与接收消息的标识。
启动服务:
cd bin
./ metaServer.sh start
关闭服务:
关闭服务器通过meta-server-stop.sh脚本即可关闭
./metaServer.sh stop
Metaq 页面访问:http://192.168.68.84:8120/
7.安装 storm
下载地址:http://storm.apache.org/downloads.html apache-storm-0.9.4.tar.gz
解压:tar –zxvf apache-storm-0.9.4.tar.gz
进入:cd apache-storm-0.9.4
设置环境变量:
vim /etc/profile
• export STORM_HOME=/路径 / apache-storm-0.9.4
• export PATH=$PATH:$STORM_HOME/bin
source /etc/profile
mkdir /usr/dpap/storm
修改storm/conf/storm.yaml文件
• storm.zookeeper.servers:
• - “zk1 server IP"
• - “zk2 server IP "
• - “zk3 server IP "
如果Zookeeper集群使用的不是默认端口,那么还需要storm.zookeeper.port选项。
• nimbus.host: “zk1"
说明: Storm集群Nimbus机器地址,各个Supervisor工作节点需要知道哪个机器是Nimbus,以便下载Topologies的jars、confs等文件
• storm.local.dir: "/usr/tmp/storm"
说明: Nimbus和Supervisor进程用于存储少量状态,如jars、confs等的本地磁盘目录,需要提前创建该目录并给以足够的访问权限。然后在storm.yaml中配置该目录
• supervisor.slots.ports:
• - 6700
• - 6701
• - 6702
• - 6703
说明:对于每个Supervisor工作节点,需要配置该工作节点可以运行的worker数量。每个worker占用一个单独的端口用于接收消息,该配置选项即用于定义哪些端口是可被worker使用的。默认情况下,每个节点上可运行4个workers,分别在6700、6701、6702和6703端口
java.library.path: ”/usr/local/lib:/opt/local/lib:/usr/lib”
说明:Storm使用的本地库(ZMQ和JZMQ)加载路径,默认为”/usr/local/lib:/opt/local/lib:/usr/lib”,一般来说ZMQ和JZMQ默认安装在/usr/local/lib 下,因此不需要配置即可。
(注意:先搭建zookeeper集群)
storm集群截图
Nimbus: 在Storm主控节点上运行”bin/storm nimbus >/dev/null 2>&1 &”启动Nimbus后台程序,并放到后台执行;
Supervisor: 在Storm各个工作节点上运行”bin/storm supervisor >/dev/null 2>&1 &”启动Supervisor后台程序,并放到后台执行;
UI: 在Storm主控节点上运行”bin/storm ui >/dev/null 2>&1 &”启动UI后台程序,并放到后台执行,启动后可以通过http://{nimbus host}:8080观察集群的worker资源使用情况、Topologies的运行状态等信息。
默认是启在8080端口上,如果你想改成其他的,如8089,直接修改nimbus的storm.yaml文件,添加
ui.port=8089
启动Storm后台进程时,需要对conf/storm.yaml配置文件中设置的storm.local.dir目录具有写权限。
Storm后台进程被启动后,将在Storm安装部署目录下的logs/子目录下生成各个进程的日志文件。
经测试,Storm UI必须和Storm Nimbus部署在同一台机器上,否则UI无法正常工作,因为UI进程会检查本机是否存在Nimbus链接。