简介
RabbitMQ 是一个实现了高级消息队列协议（AMQP）的开源消息代理中间件。俗称消息队列
基本组件
-
Connection 连接. 使用 MQ 之前需要建立连接
-
Producer 生产者
-
Consumer 消费者
-
Broker 服务器实例 管理消息和队列
-
Message 消息 由消息头和消息体组成
-
Queue 队列。消息的存放容器，先进先出
-
Exchange 交换器。分发消息，将消息路由给服务器中的队列
-
Channel 信道
-
Virtual Host 虚拟主机
官网
AMQP 客户端
The Go RabbitMQ client library
以下内容代码地址
如果对你有帮助，帮忙点个小星星 star 谢谢～
安装
docker run -it --rm --name go-rabbitmq-tutorial -p 5672:5672 -p 15672:15672 rabbitmq:3.10-management
guest/guest简单模式
一个生产者，一个队列，一个消费者。Exchange 不参与
cd hello-world
# shell1
go run send.go
# shell2
go run receive.go工作模式
Work Queue 工作队列。处理一些不需要立即执行，比较耗时的一些任务
Work Queue 会将消息分发给不同的消费者进行处理（消费者接受到的消息是不同的），消费者接受消息的数量取决于自身处理消息的速度，可以不有效的提升性能
场景：短信、邮件等提醒
cd worker-queue
# shell1
go run worker.go
# shell2
go run new_task.go
# 或者 开多个终端
# shell1
go run worker.go
# shell2
go run worker.go
#shell3
go run new_task.go发布订阅
Publist/Subscribe 发布订阅
生产者产生一条消息，将消息发送给交换器，交换器将消息推送给所有的消费者。消费者接受到的消息是相同的。
场景：开放平台 开发者订阅了某个开放平台的 api 之后，数据有变化就会自动获取到最新的数据
cd publish-subscribe
# shell1
# 如果你想保存日志文件
go run receive_log.go > logs_from_rabbit.log
# 如果你想再终端看到日志
go run receive_log.go
# shell2
go run emit_log.go
路由模式
Routing
其实就是发布订阅模式的升级版。将不同消息通过路由 key 进行绑定，进入不同的队列，每个队列的处理不同的业务逻辑
场景：日志系统 重要的日志，有专门的队列消费处理
cd publish-subscribe
# shell1
# 如果你想保存日志文件
go run receive_logs_direct.go warning error > logs_from_rabbit.log
# 如果你想再终端看到日志
go run receive_logs_direct.go info warning error
# shell2
go run emit_log_direct.go error "Run. Run. Or it will explode."主题订阅模式
Topics
在路由模式的基础上增加了通配符。可以惊醒 Routing ket 的模糊匹配，使得消息的分发更加灵活
但是模糊匹配相对于路由模式来讲，效率可能比较低，实际中尽量采用路由模式
通配符‘’‘#’: 单个关键字 #: 多个关键字
cd topics
# shell1
go run receive_logs_topic.go "#"
# shell2
go run receive_logs_topic.go "kern.*"
# shell3
go run receive_logs_topic.go "*.critical"
# shell4
go run receive_logs_topic.go "kern.*" "*.critical"
# shell5
go run emit_log_topic.go "kern.critical" "A critical kernel error"
RPC 同步通信
MQ 是一个异步通信的，也就是生产者发送消息之后，是不知道消费者的处理结果的（成功、失败、甚至都不知道消费者有没有处理这条消息）。
有些时候，在开发中，生产者是需要知道消费者的处理结果，然后再进行下一步任务的处理。也就是同步调用。相当于 RPC（Remote Procedure Call 远程过程调用）
如下图所示，实际上有两个队列，client 产生了消息之后，将消息放入队列，server 端开始进行消费，消费后的结果也放入一个队列，被 client 处理. 整个过程，是一个线程阻塞的状态。影响性能，适用于特殊的业务场景需求。
cd rpc
# shell1
go run rpc_server.go
# shell2
go run rpc_client.go 40问题
- 1 go 连接 RabbitMQ "no access to this vhost" 错误
docker exit -it container_name /bin/sh rabbitmqctl add_vhost admin rabbitmqctl set_permissions -p 用户名 admin "." "." ".*"连接的时候指定对应的 vhost
amqp091.Dial("amqp://username:password@ip:5672/admin”)
