MQ基础（异步通信）

文章目录day06-MQ基础 学习总结一、同步调用 vs 异步调用1. 同步调用OpenFeign2. 异步调用MQ二、RabbitMQ基础1. 核心概念2. 安装与端口3. 数据隔离三、SpringAMQP1. 功能介绍2. 工作模式2.1 简单队列2.2 Work Queue任务模型2.3 Fanout广播2.4 Direct路由2.5 Topic通配符3. 声明队列和交换机3.1 基于Bean3.2 基于注解推荐4. 消息转换器四、业务改造案例支付成功异步通知五、今日核心知识点MQ基础 校招面试常问问题总结一、基础概念类1. 同步调用和异步调用的区别2. 什么场景用异步调用3. 消息队列有什么好处二、RabbitMQ基础类4. RabbitMQ的核心概念有哪些5. 交换机的类型有哪些区别是什么6. Virtual Host的作用三、SpringAMQP使用类7. 怎么用Spring发送消息8. 怎么用Spring接收消息9. Work Queue模式中prefetch的作用10. 怎么声明队列和交换机四、消息转换器类11. 消息序列化方式有哪些12. 怎么改成JSON五、项目实践类13. 你们项目哪里用了MQ举例说明14. 改造同步调用为异步的步骤15. MQ消息丢了怎么办六、常见坑点16. 消息没被消费17. 消息重复消费18. 消费者处理失败七、校招微服务考察重点排序MQ篇day06-MQ基础 学习总结一、同步调用 vs 异步调用1. 同步调用OpenFeign特点调用方阻塞等待实时得到响应类比视频通话缺点拓展性差新增需求需要修改原代码性能下降总耗时 各服务耗时之和级联失败一个服务故障导致整个事务回滚2. 异步调用MQ特点调用方发送消息后立即返回不等待响应类比微信聊天优点耦合度低性能更好拓展性强故障隔离缺点依赖Broker可靠性、架构复杂二、RabbitMQ基础1. 核心概念概念作用Publisher消息生产者发送消息的一方Consumer消息消费者接收处理消息的一方Queue队列存储消息Exchange交换机负责消息路由Virtual Host虚拟主机数据隔离2. 安装与端口15672管理控制台5672消息收发接口3. 数据隔离创建独立用户创建独立Virtual Host不同项目数据隔离三、SpringAMQP1. 功能介绍自动声明队列、交换机、绑定关系基于注解的监听器模式封装RabbitTemplate发送消息2. 工作模式2.1 简单队列生产者直接发送到队列消费者监听队列适用测试场景2.2 Work Queue任务模型多个消费者绑定同一队列一条消息只被一个消费者处理能者多劳配置prefetch1按处理能力分配消息2.3 Fanout广播交换机将消息发给所有绑定队列适用群发消息2.4 Direct路由基于RoutingKey精确匹配队列绑定指定key适用定向消息2.5 Topic通配符RoutingKey用.分隔单词通配符#0或多个词、*1个词适用模糊匹配路由3. 声明队列和交换机3.1 基于Bean手动创建Queue、Exchange、Binding3.2 基于注解推荐RabbitListener(bindingsQueueBinding(valueQueue(namequeue.name),exchangeExchange(nameexchange.name,typeExchangeTypes.DIRECT),keyrouting.key))4. 消息转换器默认JDK序列化体积大、可读性差、有漏洞推荐JSON转换器引入Jackson依赖配置MessageConverter为Jackson2JsonMessageConverter四、业务改造案例支付成功异步通知改造前支付服务同步调用交易服务更新订单状态改造后支付服务发送消息到pay.direct交换机routingKeypay.success交易服务监听trade.pay.success.queue队列收到消息后更新订单状态五、今日核心知识点模块技术点作用概念同步/异步调用理解两种通信方式的区别MQRabbitMQ消息中间件MQExchange类型Fanout、Direct、TopicSpringAMQPRabbitTemplate发送消息SpringAMQPRabbitListener接收消息SpringAMQP消息转换器JSON序列化实践支付异步通知改造同步调用为异步MQ基础 校招面试常问问题总结一、基础概念类1. 同步调用和异步调用的区别问说说同步通信和异步通信的区别各自优缺点答同步阻塞等待实时响应但性能差、耦合高异步非阻塞性能好、解耦但架构复杂、有延迟2. 什么场景用异步调用问你们项目中哪些业务用了异步答支付成功后通知交易服务、下单后清理购物车、短信通知等不需要实时响应的场景3. 消息队列有什么好处问为什么要引入MQ答解耦、异步提速、削峰填谷、故障隔离二、RabbitMQ基础类4. RabbitMQ的核心概念有哪些问RabbitMQ中的Queue、Exchange、Binding是什么答Queue存储消息Exchange路由消息Binding绑定队列到交换机指定路由规则5. 交换机的类型有哪些区别是什么问Fanout、Direct、Topic三种交换机有什么区别答Fanout广播给所有队列Direct精确匹配RoutingKeyTopic通配符匹配RoutingKey6. Virtual Host的作用问RabbitMQ中Virtual Host是做什么的答数据隔离不同项目用不同vhost避免相互干扰三、SpringAMQP使用类7. 怎么用Spring发送消息问SpringAMQP中如何发送消息答注入RabbitTemplate调用convertAndSend方法8. 怎么用Spring接收消息问如何监听队列消费消息答RabbitListener注解指定队列名称9. Work Queue模式中prefetch的作用问prefetch1是什么意思答每次只取一条消息处理完才能取下一条实现能者多劳10. 怎么声明队列和交换机问你们项目中队列和交换机是怎么创建的答两种方式Bean手动创建或RabbitListener注解声明推荐四、消息转换器类11. 消息序列化方式有哪些问SpringAMQP默认用什么序列化有什么问题答默认JDK序列化问题体积大、可读性差、有安全漏洞12. 怎么改成JSON问如何配置JSON消息转换器答配置Jackson2JsonMessageConverter为Bean五、项目实践类13. 你们项目哪里用了MQ举例说明问讲讲你们项目中的异步调用场景答支付成功后发送消息交易服务监听更新订单状态下单后发送消息购物车服务监听清理购物车14. 改造同步调用为异步的步骤问怎么把一个同步接口改成异步答定义交换机、队列、绑定关系生产者发送消息替代Feign调用消费者监听队列处理业务15. MQ消息丢了怎么办问如果MQ消息丢失怎么处理答后续课程会学消息可靠性持久化、确认机制、重试六、常见坑点16. 消息没被消费注意检查队列是否绑定到交换机、routingKey是否匹配、消费者是否监听正确队列17. 消息重复消费注意需要做幂等性处理如业务id去重18. 消费者处理失败注意默认会重试需配置重试机制或死信队列后续学习七、校招微服务考察重点排序MQ篇同步/异步概念对比⭐⭐⭐⭐⭐MQ的作用和好处⭐⭐⭐⭐⭐RabbitMQ核心概念⭐⭐⭐⭐交换机类型及区别⭐⭐⭐⭐SpringAMQP基本使用⭐⭐⭐⭐Work Queue模式⭐⭐⭐消息转换器⭐⭐⭐总结校招面试MQ核心考察概念理解和使用场景。你能把今天学的什么时候用异步解耦、提速MQ怎么用发消息、收消息交换机怎么选广播、路由、通配符讲清楚逻辑再结合支付异步通知的改造案例完全足够