Rabbitmq 消息队列

Posted 2021-01-28 18513387476-com

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Rabbitmq 消息队列相关的知识，希望对你有一定的参考价值。

一.rabbitmq 的概念

AMQP 即 Advanced Message Queuing Protocol

高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。

AMQP 的主要特征是面向消息、队列、路由（包括点对点和发布 / 订阅）、可靠性、安全。

Rabbitmq 属于一个流行的开源消息队列系统。属于AMQP( 高级消息队列协议 ) 标准的一个实现。是应用层协议的一个开放标准，为面向消息的中间件设计。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。

消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。

AMQP 的主要特征是面向消息、队列、路由（包括点对点和发布 / 订阅）、可靠性、安全。

二. 特点

1.使用Erlang编写

2.支持持久化

3.支持HA

4.提供C# , erlang，java，perl，python，ruby等的client开发端

三. Rabbitmq 中的概念名词

Broker：简单来说就是消息队列服务器实体。

Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。

Queue：消息队列载体，每个消息都会被投入到一个或多个队列。

Binding：绑定，它的作用就是把exchange和queue按照路由规则绑定起来。 Routing Key：路由关键字， exchange根据这个关键字进行消息投递。

vhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。 producer：消息生产者，就是投递消息的程序。

consumer：消息消费者，就是接受消息的程序。

channel：消息通道，在客户端的每个连接里，可建立多个channel，每个 channel代表一个会话任务

四. 工作原理

MQ 是消费 - 生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取或者订阅队列中的消息。 MQ 则是遵循了 AMQP协议的具体实现和产品。在项目中，将一些无需即时返回且耗时的操作提取出来，进行了异步处理，而这种异步处理的方式大大的节省了服务器的请求响应时间，从而提高了系统的吞吐量。

（ 1）客户端连接到消息队列服务器，打开一个channel。

（ 2）客户端声明一个exchange，并设置相关属性。

（ 3）客户端声明一个queue，并设置相关属性。

（ 4）客户端使用routing key，在exchange和queue之间建立好绑定关系。

（ 5）客户端投递消息到exchange。

（ 6） exchange接收到消息后，就根据消息的key和已经设置的binding，进行消息路由，将消息投递到一个或多个队列里

外部链接，参考 https://www.cnblogs.com/dwlsxj/p/RabbitMQ.html

五.环境搭建

一、前期准备

（1）条件:准备3台linux系统，确保能连到download.yunwei.edu

（2）编写yum源下载脚本：

vim yum-repo.sh

wget -O /etc/yum.repos.d/Centos7-Base-yunwei.repo download.yunwei.edu/shell/Centos7-Base-yunwei.repo

wget -O /etc/yum.repos.d/epel-yunwei.repo download.yunwei.edu/shell/epel-yunwei.repo

wget -O /etc/yum.repos.d/rdo-release-yunwei.repo download.yunwei.edu/shell/rdo-release-yunwei.repo

wget -O /etc/pki/rpm-gpg/RPM-GPG-KEY-CentOS-SIG-Cloud download.yunwei.edu/shell/RPM-GPG-KEY-CentOS-SIG-Cloud

wget -O /etc/pki/rpm-gpg/RPM-GPG-KEY-EPEL-7 download.yunwei.edu/shell/RPM-GPG-KEY-EPEL-7

（3）将系统自带网络源移走，执行yum-repo.sh

sh yum-repo.sh

（4）DNS能够解析此三台主机

二、安装过程：

（1）所有node安装rabbtimq和erlang软件包：

yum install -y erlang rabbitmq-server.noarch

systemctl enable rabbitmq-server.service

systemctl start rabbitmq-server.service

systemctl status rabbitmq-server.service

查看监听端口：

netstat -lantp | grep 5672

配置文件：

vim /etc/rabbitmq/rabbitmq.config

（2）node1：修改guest密码为admin（默认用户为：guest 密码为：guest)

rabbitmqctl change_password guest admin

（3）node1：添加一个openstack的用户，并设密码为admin。并设置权限和成为管理员

node1：

rabbitmqctl add_user openstack admin

rabbitmqctl set_permissions openstack ".*" ".*" ".*"

rabbitmqctl set_user_tags openstack administrator

（4）node1：编辑rabbittmq变量文件

vim /etc/rabbitmq/rabbitmq-env.conf

RABBITMQ_NODE_PORT=5672

ulimit -S -n 4096

RABBITMQ_SERVER_ERL_ARGS="+K true +A30 +P 1048576 -kernel inet_default_connect_options [{nodelay,true},{raw,6,18,<<5000:64/native>>}] -kernel inet_default_listen_options [{raw,6,18,<<5000:64/native>>}]"

RABBITMQ_NODE_IP_ADDRESS=172.16.254.60

（5）node1：将rabbittmq变量文件拷贝到其他两节点，之后并修改相应节点的ip

scp /etc/rabbitmq/rabbitmq-env.conf con2:/etc/rabbitmq/

scp /etc/rabbitmq/rabbitmq-env.conf con3:/etc/rabbitmq/

查看rabbitmq插件

/usr/lib/rabbitmq/bin/rabbitmq-plugins list

（6）所有node 开启rabbitmq的web管理页面

/usr/lib/rabbitmq/bin/rabbitmq-plugins enable rabbitmq_management mochiweb webmachine rabbitmq_web_dispatch amqp_client rabbitmq_management_agent

或者：rabbitmq-plugins enable rabbitmq_management

systemctl restart rabbitmq-server.service

systemctl status rabbitmq-server.service

（7）node1发送erlang.cookie到其他节点配置集群