RabbitMQ入门

RabbitMQ 是一个基于 ​​AMQP 协议​​ 的开源消息队列，用于实现系统间的 ​​异步通信​​、​​解耦​​ 和 ​​流量削峰​​。

同步和异步

什么时候时候用同步调用

下一步的操作必须要依赖上一步的操作执行的结果，比如说扣款，扣完款必须要知道是否扣款成功，没扣款成功肯定是不能走下一步；还有查询，必须要查询到东西才能走下一步。能立刻得到响应结果。需要阻塞等待

同步调用的问题

拓展性差，性能下降，级联失败（链路上一个点掉了，整个链全阻塞）

异步调用

异步调用实际上就是基于消息通知。

消息发送者：投递消息的人，就是原来的调用方

消息代理：管理、暂存、转发消息，你可以把它理解成微信服务器

消息接收者：接收和处理消息的人，就是原来的服务提供方。监听消息代理即可

优点：

缺点：

消息队列无法拿到接收者的消息，接收者执行的怎么样了，完全不知道

不能立刻得到调用结果，时效性差。不确定下游应用是否执行成功。业务安全性依赖于消息代理，如果消息代理挂了，后面业务全都挂

什么时候用异步调用

对后面业务的返回结果不关心，调用链太长的情况

---

rabbitMQ快速入门

交换机是路由转发消息的，本身没有存储消息的能力

交换机必须和队列有绑定，才能将消息转发至队列，队列存储消息，在适时发送给消费者

怎么实现数据隔离

可以自己定义添加virtualHost。不同的虚拟主机就可以实现数据隔离。

也可以创建不同用户，管理不同的虚拟主机，用户权限也可以自定义，不能操作别人的虚拟主机

所以应该给每一个项目创建一个用户，一个虚拟主机。

---

java怎么操作rabbitMQ

官方的api太复杂了，我们使用springAMQP（基础抽象）

发消息
引入依赖--编写yml文件（配置rabbitMQ主机、端口、用户名、密码等）--使用RabbitTemplate工具类就可以放松消息--接收消息，在方法上加@RabbitListener(指定队列名)，方法参数直接接收。

发送者和消费者都要配置yml文件（配置rabbitMQ主机、端口、用户名、密码等）。