Java 消息策略的实现 - Kafak 是怎么设计的
这个也是开放讨论题，主要讨论下 Kafka 在消息中是如何进行实现的。
1_cCyPNzf95ygMFUgsrleHtw976×506 21.4 KB
总结
这个题目的开发性太强了。
Kafka 可以用的地方非常多，我经历过的项目有 Kafka 用在消息处理策略上的。这个主要是 IoT 项目，因为这个项目需要对温度传感器采集获得数据。
当我们有多个数据采集点的时候，通常是在每分钟发送几条数据的样子。
哪怕是这种使用场景，我觉得从系统架构的考虑来说还是过于臃肿了，因为 Kafka 的运行需要 ZooKeeper，一套 ZooKeeper 的运行至少是需要 3 台服务器。
正常的生产环境部署，我们可能要部署到 5 太服务器上。
对于一个每秒钟消息都不到 1 条的消息服务器来说，实在是太重了。
其实这种使用场景，我们可以用一些轻量的消息服务器，比如说 ActiveMQ，我就觉得非常好。
可以简单到使用一个 Docker 容器就可以完成了，但消息处理能力也还是强大的。
对于 Kafka 这种野兽级的消息处理服务器，实在是用不上。
缓存
我们还经历过一个项目，Kafka 被用作缓存了。
每次项目启动的时候，都需要从 Kafka 上获得缓存数据，然后系统才能运行。
这个也是非常痛苦的，有时候因为缓存机制的使用不确定，导致部分时候的数据缓存上没有。
然后在调试的过程中就非常的痛苦。
面试回答
根据上面的情况，对这开放性的问题，通常只需要说说你对问题的了解情况就好了。
一般来说还是不会要求你做到具体的实现的，只要你对消息服务器有一些相关的知识，上面的 2 个使用案例还是比较经典的。
其实消息服务器还有很多可以使用的场景，比如说数据解耦，对爬虫数据的数据解耦等等，都是可以用的。
很多公司还会做一个消息服务器，比如说对订阅用户的消息回复，手机消息推送等等，都需要我们的消息服务器去处理。
所以这个问题为设计型问题，只需要对相关问题有所了解即可。
Java 消息策略的实现 - Kafak 是怎么设计的 - 求职路上 - iSharkFly
相关文章：
Java 消息策略的实现 - Kafak 是怎么设计的
这个也是开放讨论题，主要讨论下 Kafka 在消息中是如何进行实现的。 1_cCyPNzf95ygMFUgsrleHtw976506 21.4 KB 总结 这个题目的开发性太强了。 Kafka 可以用的地方非常多，我经历过的项目有 Kafka 用在消息处理策略上的。这个主要是 IoT 项目，…...
c++opencv RotatedRect 旋转矩形角度转换和顶点顺序转换
这里写自定义目录标题 以下代码记录主要是完成轮廓点求解最小外接矩形之后计算该文本行的角度和旋转矩形的左下（bl），左上（tl)，右上（tr),右下（br)的坐标点。 RotatedRect rtminAreaRect(contours…...
Flink-CDC 抽取SQLServer问题总结
Flink-CDC 抽取SQLServer问题总结 背景 flink-cdc 抽取数据到kafka 中，使用flink-sql进行开发，相关问题总结flink-cdc 配置SQLServer cdc参数 1.创建CDC 使用的角色, 并授权给其查询待采集数据数据库 -- a.创建角色 create role flink_role;-- b.授权…...
Linux 系统目录结构 终端
系统目录结构 Linux 或 Unix 操作系统中，所有文件和目录呈一个以根节点为始的倒置的树状结构。文件系统的最顶层是根目录，用 / 来表示根目录。在根目录之下的既可以是目录，也可以是文件，而每一个目录中又可以包含子目录文件。如此…...
Layui + Flask | 实现注册、登录功能（案例篇）（08）
此案例内容比较多，建议滑到最后点击阅读原文，阅读体验更佳。后续也会录制案例视频，将在本周内上传到同名的 b 站账号。 已经看了 layui 表单相关的知识，接下来就可以实现注册功能，功能逻辑如下： 项目创建 新建 flask 项目下载 layui 文件，解压之后复制到指定文件编写前…...
GitLab数据迁移后出现500错误
一、背景 去年做GitLab数据迁移时，写过一篇文章《GitLab的备份与还原》。后来发现新创建的项目没问题，但对于迁移过来的项目，修改名称等信息，或者删除该项目时，会出现500错误，以为是系统问题&#…...
音乐随行，公网畅享，群辉Audiostation给你带来听歌新体验！
文章目录 本教程解决的问题是：按照本教程方法操作后，达到的效果是本教程使用环境：1 群晖系统安装audiostation套件2 下载移动端app3 内网穿透，映射至公网 很多老铁想在上班路上听点喜欢的歌或者相声解解闷儿，于是打开手…...
机器学习入门：从算法到实际应用
机器学习入门：从算法到实际应用 机器学习入门：从算法到实际应用摘要引言机器学习基础1. 什么是机器学习？2. 监督学习 vs. 无监督学习 机器学习算法3. 线性回归4. 决策树和随机森林 数据准备和模型训练5. 数据预处理6. 模型训练与调优 实际应用…...
【Vue.js】vue-cli搭建SPA项目并实现路由与嵌套路由---详细讲解
一，何为SPA SPA（Single Page Application）是一种 Web 应用程序的开发模式，它通过使用 AJAX 技术从服务器异步加载数据，动态地更新页面内容，实现在同一个页面内切换不同的视图，而无需整页刷新 1.…...
Node.js 调用 fluent-ffmpeg
最近开发H5资源在线裁剪，最终在资源合成的步骤，选择 ffmpeg 作为合成的插件，记录下使用方式。 一、介绍 ffmpeg 一款跨平台多媒体处理工具，可以进行视频转码、裁剪、合成、音视频提取、推流等操作。 二、安装 Node js 可以利用…...
scrapy框架--
Scrapy是一个用于爬取数据的Python框架。下面是Scrapy框架的基本操作步骤： 安装Scrapy：首先，确保你已经安装好了Python和pip。然后，在命令行中运行以下命令安装Scrapy：pip install scrapy 创建Scrapy项目：…...
算法通关村第十五关——从40亿个数中产生一个不存在的数的处理方法
1.从40个亿中产生一个不存在的整数 题目要求：给定一个输入文件，包含40亿个非负整数，请设计一个算法，产生一个不存在该文件中的整数，假设你有1GB的内存来完成这项任务。**** 解题中心思想：存储的不是这40亿…...
软件项目开发的流程及关键点
软件项目开发的流程及关键点 graph LR A[需求分析] --> B[系统设计] B --> C[编码开发] C --> D[测试验证] D --> E[部署上线] E --> F[运维支持]在项目开发的流程中，首先是进行需求分析，明确项目的目标和功能要求。接下来是系统设计&am…...
全球变暖问题（floodfill 处理联通块问题）
全球变暖问题 文章目录 全球变暖问题前言题目描述题目分析边界问题的考虑岛屿是否被淹没判断：如何寻找联通块： 代码预告 前言 之前我们介绍了 bfs算法在二维，三维地图中的应用，现在我们接续进行拓展，解锁floodfill 算…...
由于找不到vcruntime140_1.dll怎么修复，详细修复步骤分享
在使用电脑过程中，可能会遇到一些错误提示，其中之一是找不到vcruntime140_1.dll的问题。这使得许多用户感到困扰，不知道该如何解决这个问题。小编将详细介绍vcruntime140_1.dll的作用以及解决找不到该文件的方法，帮助你摆脱困境。…...
)
算法 三数之和-(双指针)
牛客网: BM54 题目: 数组中所有不重复的满足三数之和等于0的数，非递减形式。 思路: 数组不小于3。不重复非递减，需先排序。使用idx从0开始遍历到n-2, 如果出现num[idx]num[idx-1]的情况，忽略继续下一个idx；令left idx1, right …...
AB实验总结
互联网有线上系统，可做严格的AB实验。传统行业很多是不能做AB实验的。 匹配侧是采用严格的AB实验来进行模型迭代，而精细化定价是不能通过AB实验来评估模型好坏，经历过合成控制法、双重差分法，目前采用双重差分法来进行效果评估。…...
sklearn包中对于分类问题，如何计算accuracy和roc_auc_score？
1. 基础条件 import numpy as np from sklearn import metricsy_true np.array([1, 7, 4, 6, 3]) y_prediction np.array([3, 7, 4, 6, 3])2. accuracy_score计算 acc metrics.accuracy_score(y_true, y_prediction)这个没问题 3. roc_auc_score计算 The binary and mul…...
python温度转换程序
1.使用pycharm运行温度转换程序，尝试将温度单位设在前面 2.参照温度转换程序,自己写一个关于货币转换、长度转换、重量转换或者面积转换的程序 循环函数 def convertemperature():temperature ""while (temperature ! "q"):temperature in…...
Vue2中10种组件通信方式和实践技巧
目录 1，props / $emit1.1，一个需求方法1方法2 1.2，v-model 和 .syncv-model.sync 2，$children / $parent3，ref4，$attrs / $listeners$attrs$listenersinheritAttrs1.1 的问题的第3种解决方法 5，…...
idea大量爆红问题解决
问题描述 在学习和工作中，idea是程序员不可缺少的一个工具，但是突然在有些时候就会出现大量爆红的问题，发现无法跳转，无论是关机重启或者是替换root都无法解决 就是如上所展示的问题，但是程序依然可以启动。 问题解决…...
深入浅出Asp.Net Core MVC应用开发系列-AspNetCore中的日志记录
ASP.NET Core 是一个跨平台的开源框架，用于在 Windows、macOS 或 Linux 上生成基于云的新式 Web 应用。 ASP.NET Core 中的日志记录 .NET 通过 ILogger API 支持高性能结构化日志记录，以帮助监视应用程序行为和诊断问题。 可以通过配置不同的记录提供程…...
shell脚本--常见案例
1、自动备份文件或目录 2、批量重命名文件 3、查找并删除指定名称的文件： 4、批量删除文件 5、查找并替换文件内容 6、批量创建文件 7、创建文件夹并移动文件 8、在文件夹中查找文件...
Java如何权衡是使用无序的数组还是有序的数组
在 Java 中，选择有序数组还是无序数组取决于具体场景的性能需求与操作特点。以下是关键权衡因素及决策指南： ⚖️ 核心权衡维度 维度有序数组无序数组查询性能二分查找 O(log n) ✅线性扫描 O(n) ❌插入/删除需移位维护顺序 O(n) ❌直接操作尾部 O(1) ✅内存开销与无序数组相…...
基于当前项目通过npm包形式暴露公共组件
1.package.sjon文件配置 其中xh-flowable就是暴露出去的npm包名 2.创建tpyes文件夹，并新增内容 3.创建package文件夹...
【学习笔记】深入理解Java虚拟机学习笔记——第4章 虚拟机性能监控，故障处理工具
第2章 虚拟机性能监控，故障处理工具 4.1 概述 略 4.2 基础故障处理工具 4.2.1 jps:虚拟机进程状况工具 命令：jps [options] [hostid] 功能：本地虚拟机进程显示进程ID（与ps相同），可同时显示主类&#x…...
Golang——7、包与接口详解
包与接口详解 1、Golang包详解1.1、Golang中包的定义和介绍1.2、Golang包管理工具go mod1.3、Golang中自定义包1.4、Golang中使用第三包1.5、init函数 2、接口详解2.1、接口的定义2.2、空接口2.3、类型断言2.4、结构体值接收者和指针接收者实现接口的区别2.5、一个结构体实现多…...
Cilium动手实验室: 精通之旅---13.Cilium LoadBalancer IPAM and L2 Service Announcement
Cilium动手实验室: 精通之旅---13.Cilium LoadBalancer IPAM and L2 Service Announcement 1. LAB环境2. L2公告策略2.1 部署Death Star2.2 访问服务2.3 部署L2公告策略2.4 服务宣告 3. 可视化 ARP 流量3.1 部署新服务3.2 准备可视化3.3 再次请求 4. 自动IPAM4.1 IPAM Pool4.2 …...
Python 高效图像帧提取与视频编码：实战指南
Python 高效图像帧提取与视频编码：实战指南 在音视频处理领域，图像帧提取与视频编码是基础但极具挑战性的任务。Python 结合强大的第三方库（如 OpenCV、FFmpeg、PyAV），可以高效处理视频流，实现快速帧提取、压缩编码等关键功能。本文将深入介绍如何优化这些流程，提高处理…...
MySQL体系架构解析（三）：MySQL目录与启动配置全解析
MySQL中的目录和文件 bin目录 在 MySQL 的安装目录下有一个特别重要的 bin 目录，这个目录下存放着许多可执行文件。与其他系统的可执行文件类似，这些可执行文件都是与服务器和客户端程序相关的。 启动MySQL服务器程序 在 UNIX 系统中，用…...