-
1.初识Kafka
初识Kafka 基本概念 初识Kafka Kafka 起初是 由 LinkedIn 公司采用 Scala 语言开发的一个多分区、多副本且基于 ZooKeeper 协调的分布式消息系统，现已被捐献给 Apache 基金会。目前 Kafka 已经定位为一个分布式流式处理平台，它以高吞吐、可持久化、可水平扩展、支持流数据处理等多种特性而被广泛使用。目前越... -
569.golang 怎么维护websocket连接池
golang 怎么维护websocket连接池 答案1 答案2 golang 怎么维护websocket连接池 答案1 在Go语言中维护WebSocket连接池，可以通过以下步骤实现： 创建连接池：使用channel来存储连接对象，确保每个连接都被有效管理。 并发处理：利用Go的并发特性，合理配置和使用WebSocket连接，以提高性能。... -
18. TCP 对应的应用层协议？
📑 题目：18. TCP 对应的应用层协议？ 参考解析 📑 题目：18. TCP 对应的应用层协议？ 参考解析 FTP ：定义了文件传输协议，使用 21 端口。常说某某计算机开了 FTP 服务便是启动了文件传输服务。下载文件，上传主页，都要用到 FTP 服务。 Telnet ：它是一种用于远程登陆的端口，用户可以以自己的身份远程连接到计算机... -
5.生产者客户端原理分析
生产者客户端原理分析 整体架构 元数据的更新 生产者客户端原理分析 在前面的章节中，我们已经了解了 KafkaProducer 的具体使用方法，而本节的内容主要是对 Kafka 生产者客户端的内部原理进行分析，通过了解生产者客户端的整体脉络可以让我们更好地使用它，避免因为一些理解上的偏差而造成使用上的错误。 整体架构 在上一节中提及了消息在... -
11.位移提交
位移提交 控制或关闭消费 位移提交 对于 Kafka 中的分区而言，它的每条消息都有唯一的 offset，用来表示消息在分区中对应的位置。对于消费者而言，它也有一个 offset 的概念，消费者使用 offset 来表示消费到分区中某个消息所在的位置。 单词“offset”可以翻译为“偏移量”，也可以翻译为“位移”，读者可能并没有过多地在意这一点... -
67. 为什么需要头部(header)压缩？
📑 题目：67. 为什么需要头部(header)压缩？ 📑 题目：67. 为什么需要头部(header)压缩？ 假定一个页面有 100 个资源需要加载（这个数量对于今天的 Web 而言还是挺保守的），而每一次请求都有 1kb 的消息头（这同样也并不少见，因为 Cookie 和引用等东西的存在），则至少需要多消耗 100kb 来获取这些消息头。HTTP... -
572.gin 框架怎么存储路由的是hash还是其它数据结构
总结答案 原理 前言 Radix Tree的定义 Gin路由构建过程 图解Gin路由构建过程 从代码层面理解Gin路由构建 小结 总结答案 Gin框架存储路由的数据结构是Radix Tree（基数树）。 原理 在这篇文章中，我们来深入探究Gin 框架最核心的功能：路由树的构建原理。 前言 Gin 框架的底层采用Radix ... -
4.序列化-分区器-拦截器
序列化 分区器 生产者拦截器 序列化 生产者需要用序列化器（Serializer）把对象转换成字节数组才能通过网络发送给 Kafka。而在对侧，消费者需要用反序列化器（Deserializer）把从 Kafka 中收到的字节数组转换成相应的对象。在代码清单3-1中，为了方便，消息的 key 和 value 都使用了字符串，对应程序中的序列化器也使... -
45. HTTP、TCP、Socket 的关系是什么？
📑 题目：45. HTTP、TCP、Socket 的关系是什么？ 参考解析 📑 题目：45. HTTP、TCP、Socket 的关系是什么？ 参考解析 TCP/IP 代表传输控制协议/网际协议，指的是一系列协议族。 HTTP 本身就是一个协议，是从 Web 服务器传输超文本到本地浏览器的传送协议。 Socket 是 TCP/IP 网络的 A... -
25. 如何选择合适的分区数(上)
如何选择合适的分区数 性能测试工具 分区数越多吞吐量就越高吗 如何选择合适的分区数 如何选择合适的分区数？这是很多 Kafka 的使用者经常面临的问题，不过对这个问题而言，似乎并没有非常权威的答案。而且这个问题显然也没有固定的答案，只能从某些角度来做具体的分析，最终还是要根据实际的业务场景、软件条件、硬件条件、负载情况等来做具体的考量。本节主要介...