美文网首页
activeMQ+zooKeeper实现高可用性

activeMQ+zooKeeper实现高可用性

作者: zzzTango | 来源:发表于2016-09-28 16:07 被阅读0次

    ZooKeeper是一个为分布式应用所设计的分布的、开源的协调服务,它主要是用来解决分布式应用中经常遇到的一些数据管理问题,简化分布式应用协调及其管理的难度,提供高性能的分布式服务。
     ActiveMQ是Apache一款开源的,完全支持JMS1.1和J2EE 1.4规范的JMS Provider实现的消息中间件,用来帮助实现高可用、高性能、可伸缩、 易用和安全的企业级面向消息服务的系统

    原理

    activeMQ提供了三种高可用性实现方案:

    从5.9版本之后activeMQ官方推荐采用第三种,因此此文只介绍第三种。

    Replicated LevelDB Store方案使用Zookeeper选举Master。要进行选举,则需要多数派的“参与者”。因为Replicated LevelDB Store中有多个Broker,从多个Broker中选举出一个成为Master,其他的则成为Slave。只有Master接收Client的连接,Slave负责连接到Master,并接收(同步方式、异步方式)Master上的数据。
     比如说:一共有3个Broker,一个Master,二个Slave。当新消息到达Master时,Master需要将消息同步到其中一台Slave之后,才能向Producer发送ACK确认此次消息成功发送。
    而剩下的另一台Slave,则可以在后台以异步方式复制这个新消息。此外,还能容忍一台Slave宕机。(能容忍不超过大多数的Broker宕机)

    Replicated LevelDB Store.png

    配置

    zooKeeper配置文件

    确保zooKeeper集群正常工作,安装奇数个(>=3,示例安装3个)zooKeeper,每个zooKeeper配置文件如下:

    #zoo.cfg
    tickTime=2000 #Zookeeper服务器之间或客户端与服务器之间维持心跳的时间间隔
    initLimit=10 # Zookeeper接受客户端初始化连接时最长能忍受多少个心跳时间间隔数
    syncLimit=5 #标识Leader与Follower之间发送消息,请求和应答时间长度,最长不能超过多少个tickTime的时间长度
    dataDir=/path/to/zookeeper/data #Zookeeper保存数据的目录,默认情况下Zookeeper将写数据的日志文件也保存在这个目录里。
    clientPort=2181 #客户端(应用程序)连接Zookeeper服务器的端口,Zookeeper 会监听这个端 口接受客户端的访问请求。
    #server.A=B:C:D
    #A位数字与myid文件值对应,B服务器地址,C集群成员信息交换端口,D是Leader挂掉后用来选举Leader的端口
    server.1=10.0.2.190:2888:3888
    server.2=10.0.2.195:2888:3888
    server.3=10.0.2.199:2888:3888
    
    zooKeeper安装过程
    wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.9/zookeeper-3.4.9.tar.gz  #下载zookeeper,如果下载不了请移步官网
    tar zxvf zookeeper-3.4.9.tar.gz #解压
    mv zookeeper-3.4.9 zookeeper #重命名
    cd zookeeper 
    mkdir data # 创建zookeeper数据储存文件夹
    cd conf
    cp zoo_sample_cfg zoo.cfg #创建zoo.cfg配置文件,并按照上述zoo.cfg配置
    cd data 
    echo "1" > myid #data文件夹下创建myid文件,如:zoo.cfg中配置server.1=10.0.2.190:2888:3888,则10.0.2.190的zooKeeper的myid值是1
    
    activeMQ配置
    #conf/activemq.xml
    <persistenceAdapter>
        <replicatedLevelDB  
            directory="${activemq.data}/leveldb" #存储数据的路径
            replicas="3" #集群中的节点数[(replicas/2)+1公式表示集群中至少要正常运行的服务数量], 即3台集群保证两台要正常运行
            bind="tcp://0.0.0.0:0" #这个节点成为Master,它会绑定配置好的地址和端口来履行主从复制协议 
            zkAddress="10.0.2.190:2181,10.0.2.195:2181,10.0.2.199:2181" #ZooKeeper的ip和port 
            zkPassword="password" #当连接到ZooKeeper服务器时用的密码 
            hostname="10.0.2.190" #本机ip或域名  
            zkPath="/activemq/leveldb-stores" #ZooKeeper选举信息交换的存贮路径 
        />  
    </persistenceAdapter> 
    
    activeMQ安装
    1.下载activeMQ最新稳定版本,上传到服务器
    2.tar zxvf  apache-activemq-5.14.0-bin.tar.gz #解压
    3.修改配置文件
    

    shell指令

    zkServer.sh [start|stop|restart|status] #zooKeeper启动|停止|重启|状态
    activemq start #activeMQ启动
    

    测试

    根据myid从1-3依次启动zooKeeper,查看zooKeeper集群状态:
    follower(2个):


    zk_follower.png

    leader:


    zk_leader.png

    分别启动activeMQ,在浏览器地址栏里输入:

    客户端集成

    java配置activeMQ的连接工厂是,把原有的url改成下述的即可。    
    
        url=failover:(tcp://10.0.2.190:61616,tcp://10.0.2.195:61616,tcp://10.0.2.199:61616)?randomize=false

    相关文章

      网友评论

          本文标题:activeMQ+zooKeeper实现高可用性

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