第1节 kafka消息队列：2、kafka的架构介绍以及基本组件模型介绍

电玩女神 2021-11-17 05:02 266阅读 0赞

# 3、kafka的架构模型 #

1、producer：消息的生产者，主要是用于生产消息的。主要是接入一些外部的数据源，从外部获取数据，比如说我们可以从flume获取数据，还可以通过ftp传入数据等，还可以通过kafka的API生产数据，通过push的方式，主动的将数据推送到kafka的topic当中去

2、topic：主题，里面是一类消息的抽象的集合，说白了这下面就是用来装各种数据的

3、paritition：消息的分区。为了解决数据保存的横向扩展的问题，所以将一个topic分为多个partition，每个partition保存topic当中的部分部署。为了解决partition丢失的问题，引入了副本机制，可以将一个partition复制多分出来保存

4、broker：在kafka当中一台服务器，叫做一个broker

5、consumer：消息的消费者，主要去消费topic当中的数据的，主动会去pull拉取topic当中的消息

6、zookeeper：为了解决消费者消费的时候，确定一个topic当中有多少个分区，分区分别都在哪一台机器上，引入zk来保存这些数据

7、kakfa的消费模型，在kakfa当中消费有组的概念。同一时间，一个组当中，只能有一个线程去消费一个paritition当中的数据

8、kakfa消费必要的三个条件

第一个条件：确定哪一个topic

第二个条件：必须知道zk的地址

第三个条件：消息消费的offset偏移量

# 4、kafka的组件的介绍 #

produer：消息的生产者，往topic当中生产消息

consumer：消息的消费者，从topic当中消费消息

broker：kafka的服务器

zookeeper：kafka依赖于zk保存一些topic以及partition的信息

topic：一类消息的高度抽象集合，一个topic下面由多个paritition组成

partition：消息的分区，每个paritition保存了一部分topic的数据，一个partition包含多个segement。一个segement又包含两部分，.log文件和.index文件

segement：包含两个文件.log 文件 .index文件

.log：记录了我们的数据，文件是顺序读写的

.index文件：记录了.log文件的索引

offset：消息的偏移量，我们消费数据的时候，都要记录消息的offset，下次继续消费的时候，根据上次的offset偏移量就可以确定我们下一条数据从哪里开始消费

===============================

# 1、 kafka的架构模型 #

基于producer consumer topic broker 等的一个基本架构

![1325651-20190718235525920-1173211187.png][]

**5****、****kafka****的组件****介绍**

Topic ：消息根据Topic进行归类

Producer：发送消息者

Consumer：消息接受者

broker：每个kafka实例(server)

Zookeeper：依赖集群保存meta信息。

**Topics****组件介绍**

Topic：一类消息，每个topic将被分成多个partition(区)，在集群的配置文件中配置。

partition：在存储层面是逻辑append log文件，包含多个segment文件。

Segment：消息存储的真实文件，会不断生成新的。

offset：每条消息在文件中的位置（偏移量）。offset为一个long型数字，它是唯一标记一条消息。

**partition**

1、 在存储层面是逻辑append log文件，每个partition有多个segment组成。

2、 任何发布到此partition的消息都会被直接追加到log文件的尾部。

3、 每个partition在内存中对应一个index列表，记录每个segment中的第一条消息偏移。这样查找消息的时候，先在index列表中定位消息位置，再读取文件，速度块。

4、 发布者发到某个topic的消息会被均匀的分布到多个part上，broker收到发布消息往对应part的最后一个segment上添加该消息。

![1325651-20190718235547915-1546040924.png][]

**partition****分布**

1、 partitions分区到不同的server上，一个partition保存在一个server上，避免一个server上的文件过大，同时可以容纳更多的consumer消费,有效提升并发消费的能力。

2、 这个server(如果保存的是partition的leader)负责partition的读写。可以配置备份。

3、 每个partition都有一个server为"leader"，负责读写，其余的相对备份机为follower，follower同步leader数据，负责leader死了之后的接管。n个leader均衡的分散在每个server上。

4、 partition的leader和follower之间监控通过zookeeper完成。

![1325651-20190718235601398-252124569.png][]

**segment**

1、 每个segment中存储多条消息，消息id由其逻辑位置决定，即从消息id可直接定位到消息的存储位置，避免id到位置的额外映射。

2、 当某个segment上的消息条数达到配置值或消息发布时间超过阈值时，segment上的消息会被flush到磁盘，只有flush到磁盘上的消息订阅者才能订阅到

3、 segment达到一定的大小（可以通过配置文件设定,默认1G）后将不会再往该segment写数据，broker会创建新的segment。

![1325651-20190718235614821-1617480092.png][]

**offset**

offset是每条消息的偏移量。

segment日志文件中保存了一系列"log entries"(日志条目),每个log entry格式为"4个字节的数字N表示消息的长度" + "N个字节的消息内容";

每个日志文件都有一个offset来唯一的标记一条消息,offset的值为8个字节的数字,表示此消息在此partition中所处的起始位置.

每个partition在物理存储层面,有多个log file组成(称为segment).

segment file的命名为"最小offset".log.例如"00000000000.log";其中"最小offset"表示此segment中起始消息的offset.

![1325651-20190718235625765-1280711766.png][]

转载于:https://www.cnblogs.com/mediocreWorld/p/11210819.html

[1325651-20190718235525920-1173211187.png]: /images/20211116/044881ee19c04062853360ba5100f217.png
[1325651-20190718235547915-1546040924.png]: /images/20211116/2b8589177b2b4469aa47394fa9058ffe.png
[1325651-20190718235601398-252124569.png]: /images/20211116/251e30057ed949c5b408c4b065fdf52f.png
[1325651-20190718235614821-1617480092.png]: /images/20211116/a5df306ddd9b49c6a7bace0141570395.png
[1325651-20190718235625765-1280711766.png]: /images/20211116/42833854c8ba4f668c7f02a6295428ea.png