首页 > 代码库 > rabbitmq普通使用

rabbitmq普通使用

rabbitmq是一种消息队列服务,可以实现rpc,一般情况下openstack的rpc用的就是用它做的,它有很多的用途。除了Qpid以外它是唯一实现了AMQP标准的代理服务器


1.安装
安装rabbitmq是一件十分容易的事情,在yum源正常的情况下直接即可
yum install rabbitmq-server -y


2.信道
当你连接rmq后,你的应用程序与rmq服务器之间就会创建一条TCP连接,当你通过认证打开TCP连接后就会创建一条AMQP信道,这条信道是创建在真实TCP连接内的虚拟连接,当很多人对此rmq服务器进行连接使用时,这条TCP连接内就会有很多条信道。
主要原因是因为对于操作系统来说创建销毁一条TCP连接是很昂贵的!并且使用TCP连接的话很快就会达到因为根据需求所设置的调度线程数,很快就会遇到瓶颈!(在一条TCP连接内创建多少信道是没有限制的)


3.basic.consume与basic.get(知道即可)
basic.consume会让消费者一直从队列中获取消息,比如消费者消费(拒绝)最近消费的消息后就可以自动从队列中拿下一条
basic.get则是仅仅只获取单条消息,下一条不会再拿了,需要不断的再次执行basic.get,明显这种方式对性能有影响
正常情况下消费者理应使用basic.consume来提升吞吐量


4.交换器
headers允许你匹配消息的头部而不是你设置的路由规则,剩下的与direct完全一致,但是性能上会差很多,这种不实用,现在几乎已经没有在用了
direct很简单是一种完全根据路规则进行匹配投递的交换器
fanout是一种完全发布的交换器,当有一条消息进来后它会直接将其发布到绑定到fanout交换器的所有队列内
topic是一种模糊匹配的交换器,可以理解成对direct交换器匹配了正则后进行发布


5.vhost
rmq服务器都可以创建虚拟消息服务器,它是一个mini的rmq服务器,内部拥有着自己的队列交换机以及绑定,这样多租户之间就没有影响了
rabbitmqctl list_vhosts # 列出所有vhosts
rabbitmqctl add_vhost v1 # 创建一个v1的vhosts
rabbitmqctl delete_vhost v1 # 删除v1


6.基本操作
systemctl start rabbitmq-server # 开启rmq服务
systemctl stop rabbitmq-server # 关闭rmq服务
rabbitmqctl start_app # 开启内部vhost
rabbitmqctl stop_app # 关闭内部vhost,服务不会关闭
rabbitmqctl add_user bfmq miao # 创建一个bfmq用户,密码是miao
rabbitmqctl delete_user bfmq # 删除bfmq用户
rabbitmqctl list_users # 列出所有用户
rabbitmqctl change_password bmfq meng # 把bfmq用户的密码改成meng
rabbitmqctl list_queues -p v1 # 列出v1内所有队列
rabbitmqctl list_queues -p v1 name messages consumers memory # 列出v1内所有队列的名字,内部消息数目,消费者数目,内存使用
rabbitmqctl list_exchanges -p v1 列出v1内所有交换器,出来你自己创建的交换器以外,会有amq.topic、amq.fanout、amq.match、amq.headers、amq.direct这几个默认自动生命的交换器以及在列出所有条目的底部有一个direct类型没有名字的交换器(匿名交换器,所有的队列默认都会把绑定到此交换器)
rabbitmqctl list_queues -p v1 name type durable auto_delete # 列出v1内所有交换器的名字,类型,是否可持久化,是否自动删除


7.权限关系
用户对vhost的控制
读:有关消费消息的任何操作(可清空队列)
写:发布消息
配置:队列及交换机的创建删除

rabbitmqctl set_permissions -p v1 bfmq ".*" ".*" ".*" # 以前设置过再次执行即为修改成新设置的权限
-p v1:这条权限设置是给与哪个vhost,如果不填写则是默认/,即对/ vhost进行了权限设置
bfmq:被授予权限的用户
".*" ".*" ".*":授予的权限。顺序是配置,写,读

".*"代表所有权限
“”代表无此权限
“*a*”代表内部名字含有a的所有队列及交换机
rabbitmqctl set_permissions -p v2 bfmq "" "*a*" ".*" 给与bfmq在v2内对所有队列及交换机读权限,名字内包含a的队列及交换机写权限,对内部所有队列及交换机都无配置权限

rabbitmqctl list_permissions -p v1 # 查看对v1 vhost里所有权限,如果不填写则是对/ vhost进行查看
rabbitmqctl clear_permissions -p v1 bfmq # 清空bfmq在v1上的权限设置
rabbitmqctl list_user_permissions bfmq # 查看bfmq用户的所有权限


8.集群
通过更改port在同一台机器上搭建集群(当然正经来说肯定是不同的物理机了),默认端口5672,我们用5672,5673,5674来模拟
RABBITMQ_NODE_PORT=5672 RABBITMQ_NODENAME=rabbitmq_1 /sbin/rabbitmq-server -detached # -detached是让在后台运行
RABBITMQ_NODE_PORT=5673 RABBITMQ_NODENAME=rabbitmq_2 /sbin/rabbitmq-server -detached
RABBITMQ_NODE_PORT=5674 RABBITMQ_NODENAME=rabbitmq_3 /sbin/rabbitmq-server -detached
rabbitmq_1作为第一个节点无需操作,但是rabbitmq_2与rabbitmq_3在加入集群前需要清空他们上面的元数据,首先需要停止erlang程序
rabbitmqctl -n rabbitmq_2@bfmq stop_app # rabbitmq_2@bfmq,bfmq是我的主机名
rabbitmqctl -n rabbitmq_3@bfmq stop_app
rabbitmqctl -n rabbitmq_2@bfmq reset
rabbitmqctl -n rabbitmq_3@bfmq reset

组建集群
rabbitmqctl -n rabbitmq_2@bfmq join_cluster rabbitmq_1@bfmq # 把rabbitmq_2@bfmq加入到rabbitmq_1@bfmq集群内
rabbitmqctl cluster_status -n rabbitmq_1@bfmq # 查看rabbitmq_1@bfmq集群信息
rabbitmqctl cluster_status -n rabbitmq_1@bfmq出现下列信息
Cluster status of node rabbitmq_1@bfmq ...
[{nodes,[{disc,[rabbitmq_1@bfmq,rabbitmq_2@bfmq]}]},
{running_nodes,[rabbitmq_1@bfmq]},
{cluster_name,<<"rabbitmq_1@bfmq">>},
{partitions,[]},
{alarms,[{rabbitmq_1@bfmq,[]}]}]
我们看到running_nodes只有rabbitmq_1@bfmq一个,刚才加入的rabbitmq_2@bfmq没有运行,因为我们刚才stop_app了,现在启动它再查看信息

rabbitmqctl -n rabbitmq_2@bfmq start_app && rabbitmqctl cluster_status -n rabbitmq_1@bfmq
Cluster status of node rabbitmq_1@bfmq ...
[{nodes,[{disc,[rabbitmq_1@bfmq,rabbitmq_2@bfmq]}]},
{running_nodes,[rabbitmq_2@bfmq,rabbitmq_1@bfmq]},
{cluster_name,<<"rabbitmq_1@bfmq">>},
{partitions,[]},
{alarms,[{rabbitmq_2@bfmq,[]},{rabbitmq_1@bfmq,[]}]}]
好了现在rabbitmq_2@bfmq也在running_nodes里了,我们再将rabbitmq_3@bfmq也加进来并且启动然后查看信息

rabbitmqctl -n rabbitmq_3@bfmq join_cluster rabbitmq_1@bfmq --ram && rabbitmqctl -n rabbitmq_3@bfmq start_app && rabbitmqctl cluster_status -n rabbitmq_1@bfmq # --ram是让此节点以内存节点加入,rmq集群内至少需要2个磁盘节点
Cluster status of node rabbitmq_1@bfmq ...
[{nodes,[{disc,[rabbitmq_1@bfmq,rabbitmq_2@bfmq]},{ram,[rabbitmq_3@bfmq]}]},
{running_nodes,[rabbitmq_3@bfmq,rabbitmq_2@bfmq,rabbitmq_1@bfmq]},
{cluster_name,<<"rabbitmq_1@bfmq">>},
{partitions,[]},
{alarms,[{rabbitmq_3@bfmq,[]},{rabbitmq_2@bfmq,[]},{rabbitmq_1@bfmq,[]}]}]
我们看到rabbitmq_1@bfmq,rabbitmq_2@bfmq是disc而rabbitmq_3@bfmq是ram正是我们所设置的

离开集群
rabbitmqctl -n rabbitmq_3@bfmq stop_app
rabbitmqctl -n rabbitmq_3@bfmq reset # reset会直接清空节点的状态,因此原本在集群内的状态也会被清掉
rabbitmqctl -n rabbitmq_3@bfmq start_app # 此时rabbitmq_3@bfmq就已经是一个独立节点了
rabbitmqctl cluster_status -n rabbitmq_1@bfmq
Cluster status of node rabbitmq_1@bfmq ...
[{nodes,[{disc,[rabbitmq_1@bfmq,rabbitmq_2@bfmq]}]},
{running_nodes,[rabbitmq_2@bfmq,rabbitmq_1@bfmq]},
{cluster_name,<<"rabbitmq_1@bfmq">>},
{partitions,[]},
{alarms,[{rabbitmq_2@bfmq,[]},{rabbitmq_1@bfmq,[]}]}]

不同机器上搭建集群,那就不需要调整端口号了,我以1.1.1.1、10.10.10.10、100.100.100.100为例子直接写一遍流程
3台机子上操作systemctl start rabbitmq-server
将1.1.1.1内的/var/lib/rabbitmq/.erlang.cookie复制覆盖到10.10.10.10、100.100.100.100的/var/lib/rabbitmq/.erlang.cookie
10.10.10.10、100.100.100.100操作
systemctl restart rabbitmq-server
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbitmq@1.1.1.1 && rabbitmqctl start_app
如果写好了hosts文件就可以把ip用主机名替换掉,其实就是把@后主机名变更下以及把erlang.cookie统一


9.升级
独立节点升级很容易,只需要解压新版包后直接运行即可。
集群则不可以!这样做会清除掉集群的相关配置及数据,你需要使用RabbitMQ Management插件备份当前配置,然后关闭所有生产者并且等待消费者消费完所有消息后关闭节点,解压新版本包到现有的安装目录,选用其中一个磁盘节点作为升级节点,当它运行时,该节点会把持久化的集群数据升级到新版本,然后启动其他磁盘节点,他们会获取数据自动升级,最后再打开内存节点,升级完毕。

rabbitmq普通使用