消息总线之zookeeper

作者: itfinally | 来源:发表于2017-06-27 14:42 被阅读0次

实际上 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

    实际上 spring cloud 的消息总线用的是 kafka,但是 kafka 依赖 zookeeper 进行集...

  • 消息总线之kafka

    继上一篇消息总线之zookeeper之后,终于到部署 kafka 了,如果不记得上一篇描述的目录结构,那... 怪...

  • SpringCloud之消息总线

    【前面的话】书接上文SpringCloud之Config[https://eelve.com/archives/S...

  • Android实现消息总线的几种方式,你都会吗?

    Android中消息总线的几种实现方式 前言 消息总线又叫事件总线,为什么我们需要一个消息总线呢?是因为随着项目变...

  • 高级框架第十三天Config:分布式配置中心

    第一部分 Bus:消息总线 主要内容 1.消息总线简介 2.基于消息总线实现全局热刷新 一.消息总线简介 1.什么...

  • 消息总线

    SpringCloudBus:事件、消息总线,用于在集群(例如,配置变化事件)中传播状态变化,可与Spring C...

  • Spark消息总线实现

    消息总线概述 消息总线是Spark内部进行消息传递,触发事件的框架,消息总线的核心是由三个抽象的对象组成: Eve...

  • 微服务之消息总线

    简介 在上篇文章《微服务之配置中心》中写到,客户端可从服务端获取配置信息,当Git仓库中的配置文件修改后,为了让客...

  • Spring Cloud 之消息总线

    客户端获取到最新的配置信息需要执行refresh,可以利用webhook的机制每次提交代码发送请求来刷新客户端,当...

  • 消息总线之集成sc

    前戏做了那么多,终于到主题了。如果还没感觉,请先回顾一下zk部署和kafka部署,不然直接来主题会感觉很干涸的(认...

网友评论

    本文标题:消息总线之zookeeper

    本文链接:https://www.haomeiwen.com/subject/gztecxtx.html