交换机
交换机 定义交换机:向 2 个队列同时发生消息 前面我们发送消息的时候,我们传的exchange都是空,所以它是直接使用的默认的AMQP default默认的交换机。 Direct Exchange:直接模式交换机。交换机和一个队列绑定起来,并指定一个路由键,交换机会寻找匹配的路由键的绑定,并将消息路由给对应的队列。 我们把前面的发送消息的修改一下代码 然后

wxvirus2023年1月7日
大约 3 分钟
简单生产消息和消费消息
简单生产消息和消费消息 生产者发送消息 我这里发送了 2 次,这里的idle表示空闲状态,Total有 2 个消息,队列名为test 消费者读取消息 将连接 MQ 的代码进行封装一下 此时 MQ 中是Unacked,这个是确认机制,我们获取消息后,我们需要告诉 MQ 消息收到了,否则下次运行,Ready又会变成 2 个,还能继续收到这个消息。 https:/

wxvirus2023年1月7日
大约 2 分钟
快速部署以及使用Go客户端
快速使用 docker 部署单机 RabbitMQ、Go 客户端 使用 docker 部署 docker镜像地址:https://hub.docker.com/\_/rabbitmq 通常带有:DOCKER OFFICIAL IMAGE的都代表是对应的官方镜像 management代表是有带管理后台的。 最新版 启动容器 15672 是管理端的端口; 注意

wxvirus2023年1月7日
大约 2 分钟
RabbitMQ 了解
RabbitMQ 了解 为啥要用 MQ 如果项目就几万条数据。1-2 百并发,就增删改查业务 那么,就不需要 MQ 案例 解耦 + 异步 假设有一个用户注册需要以下流程 1. 用户数据入库 2. 发送新人欢迎邮件 3. 赠送新人虚拟币【或积分】 其实只要入库成功就算成功了,下面 2 步完全不需要去等待,如果有 MQ 就可以完成异步。 " 本质上其实入库完就算

wxvirus2023年1月7日
大约 2 分钟