乐趣区

RabbitMQ入门2工作原理和基本操作

组成部分:

名称 解释
Broker 消息队列服务进程, 该进程包含 2 个部分,Exchange 和 Queue
Exchange 消息队列交换机, 按一定的规则将消息路由转发到某个队列, 对消息进行过滤!
Queue 存储消息的队列, 消息到达队列并转发给消费方
Producer 消息生产者, 即生产方客户端, 生产方客户端将消息发送到 MQ
Consumer 消息消费者, 消费方客户端, 接收 MQ 转发的消息

消息发布流程:

  1. 生产者和 Broker 建立 TCP 连接
  2. 生产者和 Broker 建立通道.
  3. 生产者通过通道把消息发送给 Broker, 由 Exchange 将消息转发.
  4. Exchange 将消息发送给指定的 Queue(队列)

消息接收流程:

  1. 消费者和 Broker 建立 TCP 连接
  2. 消费者和 Broker 建立通道
  3. 消费者监听指定的 Queue
  4. 当有消息到达 Queue 时 Broker 默认将消息推给消费者
  5. 消费者接收到消息.

基本操作

后台启动 rabbitmq

rabbitmq-server -detached

查看单节点状态

rabbitmqctl status

查看日志

cat $RABBITMQ/var/log/rabbitmq/rabbit@$HOSTNAME.log

查看集群状态

rabbitmqctl cluster_status

新增用户

rabbitmqctl add_user lee lee

新增授权

rabbitmqctl set_permissions -p / lee ".*" ".*" ".*"

设置管理者权限

rabbitmqctl set_user_tags lee administrator

启动 web 管理插件

rabbitmq-plugins enable rabbitmq_management

打开 http://ip:15672/ 即可打开 web 管理界面 
退出移动版