ActiveMQ简介
ActiveMQ是一种开源的基于JMS(Java Message Servie)规范的一种消息中间件的实现,ActiveMQ的设计目标是提供标准的,面向消息的,能够跨越多语言和多系统的应用集成消息通信中间件。
文章源自小柒网-https://www.yangxingzhen.cn/6012.html
一、高可用集群搭建方案
文章源自小柒网-https://www.yangxingzhen.cn/6012.html
节点A: 与节点B节点C进行消息同步, 所以节点A节点B节点C都可用作消费者访问节点;
文章源自小柒网-https://www.yangxingzhen.cn/6012.html
节点B: 作为master主节点, 作为生产者访问节点和消费者访问节点;
文章源自小柒网-https://www.yangxingzhen.cn/6012.html
节点C: 作为slave从节点, 作为生产者访问节点和消费者访问节点, 当 master节点挂掉后, slave自动转换为master节点。
文章源自小柒网-https://www.yangxingzhen.cn/6012.html
#这里采用三台机器进行集群搭建。
文章源自小柒网-https://www.yangxingzhen.cn/6012.html
IP地址文章源自小柒网-https://www.yangxingzhen.cn/6012.html |
服务端口文章源自小柒网-https://www.yangxingzhen.cn/6012.html |
管理端口文章源自小柒网-https://www.yangxingzhen.cn/6012.html |
存储文章源自小柒网-https://www.yangxingzhen.cn/6012.html |
网络连接器 |
用途 |
192.168.1.76(A) |
61616 |
8161 |
- |
节点B、节点C |
消费者 |
192.168.1.77(B) |
61616 |
8161 |
/data/kahadb |
节点A |
生产者、消费者 |
192.168.1.78(C) |
61616 |
8161 |
/data/kahadb |
节点A |
生产者、消费者 |
三、JAVA环境部署
注:三台机器上面都需要部署JAVA环境
注:在192.168.1.76服务器上安装
1、安装步骤
1)下载安装包(https://www.oracle.com/technetwork/java/javase/downloads/java-archive-javase8-2177648.html)
2)解压JDK软件包
[root@localhost ~]# tar zxf jdk-8u181-linux-x64.tar.gz -C /usr/local
3)配置系统环境变量
编辑vim /etc/profile,添加以下内容
[root@localhost ~]# vim /etc/profile
export JAVA_HOME=/usr/local/jdk1.8.0_181
export CLASSPATH=$CLASSPATH:$JAVA_HOME/lib:$JAVA_HOME/jre/lib
export PATH=$JAVA_HOME/bin:$JAVA_HOME/jre/bin:$PATH:$HOMR/bin
执行source /etc/profile使其生效
[root@localhost ~]# source /etc/profile
4)使用java、javac等命令验证是否安装成功。
[root@localhost ~]# java -version
java version "1.8.0_181"
Java(TM) SE Runtime Environment (build 1.8.0_181-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.181-b13, mixed mode)
注:在192.168.1.77服务器上安装
1、安装步骤
1)下载安装包(https://www.oracle.com/technetwork/java/javase/downloads/java-archive-javase8-2177648.html)
2)解压JDK软件包
[root@localhost ~]# tar zxf jdk-8u181-linux-x64.tar.gz -C /usr/local
3)配置系统环境变量
编辑vim /etc/profile,添加以下内容
[root@localhost ~]# vim /etc/profile
export JAVA_HOME=/usr/local/jdk1.8.0_181
export CLASSPATH=$CLASSPATH:$JAVA_HOME/lib:$JAVA_HOME/jre/lib
export PATH=$JAVA_HOME/bin:$JAVA_HOME/jre/bin:$PATH:$HOMR/bin
执行source /etc/profile使其生效
[root@localhost ~]# source /etc/profile
4)使用java、javac等命令验证是否安装成功。
[root@localhost ~]# java -version
java version "1.8.0_181"
Java(TM) SE Runtime Environment (build 1.8.0_181-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.181-b13, mixed mode)
注:在192.168.1.78服务器上安装
1、安装步骤
1)下载安装包(https://www.oracle.com/technetwork/java/javase/downloads/java-archive-javase8-2177648.html)
2)解压JDK软件包
[root@localhost ~]# tar zxf jdk-8u181-linux-x64.tar.gz -C /usr/local
3)配置系统环境变量
编辑vim /etc/profile,添加以下内容
[root@localhost ~]# vim /etc/profile
export JAVA_HOME=/usr/local/jdk1.8.0_181
export CLASSPATH=$CLASSPATH:$JAVA_HOME/lib:$JAVA_HOME/jre/lib
export PATH=$JAVA_HOME/bin:$JAVA_HOME/jre/bin:$PATH:$HOMR/bin
执行source /etc/profile使其生效
[root@localhost ~]# source /etc/profile
4)使用java、javac等命令验证是否安装成功。
[root@localhost ~]# java -version
java version "1.8.0_181"
Java(TM) SE Runtime Environment (build 1.8.0_181-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.181-b13, mixed mode)
四、ActiveMQ部署
注:在192.168.1.76机器上安装
1)下载ActiveMQ安装包
[root@localhost ~]# wget -c http://mirror.bit.edu.cn/apache//activemq/5.15.10/apache-activemq-5.15.10-bin.tar.gz
2)解压ActiveMQ安装包
[root@localhost ~]# tar xf apache-activemq-5.15.10-bin.tar.gz
[root@localhost ~]# mv apache-activemq-5.15.10 /usr/local/activemq
[root@localhost ~]# vim /usr/local/activemq/conf/activemq.xml
#添加以下内容
<networkConnectors>
<networkConnector name="local_network" uri="static:(tcp://192.168.1.77:61616,tcp://192.168.1.78:61616)"/>
</networkConnectors>
注:在192.168.1.77机器上安装
1)下载ActiveMQ安装包
[root@localhost ~]# wget -c http://mirror.bit.edu.cn/apache//activemq/5.15.10/apache-activemq-5.15.10-bin.tar.gz
2)解压ActiveMQ安装包
[root@localhost ~]# tar xf apache-activemq-5.15.10-bin.tar.gz
[root@localhost ~]# mv apache-activemq-5.15.10 /usr/local/activemq
3)编辑activemq.xml配置文件
[root@localhost ~]# vim /usr/local/activemq/conf/activemq.xml
#添加以下内容
<networkConnectors>
<networkConnector name="network_a" uri="static:(tcp://192.168.1.76:61616)"/>
</networkConnectors>
注:在192.168.1.78机器上安装
1)下载ActiveMQ安装包
[root@localhost ~]# wget -c http://mirror.bit.edu.cn/apache//activemq/5.15.10/apache-activemq-5.15.10-bin.tar.gz
2)解压ActiveMQ安装包
[root@localhost ~]# tar xf apache-activemq-5.15.10-bin.tar.gz
[root@localhost ~]# mv apache-activemq-5.15.10 /usr/local/activemq
3)编辑activemq.xml配置文件
[root@localhost ~]# vim /usr/local/activemq/conf/activemq.xml
#添加以下内容
<networkConnectors>
<networkConnector name="network_a" uri="static:(tcp://192.168.1.76:61616)"/>
</networkConnectors>
4)分别启动三台机器AcitveMQ服务
#192.168.1.76
[root@localhost ~]# /usr/local/activemq/bin/activemq start
#192.168.1.77
[root@localhost ~]# /usr/local/activemq/bin/activemq start
#192.168.1.78
[root@localhost ~]# /usr/local/activemq/bin/activemq start
5)查看ActiveMQ进程
[root@localhost ~]# ps -ef |grep activemq
6)查看动AcitveMQ端口
[root@localhost ~]# netstat -lntup
#最后访问三个节点的 ActiveMQ 管理界面 进行相关查看
节点A http://192.168.1.76:8161
节点B http://192.168.1.77:8161
节点C http://192.168.1.78:8161
7)访问ActiveMQ WEB界面
ActiveMQ自带了一个web服务器(jetty,是java开发的),如果不了解没有关系,我们先学会怎么使用即可。
apache-activemq-5.15.10/conf/jetty.xml是该服务器的基本配置。
浏览器输入:192.168.1.76:8161,出现以下界面
浏览器输入:192.168.1.77:8161,出现以下界面
浏览器输入:192.168.1.78:8161,出现以下界面
8)访问ActiveMQ后台
浏览器输入:http://192.168.1.77:8161/admin
用户名:admin
密码:admin
登录后界面
9)查看队列
10)创建Topic
至此,ActiveMQ高可用集群搭建完成。
若文章图片、下载链接等信息出错,请在评论区留言反馈,博主将第一时间更新!如本文“对您有用”,欢迎随意打赏,谢谢!
![weinxin](https://www.yangxingzhen.com/images/weixin.jpg)
![weinxin](https://www.yangxingzhen.com/images/weixingongzhonghao.png)
不错