当前位置: 首页 > news >正文

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返回结果,具体是怎么实现的?

实时返回结果的问题

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

http://www.lryc.cn/news/141189.html

相关文章:

  • npm 卸载 vuecli后还是存在
  • Unity 之利用 localEulerAngle与EulerAngle 控制物体旋转
  • 从零学算法 (剑指 Offer 13)
  • 854之数据结构
  • Redis从基础到进阶篇(二)----内存模型与内存优化
  • DBO优化SVM的电力负荷预测,附MATLAB代码
  • 第一百二十五回 dart中List和Map的常见用法
  • 小白到运维工程师自学之路 第七十九集 (基于Jenkins自动打包并部署Tomcat环境)2
  • 林【2021】
  • c语言练习题30:判断一个数是否为2^n
  • VX小程序 实现区域转图片预览
  • HTML5-1-标签及属性
  • 5017. 垦田计划
  • 【校招VIP】产品思维分析之面试新的功能点设计
  • indexDB vue 创建数据库 创建表 添加对象数据
  • Django基础1——项目实现流程
  • 基于SSM的在线购物系统——LW模板
  • Mac操作系统上设置和配置PPPoE连接
  • Python类的属性和方法
  • C#Queue<T>队列出现弹出元素被最后一次压入得元素覆盖的问题
  • python3GUI--模仿一些b站网页端组件By:PyQt5(详细介绍、附下载地址)
  • 聚类分析概述
  • 建模杂谈系列234 基于图的程序改造
  • requestAnimationFrame(RAF)
  • 【JavaScript笔记】面对对象与构造函数
  • ​LeetCode解法汇总5-正则表达式匹配​
  • 前端开发工具: VSCode
  • 【Stable-Diffusion-WebUI】Windows系统安装Stable-Diffusion-WebUI
  • 面试题(三)
  • 谈谈子网划分的定义、作用、划分方式以及案例