01 消息引擎系统

本文是Kafka 核心技术与实战学习笔记

kafka的作用

kafka最经常被提到的作用是是削峰填谷，即解决上下游TPS的错配以及瞬时峰值流量，如果没有消息引擎系统的保护，下游系统的崩溃可能会导致全链路的崩溃。还有一个好处是发送方和接收方的松耦合，一定程度上简化了应用的开发。

评论区优秀内容

使用kafka业务场景举例

比如被说烂的秒杀场景，找到了《消息队列高手课》这个课程的学习笔记，kafka异步处理和流量控制的实际使用场景可以参考
https://zhuanlan.zhihu.com/p/480260300
https://www.cnblogs.com/traditional/p/17501371.html

读完知乎的这篇文章，有两个问题：
1.秒杀服务处理完业务响应通知网关，是通过rpc调用实现的，具体的实现细节是什么样子的？
联系到之前学习过的Spring DifferResult，是否可以这样实现：1.APP端请求网关进行秒杀；2.网关将请求包装成消息发到kafka，并返回DifferResult到网关；3.秒杀后端消费消息，处理完业务，通过rpc调用通知网关；4.网关调用DifferResult的setResult方法，响应APP端
2.文章中提到的秒杀服务处理完业务后，通过回调或者push返回结果，具体是怎么实现的？

实时返回结果的问题

使用消息引擎的这种数据处理方式，上游是否无法得知处理的结果了，甚至是无法将处理的结果返回上游？
消息引擎的这种通信方式，确实是异步且单向的，如果需要这种回馈的机制，最好使用服务调用的方式。