消息队列：是一种应用程序对应用程序的通信方法，应用程序通过读取和写入队列的消息来通信。
消息传递指的是程序之间通过消息中发送的数据进行通信，而不是通过直接的调用彼此来通信，排队是指应用程序通过队列来通信。
高级消息队列协议AMQP ，是应用层协议，为面向消息的中间件设计，消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在。
消息中间件： rabbitmq
概念名词：
broker：简单来说就是消息队列服务器实体
exchange：消息交换机，他指定消息按什么规则，路由到那个队列
queue： 消息载体，每个消息都会被投放到一个或多个队列。
binding：绑定，他的作用就是将exchange 和queue按照路由规则绑定
routing key：路由关键字，exchange根据这个关键字进行消息投递
vhost：虚拟主机，一个broker里面可以设多个vhost，用作不同用户的权限分离
producer：消息生产者
consumer： 消息消费者
channel： 消息通道，在客户端的每个连接里，可以建立多个channel，每个channel代表一个会话任务
流程：
1 客户端连接到消息队列服务器，打开一个channel，
2 客户端声明一个exchange，并设置相关属性
3 客户端声明一个queue，并设置相关属性
4 客户端使用routing key ，在exchange 和queue之间建立绑定关系
5 客户端投递消息到exchange
6 exchange 收到消息后根据key和已经设定好的binding，进行消息路由，将消息投递到一个或多各队列中
rabbitmq的metadate
元数据可以持久化在 RAM 或 Disc. 从这个角度可以把 RabbitMQ 集群中的节点分成两种 :RAM Node和 Disk Node.
RAM Node 只会将元数据存放在RAM
Disk node 会将元数据持久化到磁盘。
单节点系统就没有什么选择了 , 只允许 disk node, 否则由于没有数据冗余一旦重启就会丢掉所有的配置信息 . 但在集群环境中可以选择哪些节点是 RAM node.在集群中声明(declare) 创建 exchange queue binding, 这类操作要等到所有的节点都完成创建才会返回 :
如果是内存节点就要修改内存数据 ,
如果是 disk node 就要等待写磁盘 , 节点过多这里的速度就会被大大的拖慢 .
有些场景 exchang queue 相当固定 , 变动很少 ,那即使全都是 disc node, 也没有什么影响 . 如果使用 Rabbitmq 做 RPC（ RPC :Remote Procedure Call—远程过程调用）, RPC 或者类似 RPC 的场景这个问题就严重了 , 频繁创建销毁临时队列 , 磁盘读写能力就很快成为性能瓶颈了。所以 , 大多数情况下 , 我们尽量把 Node 创建为RAM Node. 这里就有一个问题了 , 要想集群重启后元数据可以恢复就需要把集群元数据持久化到磁盘 , 那需要规划 RabbitMQ 集群中的 RAM Node 和 Disc Node 。
只要有一个节点是 Disc Node 就能提供条件把集群元数据写到磁盘 ,RabbitMQ 的确也是这样要求的 : 集群中只要有一个 disk node 就可以 , 其它的都可以是 RAM node. 节点加入或退出集群一定至少要通知集群中的一个 disk node 。
如果集群中 disk node 都宕掉 , 就不要变动集群的元数据 . 声明 exchange queue 修改用户权限 , 添加用户等等这些变动在节点重启之后无法恢复 。
有一种情况要求所有的 disk node 都要在线情况在才能操作 , 那就是增加或者移除节点 .RAM node 启动的时候会连接到预设的 disk node 下载最新的集群元数据 . 如果你有两个 disk node(d1 d2), 一个 RAM node 加入的时候你只告诉 d1, 而恰好这个 RAM node 重启的时候 d1 并没有启动 , 重启就会失败 . 所以加入 RAM 节点的时候 , 把所有的disk node 信息都告诉它 ,RAM node 会把 disk node 的信息持久化到磁盘以便后续启动可以按图索骥 .
部署步骤：
1 前置条件
准备三台机器， 配置好epel源
修改主机名
编辑hosts ，进行域名解析
关闭防火墙， selinux 设置
systemctl stop firewalld.service
systemctl disable firewalld.service
主机之间设置免密登录
# ssh-keygen
# ssh-copy-id node2
2安装组件包
将所有主机安装rabbitmq和erlang
# yum install erlang rabbitmq-server.noarch -y
启动服务
systemctl start rabbitmq-server.service
systemctl enable rabbitmq-server.service
node1：修改guest密码为admin（默认用户为：guest 密码为：guest)
rabbitmqctl change_password guest admin
node1：添加一个openstack的用户，并设密码为admin。并设置权限和成为管理员
[root@node1 ~]# rabbitmqctl add_user openstack admin
rabbitmqctl set_permissions openstack ".*" ".*" ".*"
rabbitmqctl set_user_tags openstack administrator
3 将三个节点加入到一个集群中
编辑node1节点变量文件
vim /etc/rabbitmq/rabbitmq-env.config
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.234.148
将rabbittmq变量文件拷贝到其他两节点，之后并修改相应节点的ip
scp /etc/rabbitmq/rabbitmq-env.config node2:/etc/rabbitmq/
scp /etc/rabbitmq/rabbitmq-env.config node3:/etc/rabbitmq/
2 查看rabbitmq插件
/usr/lib/rabbitmq/bin/rabbitmq-plugins list 3 在所有节点开启web节点 /usr/lib/rabbitmq/bin/rabbitmq-plugins enable rabbitmq_management mochiweb webmachine rabbitmq_web_dispatch amqp_client rabbitmq_management_agent 4 各节点重启服务 systemctl restart rabbitmq-server.service 5 node1发送erlang.cookie到其他节点配置集群 scp /var/lib/rabbitmq/.erlang.cookie node2:/var/lib/rabbitmq/.erlang.cookiescp /var/lib/rabbitmq/.erlang.cookie node3:/var/lib/rabbitmq/.erlang.cookie
6 node2和node3停止应用，并以ram的方式加入node1节点，之后重启应用
[root@node3 ~]# systemctl restart rabbitmq-server.service [root@node3 ~]# rabbitmqctl stop_app Stopping node rabbit@node3 ... ...done. [root@node3 ~]# rabbitmqctl join_cluster --ram rabbit@node1 Clustering node rabbit@node3 with rabbit@node1 ... ...done. [root@node3 ~]# rabbitmqctl start_app Starting node rabbit@node3 ... ...done.
7 node1检查集群状态
[root@node1 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@node1 ...
[{nodes,[{disc,[rabbit@node1]},{ram,[rabbit@node3,rabbit@node2]}]},
{running_nodes,[rabbit@node3,rabbit@node2,rabbit@node1]},
{cluster_name,<<"rabbit@node1">>},
{partitions,[]}]
...done.
8 web页面登录
其他命令： （1）添加管理员： rabbitmqctl add_user mqadmin mqadmin rabbitmqctl set_user_tags mqadmin administrator rabbitmqctl set_permissions -p / mqadmin ".*" ".*" ".*" （2）更改节点类型（内存型或磁盘型） rabbitmqctl stop_app rabbitmqctl change_cluster_node_type disc 或 rabbitmqctl change_cluster_node_type ram rabbitmqctl start_app （3）从集群移除节点（或者重置节点） rabbitmqctl stop_app rabbitmqctl reset rabbitmqctl start_app rabbitmqctl cluster_status （4）从某个节点移除集群中其他节点 rabbitmqctl forget_cluster_node rabbit@node3 rabbitmqctl reset rabbitmqctl start_app rabbitmqctl cluster_status 1. 保证集群中至少有一个磁盘类型的节点以防数据丢失，在更改节点类型时尤其要注意。 2. 若整个集群被停掉了，应保证最后一个 down 掉的节点被最先启动，若不能则要使用 forget_cluster_node 命令将其移出集群 3. 若集群中节点几乎同时以不可控的方式 down 了此时在其中一个节点使用 force_boot 命令重启节点
搜索
复制
<iframe></iframe> 标签：node,rabbitmq,rabbitmqctl,集群,node1,openstack,节点 From： https://www.cnblogs.com/huxl1/p/16717481.html