消息总线之zookeeper

2017-06-27 本文已影响0人 itfinally

实际上 spring cloud 的消息总线用的是 kafka，但是 kafka 依赖 zookeeper 进行集群，所以先写怎么配置 zookeeper，这里用的版本是 3.4.9。

zookeeper 单实例不用多说，默认配置就能跑，这里直接上集群，集群也分真伪，比如单机多实例就是一个伪集群，这是现在的实验环境。

目录结构如下:

kafka-HA
   |--- kafka-node0
   |         |--- config     ( kafka 根目录的 config 文件夹复制过来 )
   |         |--- log        ( kafka 配置指定的 log 文件夹 )
   |         |--- zk         ( zookeeper 根目录 )
   |         |--- zk-data    ( zookeeper 的 dataDir 文件夹 )
   |         |--- zk-log     ( zookeeper 的 log 文件夹 )
   |
   |--- kafka-node1
   |         |--- 同上
   |
more node...

其中 config 文件夹是这样的，真的是 kafka 的 config 复制过来，骗你是小狗:

config 文件夹

开胃菜吃完了，来点面包。

config 目录下有份 zookeeper.properties ，这正是 zk 的配置，主要配置只有几项，下面列一列:

dataDir --> 指定 zk 的数据存放目录
dataLogDir --> 指定 zk 的 log 目录
clientPort --> 指定 zk 的端口号

重点来了，小兵一般都冲前锋，比如前三个配置，不过没了小兵，大将也不叫大将，比如如果少了 dataDir，那就等着报错吧。

tickTime --> 这是 zk 的默认时间单元，默认两毫秒，后面说 N 个单位时间就是 ( tickTime * N ) 毫秒
initLimit --> 告诉 leader 在 initLimit 个时间单元内，如果 follower 还在躺尸就等于歇菜了
syncLimit ---> 告诉 leader 跟 follower 发消息的时候，如果请求&响应超过 syncLimit 个时间单元就等于歇菜了
server.A = ip:B:C ---> A 是一个数字，代表第几号服务器，就当 id 用好了，不能重复；ip 是对应第 A 号服务器的 ip；B 是在集群中 leader 和 follower 交流信息的端口号；C 是用来选举的端口号( 风水轮流转，leader 也可能歇菜，who know？ )

纳尼？no picture you say a jb?! 小弟不才，下面给大家看看:

zookeeper.propertie

这里看到图里是用 zk-node0 之类的 hostname ，一切为了方( bu )便( luo )，别忘了改 hosts 文件，同时在伪集群的时候，记得端口不要相同。

接下来要在 dataDir 指定的目录下加一份名为 myid 的文件，不用带后缀，文件内容写对应服务器的 id( 就是配置里面 server.A 的那个 A )，如果你是 *nix 系统，直接 echo 0 >> YOUR DATADIR/myid( 比如有一个第 0 号的 zk )，记得每个 zk 都要这么做，最后上个图:

myid 文件

不知不觉，连正餐都吃完了，最后来份甜品。

在上述目录中，zk 文件夹里面必须包含 zk 源文件( 就是说不能是软连接，硬的也不行 )，因为 zk 在运行时会在 zkServer 的上一级目录创建 pid 文件，如果是仅仅是连接，实际上你操作的是同一个文件夹，而多个 zk 实例会相互覆盖 pid，后果你懂的，我想这也是为什么 zookeeper 安装时没有把 zkServer 这种启动脚本复制到 /usr/bin 的原因。( 逼逼那么多，反正把 zk 的源文件复制一份过来就行了 )

like this:

zookeeeper 文件夹

小杜，是时候了！

跑到每一个 zk/bin 下执行 zkServer start YOUR CONFIG PATH 就行了，这个 path 一定要用绝对路径，因为 zkServer 脚本比较神奇，相对路径99.999%会找不到你给的文件，结果要么用了默认的 zoo.properties 要么就直接抛错罢工( 没有找到任何配置文件的情况下 )，可惜我又不会 bash 的语法，不然一番改改改。

比如 zkServer start /Users/finally/deveEnv/kafka-HA/kafka-node0/config/zookeeper.properties 运行 zk。

想看有没有跑起来？zkServer status YOUR CONFIG PATH 帮到你，跑起来的话你会看到如下信息:

zk status

这里的 Mode 是说明这个 zk 实例的身份，这里是 follower。

zookeeper 到这里，就完成部署了。

消息总线之zookeeper

猜你喜欢

热点阅读