共计 723 个字符，预计需要花费 2 分钟才能阅读完成。
组成部分:
| 名称 | 解释 |
|---|---|
| Broker | 消息队列服务进程, 该进程包含 2 个部分,Exchange 和 Queue |
| Exchange | 消息队列交换机, 按一定的规则将消息路由转发到某个队列, 对消息进行过滤! |
| Queue | 存储消息的队列, 消息到达队列并转发给消费方 |
| Producer | 消息生产者, 即生产方客户端, 生产方客户端将消息发送到 MQ |
| Consumer | 消息消费者, 消费方客户端, 接收 MQ 转发的消息 |
消息发布流程:
- 生产者和 Broker 建立 TCP 连接
- 生产者和 Broker 建立通道.
- 生产者通过通道把消息发送给 Broker, 由 Exchange 将消息转发.
- Exchange 将消息发送给指定的 Queue(队列)
消息接收流程:
- 消费者和 Broker 建立 TCP 连接
- 消费者和 Broker 建立通道
- 消费者监听指定的 Queue
- 当有消息到达 Queue 时 Broker 默认将消息推给消费者
- 消费者接收到消息.
基本操作
后台启动 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 管理界面 正文完