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

Java 消息策略的实现 - Kafak 是怎么设计的

这个也是开放讨论题,主要讨论下 Kafka 在消息中是如何进行实现的。

1_cCyPNzf95ygMFUgsrleHtw

1_cCyPNzf95ygMFUgsrleHtw976×506 21.4 KB

总结

这个题目的开发性太强了。

Kafka 可以用的地方非常多,我经历过的项目有 Kafka 用在消息处理策略上的。这个主要是 IoT 项目,因为这个项目需要对温度传感器采集获得数据。

当我们有多个数据采集点的时候,通常是在每分钟发送几条数据的样子。

哪怕是这种使用场景,我觉得从系统架构的考虑来说还是过于臃肿了,因为 Kafka 的运行需要 ZooKeeper,一套 ZooKeeper 的运行至少是需要 3 台服务器。

正常的生产环境部署,我们可能要部署到 5 太服务器上。

对于一个每秒钟消息都不到 1 条的消息服务器来说,实在是太重了。

其实这种使用场景,我们可以用一些轻量的消息服务器,比如说 ActiveMQ,我就觉得非常好。

可以简单到使用一个 Docker 容器就可以完成了,但消息处理能力也还是强大的。

对于 Kafka 这种野兽级的消息处理服务器,实在是用不上。

缓存

我们还经历过一个项目,Kafka 被用作缓存了。

每次项目启动的时候,都需要从 Kafka 上获得缓存数据,然后系统才能运行。

这个也是非常痛苦的,有时候因为缓存机制的使用不确定,导致部分时候的数据缓存上没有。

然后在调试的过程中就非常的痛苦。

面试回答

根据上面的情况,对这开放性的问题,通常只需要说说你对问题的了解情况就好了。

一般来说还是不会要求你做到具体的实现的,只要你对消息服务器有一些相关的知识,上面的 2 个使用案例还是比较经典的。

其实消息服务器还有很多可以使用的场景,比如说数据解耦,对爬虫数据的数据解耦等等,都是可以用的。

很多公司还会做一个消息服务器,比如说对订阅用户的消息回复,手机消息推送等等,都需要我们的消息服务器去处理。

所以这个问题为设计型问题,只需要对相关问题有所了解即可。

Java 消息策略的实现 - Kafak 是怎么设计的 - 求职路上 - iSharkFly

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

相关文章:

  • c++opencv RotatedRect 旋转矩形角度转换和顶点顺序转换
  • Flink-CDC 抽取SQLServer问题总结
  • Linux 系统目录结构 终端
  • Layui + Flask | 实现注册、登录功能(案例篇)(08)
  • GitLab数据迁移后出现500错误
  • 音乐随行,公网畅享,群辉Audiostation给你带来听歌新体验!
  • 机器学习入门:从算法到实际应用
  • 【Vue.js】vue-cli搭建SPA项目并实现路由与嵌套路由---详细讲解
  • Node.js 调用 fluent-ffmpeg
  • scrapy框架--
  • 算法通关村第十五关——从40亿个数中产生一个不存在的数的处理方法
  • 软件项目开发的流程及关键点
  • 全球变暖问题(floodfill 处理联通块问题)
  • 由于找不到vcruntime140_1.dll怎么修复,详细修复步骤分享
  • 算法 三数之和-(双指针)
  • AB实验总结
  • sklearn包中对于分类问题,如何计算accuracy和roc_auc_score?
  • python温度转换程序
  • Vue2中10种组件通信方式和实践技巧
  • Flutter flutter.minSdkVersion的实际文件位置
  • python生成PDF报告
  • 在visual studio里安装Python并创建python工程
  • AIGC(生成式AI)试用 6 -- 从简单到复杂
  • 竞赛 基于深度学习的人脸识别系统
  • uniapp:APP开发,后台保活
  • vue2 项目中嵌入视频
  • 第二章 进程与线程 十二、进程同步与进程互斥
  • Linux内核链表(list)移植到任意平台
  • 【操作系统】聊聊什么是CPU上下文切换
  • CMake教程-第 2 步 添加一个库