1. 准备环境

centOS7

zookeeper

JDK8

安装可参考：

JDK8安装： http://blog.csdn.net/qq_21299835/article/details/79333532

zookeeper集群安装：http://blog.csdn.net/qq_21299835/article/details/79444929

2. 下载ActiveMQ

下载地址：http://activemq.apache.org/download.html

3. 在集群中创建activemq文件夹,路径为/usr/activemq

cd /usr

mkdir activemq

上传apache-activemq-5.15.2-bin.tar.gz到 /usr/activemq

4. 解压并重命名目录

tar -zxvf apache-activemq-5.15.2-bin.tar.gz

centOS7_1 :  mv apache-activemq-5.15.2 node-01

centOS7_2 :  mv apache-activemq-5.15.2 node-02

centOS7_3 :  mv apache-activemq-5.15.2 node-03

5. 修改管控台端口, 文件在conf/jetty.xml

node-01:

<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">

<!-- the default port number for the web console -->

<property name="host" value="0.0.0.0"/>

<property name="port" value="8161"/>

</bean>

node-02:

<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">

<!-- the default port number for the web console -->

<property name="host" value="0.0.0.0"/>

<property name="port" value="8162"/>

</bean>

node-03:

<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">

<!-- the default port number for the web console -->

<property name="host" value="0.0.0.0"/>

<property name="port" value="8163"/>

</bean>

6. 修改activemq.xml集群配置文件 文件路径conf/activemq.xml

node-01：

<persistenceAdapter>

<!-- kahaDB directory="${activemq.data}/kahadb"/ -->

<replicatedLevelDB

directory="${activemq.data}/leveldb"

replicas="3"

bind="tcp://0.0.0.0:62621"

zkAddress="192.168.1.217:2181,192.168.1.216:2182,192.168.1.218:2183"

hostname="192.168.1.217"

zkPath="/activemq/leveldb-stores"

/>

</persistenceAdapter>

node-02：

<persistenceAdapter>

<!-- kahaDB directory="${activemq.data}/kahadb"/ -->

<replicatedLevelDB

directory="${activemq.data}/leveldb"

replicas="3"

bind="tcp://0.0.0.0:62622"

zkAddress="192.168.1.217:2181,192.168.1.216:2182,192.168.1.218:2183"

hostname="192.168.1.216"

zkPath="/activemq/leveldb-stores"

/>

</persistenceAdapter>

node-03：

<persistenceAdapter>

<!-- kahaDB directory="${activemq.data}/kahadb"/ -->

<replicatedLevelDB

directory="${activemq.data}/leveldb"

replicas="3"

bind="tcp://0.0.0.0:62623"

zkAddress="192.168.1.217:2181,192.168.1.216:2182,192.168.1.218:2183"

hostname="192.168.1.218"

zkPath="/activemq/leveldb-stores"

/>

</persistenceAdapter>

7. 修改消息端口

node-01：

<transportConnectors>

<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->

<transportConnector name="openwire" uri="tcp://0.0.0.0:51511?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

node-02：

<transportConnectors>

<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->

<transportConnector name="openwire" uri="tcp://0.0.0.0:51512?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

node-03：

<transportConnectors>

<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->

<transportConnector name="openwire" uri="tcp://0.0.0.0:51513?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

8. 在防火墙中打开需要的端口

（1）查看防火墙所有打开的端口

firewall-cmd --list-ports

（2）开启端口

centOS_7_1:

firewall-cmd --zone=public --add-port=62621/tcp --permanent

firewall-cmd --zone=public --add-port=51511/tcp --permanent

firewall-cmd --zone=public --add-port=8161/tcp --permanent

centOS_7_2:

firewall-cmd --zone=public --add-port=62622/tcp --permanent

firewall-cmd --zone=public --add-port=51512/tcp --permanent

firewall-cmd --zone=public --add-port=8162/tcp --permanent

centOS_7_3:

firewall-cmd --zone=public --add-port=62623/tcp --permanent

firewall-cmd --zone=public --add-port=51513/tcp --permanent

firewall-cmd --zone=public --add-port=8163/tcp --permanent

9. 重新启动防火墙

（1）关闭防火墙

systemctl stop firewalld.service

（2）开启防火墙

systemctl start firewalld.service

（3）再次查看打开的端口

firewall-cmd --list-ports

10. 启动zookeeper服务

11. 启动activemq服务

cd bin

./activemq start

查看日志

cd data

tail -f activemq.log   //日志无报错即配置成功

12. 在项目配置文件中添加mq的配置文件

主要配置如下：

failover:(tcp://192.168.1.217:51511,tcp://192.168.1.216:51512,tcp://192.168.1.218:51513)?randomize=false

ActiveMQ集群安装与配置相关推荐

1. ActiveMQ — 集群 — 安装与配置

   2019独角兽企业重金招聘Python工程师标准>>> 1. 服务器配置 推荐集群的数量为基数,并且在这些机器上安装JDK,配置环境变量. 2. 集群方式 常用的集群方式有三种: 基 ...

2. 基于zookeeper(集群)+LevelDB的ActiveMq高可用集群安装、配置、测试

   Linux 环境 zookeeper集群安装.配置.测试https://blog.csdn.net/weixin_40816738/article/details/100576259 MQ集群部署规划 ...

3. Hadoop集群安装及其配置（三台虚拟机）

   Hadoop集群安装及其配置(三台虚拟机) 利安装配置前准备--安装虚拟机 利用cat查看配置文件 修改主机名称 配置IP映射 配置网卡设备的mac地址 Xshell的安装与配置 ssh的配置 JDK ...

4. JMS之——ActiveMQ 高可用与负载均衡集群安装、配置(ZooKeeper + LevelDB + Static discovery)...

   一.说明 从 ActiveMQ 5.9 开始, ActiveMQ 的集群实现方式取消了传统的 Master-Slave 方式,增加了基于ZooKeeper + LevelDB 的 Master-Sla ...

5. KafKa集群安装、配置

   一.事前准备 1.kafka官网:http://kafka.apache.org/downloads. 2.选择使用版本下载. 3.kafka集群环境准备:(linux) 192.168.145.12 ...

6. Hadoop集群安装与配置

   转载自Hadoop集群安装配置教程_Hadoop2.6.0_Ubuntu/CentOS 本教程讲述如何配置 Hadoop 集群,默认读者已经掌握了 Hadoop 的单机伪分布式配置,否则请先查看Had ...

7. hadoop2.8配置_Hadoop 2.8集群安装及配置记录

   第一部分:环境配置(含操作系统.防火墙.SSH.JAVA安装等) Hadoop 2.8集群安装模拟环境为: 主机:Hostname:Hadoop-host,IP:10.10.11.225 节点1:Ho ...

8. zookeeper集群安装和配置解读 - 雨中散步撒哈拉

   一.集群安装 0.环境准备 1.下载好的zk进行解压 2.创建数据和日志目录 3.修改配置 4.分发到集群节点 5.分别添加id 6.添加环境变量 二.集群常用命令 2.2.1 启动客户端 2.2.2 ...

9. MongoDB的集群安装搭建配置

   1. MongoDB介绍 1.1.MongoDB 简介 MongoDB 是由C++语言编写的,是一个基于分布式文件存储的开源数据库系统.具有以下特点: 面向集合文档型存储,易于存储对象类型的数据, 以 ...

10. FastDFS分布式文件系统集群安装与配置

    原文链接:http://blog.csdn.net/xyang81/article/details/52928230 FastDFS集群规划 跟踪服务器负载均衡节点1:192.168.1.206 df ...

最新文章

1. 利益相关者软件工程_如何向利益相关者解释用户体验的重要性
2. python实现关联算法_python使用Apriori算法进行关联性解析
3. php 文件 不更新,php页面不刷新更新数据
4. Spring IOC原理总结
5. isdigit()、isalpha()、isalnum() 三个函数的区别和注意点
6. WCF系统内置绑定列表与系统绑定所支持的功能
7. zend新建php项目,如何使用Zend Studio创建PHP项目
8. Allegro各属性说明如 Clines或者Cline Segs
9. 北京智能机器人为游客指路；日本研发出可识别背影的人工智能
10. java poi 替换word,POI替换Word中的mark标记（指定字符串）
11. 【Reinforcement Learning】蒙特卡洛算法
12. 土木工程材料——混凝土
13. 服务器2012系统修复,windows2012R2: sfc /scannow，错误：资源保护无法启动修复服务 - Microsoft Community...
14. 一个曾经纯数学专业毕业的未来算法工程师内心独白
15. python 新式类 旧式类_Python新式类与经典类(旧式类)的区别
16. 【Pytorch】加载torchvision中预训练好的模型并修改默认下载路径（使用models.__dict__[model_name]()读取）
17. 蓝牙的ATT协议（属性协议）和GATT协议
18. javaweb简单版学生管理系统
19. 0206PHOTOSHOP第零十式色相环
20. 2019 面试准备 - JS 防抖与节流 (超级 重要!!!!!)

热门文章

1. 盒子模型及其通用属性
2. oracle analyze失效,ORACLE: Analyze Table 失敗
3. 用xLang写Timer事件
4. 文献速递 | 宿主细胞中SARS-CoV-2（新冠病毒）的m⁶A甲基化研究
5. 国外哪个服务器最稳定,合适的国外服务器有什么选择技巧
6. Oracle中国区大裁员：昔日辉煌不再，退出中国市场？
7. ubuntu下查看硬件配置
8. 图层蒙版和图层剪贴路径_PS图层蒙版与剪贴蒙版综合应用——水杯里的树
9. mysql blast2go_blast2go本地化教程
10. 干货|爬虫被封的几个常见原因