RabbitMQ 基础使用教程之一

相关站点

RabbitMQ 基础概念

AMQP(Advanced Message Queuing Protocol)高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然。AMQP 的主要特征是面向消息、队列、路由(包括点对点和发布 / 订阅)、可靠性、安全。RabbitMQ 是一个开源的 AMQP 标准实现,服务器端用 Erlang 语言编写,支持多种客户端,如:Python、Ruby、C#、Java、PHP、GO、JavaScript 等。RabbitMQ 用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性、灵活的路由、集群、事务、高可用的队列、消息排序、问题追踪、可视化管理工具、插件系统等方面表现不俗。

RabbitMQ 的用户角色分类

  • 超级管理员 (administrator),可登陆管理控制台,可查看所有的信息,并且可以对用户,策略 (policy) 进行操作
  • 监控者 (monitoring),可登陆管理控制台,同时可以查看 rabbitmq 节点的相关信息 (进程数,内存使用情况,磁盘使用情况等)
  • 策略制定者 (policymaker),可登陆管理控制台,同时可以对 policy 进行管理。但无法查看节点的相关信息,与 administrator 的对比,administrator 能看到节点信息
  • 普通管理者 (management),仅可登陆管理控制台,无法看到节点信息,也无法对策略进行管理
  • 其他,无法登陆管理控制台,通常就是普通的生产者和消费者

RabbitMQ 用户与角色管理

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
# 创建超级管理员用户
# rabbitmqctl add_user user_admin your_password

# 赋予administrator角色给超级管理员用户
# rabbitmqctl set_user_tags user_admin administrator

# 创建监控用户
# rabbitmqctl add_user user_monitoring your_password

# 赋予monitoring角色给监控用户
# rabbitmqctl set_user_tags user_monitoring monitoring

# 创建某个项目的专用用户,限制只能访问自己项目的virtual hosts
# rabbitmqctl add_user user_proj your_password

# 赋予management给某个项目的专用用户
# rabbitmqctl set_user_tags user_proj management

# 查看用户与角色列表
# rabbitmqctl list_users

# 删除用户
# rabbitmqctl delete_user user_admin

# 修改用户密码
# rabbitmqctl change_password user_admin your_password

RabbitMQ 虚拟主机管理

对 RabbitMQ 的用户角色权限进行管理时,可以将 RabbitMQ 理解为普通的数据库,其中 VHostPath 可以类比为数据库名,用户角色权限则是对指定数据库的限制访问。

1
2
3
4
5
6
7
8
# 创建虚拟主机
# rabbitmqctl add_vhost vhostpath

# 删除虚拟主机
# rabbitmqctl delete_vhost vhostpath

# 列出所有虚拟主机
# rabbitmqctl list_vhosts

RabbitMQ 用户权限管理

用户权限指的是用户对其所能访问的 VHostPath 的 exchange,queue 的操作权限,包括配置权限,读写权限。配置权限会影响到 exchange,queue 的声明和删除;读写权限影响到从 queue 里取消息,向 exchange 发送消息以及 queue 和 exchange 的绑定 (bind) 操作。例如: 将 queue 绑定到某 exchange 上,需要具有 queue 的可写权限,以及 exchange 的可读权限;向 exchange 发送消息需要具有 exchange 的可写权限;从 queue 里取数据需要具有 queue 的可读权限。详细请参考官方文档中 “How permissions work” 部分。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
# 赋予用户权限
# rabbitmqctl set_permissions -p VHostPath user_admin ConfP WriteP ReadP

# 赋予用户所有权限
# rabbitmqctl set_permissions -p VHostPath user_admin '.*' '.*' '.*'

# 查看VHostPath下所有用户的权限
# rabbitmqctl list_permissions -p VHostPath

# 查看指定用户的权限
# rabbitmqctl list_user_permissions user_admin

# 清除指定用户在指定VHostPath下的权限
# rabbitmqctl clear_permissions -p VHostPath user_admin

# 清除指定用户的所有权限
# rabbitmqctl clear_permissions user_admin

RabbitMQ 常用命令

1
2
3
4
5
6
7
8
9
10
11
# 列出所有队列
# rabbitmqctl list_queues

# 列出指定队列的信息
# rabbitmqctl list_queues queue_name messages_ready messages_unacknowledged

# 列出所有交换机
# rabbitmqctl list_exchanges

# 列出所有绑定
# rabbitmqctl list_bindings

RabbitMQ Simple Queue 模式(简单队列)

简单队列模式下,每条消息只会被一个消费者所接收,不存在多个消费者接收到同一条消息的情况,而且不管有多少个消费者,默认情况下服务端都会以轮询分发(round-robin)的方式确保每个消费者接收到的消息数量是一样的。
rabbitmq-sample

RabbitMQ Work Queue 模式(工作队列)

工作队列模式下,每条消息只会被一个消费者所接收,不存在多个消费者接收到同一条消息的情况;同时工作队列模式可以使用公平分发(fair dispatch)的方式来发送消息,特点是处理能力强的消费者可以接收到更多的消息(能者多劳),这也是与简单队列模式相比较不同的地方。当使用公平分发时,消费者可调用 basicQos()方法,同时需要手动确认消息(ACK 机制)。
rabbitmq-work-queue

RabbitMQ Fanout 模式(发布 / 订阅)

单个生产者可以对应多个消费者,每个消费者都有自己的队列,同一条消息可以被多个消费者接收。所有发送到 Fanout Exchange 的消息都会被转发到与该 Exchange 绑定 (Binding) 的所有 Queue 上。Fanout Exchange 不需要额外处理 RouteKey,只需要简单地将队列绑定到 Exchange 上,这样发送到 Exchange 的消息都会被转发到与该交换机绑定的所有队列上,作用类似子网广播,每台子网内的主机都获得了一份复制的消息,因此 Fanout Exchange 转发消息是最快的。
rabbitmq-fanout-exchang-1 rabbitmq-fanout-exchang-2

RabbitMQ Direct 模式(路由)

单个生产者可以对应多个消费者,每个消费者都有自己的队列,同一条消息可以被多个消费者接收。所有发送到 Direct Exchange 的消息会被转发到 RouteKey 中指定的 Queue 上。消息传递时,RouteKey 必须完全匹配,才会被队列接收,否则该消息会被抛弃。
rabbitmq-direct-exchang-1 rabbitmq-direct-exchange-2

RabbitMQ Topic 模式(通配符)

单个生产者可以对应多个消费者,每个消费者都有自己的队列,同一条消息可以被多个消费者接收。所有发送到 Topic Exchange 的消息会被转发到指定 Topic 的 Queue 上,Exchange 会将 RouteKey 和某个 Topic 进行模糊匹配,此时队列需要绑定一个 Topic。RouteKey 可以使用通配符进行模糊匹配,符号”#” 表示匹配一个或多个词,符号”*” 表示匹配不多不少一个词。因此”log.#” 能够匹配到”log.info.oa”,但是”log.*” 只会匹配到”log.error”,所以 Topic Exchange 的使用非常灵活。
rabbitmq-topic-exchange-1 rabbitmq-topic-exchange-2