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,两个消费者各自消费一半的消息。

activeMq集群搭建

上一篇:系统集成项目管理工程师10大管理47个过程域输入输出工具(项目质量管理)


下一篇:若依框架-字段绑定到字典