RabbitMQ是什么?
MQ(Msaaage Queue,消息队列)是一种应用程序对应用程序的通信方式。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无须专用链接来连接它们。消息传递指的是程序之间通过在消息中发送数据进行通讯。而不是通过直接调用彼此来通信。队列的使用除去了接收和发送应用程序同时执行的要求。
RabbirMQ使用场景在项目中,将一些无需即时返回且耗时的操作提取出来,进行异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高系统的吞吐量
RabbitMQ支持消息的持久化,也就是数据写在磁盘上。为了数据安全考虑,大多数企业都会选择持久化。当然如果不需要消息持久化,那么使用内存节点即可。RabbitMQ的集群节点包括内存节点、磁盘节点。最合适的方案就是既有内存节点,又有磁盘节点。
RabbitMQ是用Erlang开发的,集群非常方便,因为Erlang天生就是一门分布式语言,但其本身并不支持负载均衡。
RabbitMQ模式大概分为三种
单一模式
普通模式(默认的集群模式)
镜像模式(把需要的队列做成镜像队列,存在于多个节点,属于RabbitMQ的HA方案,在对业务可靠性要求较高的场合中比较适用)
要实现镜像模式,需要先搭建一个普通集群模式,在这个模式的基础上再配置镜像模式可以实现高可用。
RabbitMQ功能 RabbitMQ集群搭建 实现步骤设计架构模式:在一个集群里,有三台服务器,其中一台使用磁盘模式,另两台使用内存模式。两台内存模式的节点速度更快,因此通过客户端连接访问它们。但是在客户端不可能分别连接两台内存节点,肯定是通过前端反向代理去轮询分发请求。如果担心前端反向代理服务器故障,可以通过keepalived软件做一个高可用架构。而磁盘模式的节点,由于磁盘IO相对较慢,因此仅作数据备份使用。
环境准备关闭防火墙及selinux systemctl stop firewalld.service setenforce 0
虚拟机规划如下
主机名IP地址操作系统系统用途软件包mq01 172.16.10.28 CentOS-7-x86_64 磁盘节点 rabbitmq-server-3.3.5
mq02 172.16.10.29 CentOS-7-x86_64 内存节点 rabbitmq-server-3.3.5
mq03 172.16.10.31 CentOS-7-x86_64 内存节点 rabbitmq-server-3.3.5
修改主机名及hosts文件 vim /etc/hostname mq01.localdomain //三台服务器都需要修改,分别改为mq02,mq03,名称可以自定义 vim /etc/hosts 172.16.10.28 mq01 172.16.10.29 mq02 172.16.10.31 mq03 //hosts文件三台服务器都一致,与hostname修改的内容要对应 reboot //修改之后重启虚拟机生效 安装rabbitmq软件 yum install epel-release -y yum install rabbitmq-server -y 查看节点服务 rabbitmq-plugins list 启动管理服务 rabbitmq-plugins enable rabbitmq_management 启动rabbitmq服务 systemctl start rabbitmq-server.service netstat -ntap | grep 5672
在服务启动之后,若是有三个端口开放,则表示服务服务开启成功。其中15672和25672都是rabbitmq的管理端口,5672则是和生产者、消费者通信的端口。
查看连接状态先查看单个连接是否能够,三台服务器都要做测试,如果连接失败,就要检查前面的hostname和hosts文件设置有没有错误。
rabbitmqctl cluster_status 修改.erlang.cookie文件Rabbitmq的集群是依赖于Erlang的集群来工作的,所以必须先构建起Erlang的集群环境。在Erlang的集群中,各节点通过一个magic cookie来实现的,这个cookie存放在/var/lib/rabbitmq/.erlang.cookie(该文件为隐藏文件)中,文件是400的权限。必须使各节点cookie保持一致,否则节点之间就无法通信。注意在作修改时,应先关闭rabbitmq服务
cat .erlang.cookie //查看文件中的值,修改两个内存节点,使三个值相同 systemctl stop rabbitmq-server.service //关闭两个内存节点的rabbimq服务,并修改cookie值 systemctl start rabbitmq-server.service //修改完成之后再启动服务 将内存节点与磁盘节点相连