zoukankan      html  css  js  c++  java
  • activeMq集群搭建

    1.ActiveMq下载

    下载地址:https://activemq.apache.org/components/classic/download/

     2.ActiveMq解压安装

    Tar -zxvf  xxx(下载的安装包名称)

     3.Master/Slave集群配置

    shared File System Mater Slave方式

    (1)选择一台服务器作为NFS服务器(如:172.17.100.60

    (2)在该服务器上面创建一个可共享的目录    /mydata/shareMQ目录

    /mydata下执行命令mkdir shareMQ

    (3)/mydata/shareMQ目录的权限设置为777 chmod  777  /mydata/shareMQ

    4)编辑NFS服务器上面的/etc/exports文件(刚开始打开是个空文件)

    添加内容 /mydata/shareMQ  172.17.100.55(rw,sync)  172.17.100.57(rw,sync)

    添加内容 /mydata/shareMQ  172.17.100.58(rw,sync)  172.17.100.59(rw,sync)

    5)重启nfs服务  service nfs restart

    6)选择两台服务器作为activemq的运行环境 (如:172.17.100.55  172.17.100.57

    7)分别在两台服务器上面执行

    Mount  -t  nfs  172.17.100.60:/mydata/shareMQ  /mydata/mq/apache-activemq-5.15.14/data/kahadb

    172.17.100.60:/mydata/shareMQ  刚开始创建的共享目录

    /mydata/mq/apache-activemq-5.15.14/data/kahadb 挂载点,也是我们的MQ消息持久化的位置。

    (8)重复上面的步骤,第二步中的共享目录新建一个/mydata/shareMQ5859

    选择两台服务器作为activemq的运行环境 (如:172.17.100.58  172.17.100.59

    则会有两个master/slave集群,每个集群分别有两个节点。

    4.静态网络连接配置

    (1)在activemq根目录下进入/conf,可以看到activemq.xml文件

    (2)编辑activemq.xml文件,添加内容(注意该配置信息需要放到broker标签下面

    <networkConnectors>

        <networkConnector uri="static:(tcp://172.17.100.58:61616,tcp://172.17.100.59:61616)" duplex="true" conduitSubscriptions="false"/>

    </networkConnectors>

    Duplex:代表是否双向连接

    conduitSubscriptions:是否把同一个broker的多个consumer当做一个来处理。如果配置为true,假定有1个消费者连接amq13个消费者连接amq2,那么amq1的那个消费者将接收到50%的消息,amq23个消费者一共接收到50%的消息。所以这里设置为false,这样假定发送100条消息,那么每个消费者消费25条消息。

    uri="static:(tcp://172.17.100.58:61616,tcp://172.17.100.59:61616):连接另外两台机器上面的mq

     5.ActiveMq启动、停止、查看状态

    进入activemq根目录下的bin目录

    启动: ./activemq start

    停止: ./activemq stop

    查看状态:./activemq status

    6.集群高可用性测试

    分别启动172.17.100.55  172.17.100.57两台机器上面的mq服务,先启动的获取到文件锁为master,后启动的为slave。只有master可以被访问到,杀掉master服务,slave获取文件锁变为master

    7.消费者负载均衡测试

    两个可访问的mq服务之间形成静态的网络连接,两个服务上面各连接有一个消费者和一个生产者,其中一个生产者投递消息到mq,两个消费者各自消费一半的消息。

  • 相关阅读:
    20190613 安装Anaconda
    20190613 一个SQL问题
    20190604 宠物引发的乱想
    windows下的vim打开文件乱码解决
    【题解】 「NOI2019」弹跳 KDT优化建图+最短路+剪枝+卡空间 LOJ3159
    【题解】 [AH/HNOI2017]单旋 LCT+splay
    【题解】 CF1400E Clear the Multiset 笛卡尔树+贪心+dp
    【题解】 CF1404C Fixed Point Removal 线段树+树状数组+带悔贪心
    【题解】 CF1251E2 Voting (Hard Version) 带悔贪心
    【题解】 CF1418G Three Occurrences hash+双指针+差分
  • 原文地址:https://www.cnblogs.com/joeking/p/15223202.html
Copyright © 2011-2022 走看看