温馨提示：本文基于Kafka2.2.1版本。如果觉得源码阅读比较枯燥，本文的中间有Sender线程的工作流程图。上文《源码分析Kafka消息发送流程》已经详细介绍了KafkaProducersend方法的流程，该方法只是将消息追加到KafKaProducer的缓存中，并未真正的向broker发送消息，本文将来探讨Kafka的Sender线程。在KafkaProducer中会启动一个单独的线程，其名
分类：
编程语言 时间：
2020-12-08 12:00:53
阅读次数：
6
温馨提示：本文基于Kafka2.2.1版本。本文主要是以源码的手段一步一步探究消息发送流程，如果对源码不感兴趣，可以直接跳到文末查看消息发送流程图与消息发送本地缓存存储结构图。从上文初识KafkaProducer生产者，可以通过KafkaProducer的send方法发送消息，send方法的声明如下：Future<RecordMetadata>send(ProducerRecord&l
分类：
其他好文 时间：
2020-12-08 11:59:45
阅读次数：
3
温馨提示：整个KafkaClient专栏基于kafka-2.3.0版本。1、KafkaProducer概述根据KafkaProducer类上的注释上来看KafkaProducer具有如下特征：KafkaProducer是线程安全的，可以被多个线程交叉使用。KafkaProducer内部包含一个缓存池，存放待发送消息，即ProducerRecord队列，与此同时会开启一个IO线程将ProducerR
分类：
其他好文 时间：
2020-12-07 12:49:28
阅读次数：
11
1. 概述 在本教程中，我们将介绍 Apache Beam 并探讨其基本概念。 我们将首先演示使用 Apache Beam 的用例和好处，然后介绍基本概念和术语。之后，我们将通过一个简单的例子来说明 Apache Beam 的所有重要方面。 2. Apache Beam是个啥? **Apache B ...
分类：
Web程序 时间：
2020-12-07 12:08:06
阅读次数：
7
JDBC基本概念 Java数据库连接，也就是使用Java语言操作数据库。 本质： 其实是官方（SUN公司）定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包，我们可以使用这套接口（JDBC）变成，整整执行的代码是驱动jar包中的实现类。 JDBC快速入 ...
分类：
数据库 时间：
2020-12-07 12:03:08
阅读次数：
21
UML（Unified Modeling Language）是一种统一建模语言，为面向对象开发系统的产品进行说明、可视化、和编制文档的一种标准语言。 下面将对UML的九种图+包图的基本概念进行介绍以及各个图的使用场景。 用例图（UseCase Diagrams） 用例图主要回答了两个问题：1、是谁用 ...
分类：
编程语言 时间：
2020-12-05 10:51:02
阅读次数：
6
1.基本概念 HTTP： 超文本传输协议，是互联网上应用最为广泛的一种网络协议，是一个客户端与服务器端请求和应答的标准（TCP)，用于从WWW服务器传输超文本到本地浏览器的传输协议，可以使浏览器更加高效，使网络传输减少。 HTTPS：是以安全为目标的HTTP通道，简单讲是HTTP的安全版，即HTTP ...
分类：
Web程序 时间：
2020-12-04 11:28:24
阅读次数：
15
Apache Kafka由Scala和Java编写，基于生产者和消费者模型作为开源的分布式发布订阅消息系统。它提供了类似于JMS的特性，但设计上又有很大区别，它不是JMS规范的实现，如Kafka允许多个消费者主动拉取数据，而在JMS中只有点对点模式消费者才会主动拉取数据 ...
分类：
其他好文 时间：
2020-12-04 11:04:22
阅读次数：
7
Kafka 最初考虑的问题是，customer 应该从 brokes 拉取消息还是 brokers 将消 息推送到 consumer，也就是 pull 还 push。在这方面，Kafka 遵循了一种大部分 消息系统共同的传统的设计：producer 将消息推送到 broker，consumer 从 ...
分类：
其他好文 时间：
2020-12-03 11:32:29
阅读次数：
3
1.内核及发行版 1）内核（kernel）:运行程序和管理硬件的核心程序，提供了一个在裸设备和应用程序之间的抽象层。 2）发行版：提供了人机交互界面。 2.Linux的文件结构 Linux没有Windows那样的盘符概念，只有一个根目录/，所有的文件都在它下面。/下的home目录为每个用户私有。 3 ...
分类：
系统相关 时间：
2020-12-01 12:33:34
阅读次数：
10
