00:02
好啊,我们单机版的热卡Q啊,已经安装完毕了啊,也可以正常启动了,然后我们的控制台呢,也安装完毕了啊,也可以启动了,那么下边我们就要讲这个。集群。呃,集群搭建啊,我们先来说一下我们这个,大家看这个图。这个图里边我们发现啊,我们的producer是集群,Consumer是集群,Name server是集群,Broke是集群,那你说这个集群搭建指的是什么?就集群来讲啊,首先我们不会是producer和consumer的集群。因为producer和consumer集群很简单,你只需要啊,呃,在你启动的这个应用上啊。写上相同的,他们只要写上相同的group name,那么他们就是一个集群里边的,所以你只要启动就行了,写上相同的group name以后,启动一个集群里面就增加一个节点,启动一个就增加一个节点。
01:11
所以这个集群呢,不会是它这个太简单了啊,我们就就这一句话就搞定了。那么name server是他吗?也不是他,因为我们前面说过name server这个。这个这个鸡群啊,它的。主机之间是无状态的。也就是说。他们之间,相互之间啊,是没有通讯,谁也不知道谁的存在。那么我只要启动一个name server。那这个集群里边就增加了一个节点,启动server,它就增加了一个节点,所以这个集群也不用讲。它比这个更简单,比producer和consumer更简单,所以也不会是它。那只能是谁了,博克集群,博克集群是比较复杂的。
02:01
负担到哪呢,我们可以看。首先,这是一个大的集群。对吧,但是大类集群里边为了保证它的高可用性,所以。这是一个小鸡群,这又是一个小鸡群。对吧,这些小集群构成这个大集群,所以它整体结构还是很复杂的,这边就涉及到什么,比如说你你你你producer啊,你生产的消息。是吧,啊,你是写到他。他写到他是吧,然后他的数据是要做复制。同步给他。对吧。那怎么样同步呢?对不对。所以这个这个集群是比较复杂的,所以我们下面要讲的这个,呃,集群搭建理论啊,我们集群搭建啊,指的是什么?博客集群,只要清楚这个。那么这个集群搭建啊,在学习之前呢,需要。
03:02
有一些理论知识我们需要掌握,否则的话,这集训搭建嗯,你也是搞不明白,搞不清楚的。呃,这里边有这样的两块啊,一个是数据复制与刷盘策略,一个是博集训模式。我们先来看。先来看这个啊,数据复制与刷盘策略。那么我们看这个看这个图啊,这个图这是。Master正是slave。在master和slave中间叫什么?复制。所以我们说这个复制策略啊,数据的复制策略是指的master和slave之间。啊,数据的同步啊,数据的复制。这个是指的这个这这个策略啊,然后呢,它有个刷盘,什么叫刷盘呢?我们看啊,在一个机器里边内存到磁盘。
04:00
这叫刷盘,内存到磁盘,这刷盘,所以刷盘指在什么?刷盘是指的啊,一个主机内部由内存写入到磁盘,将数据流内存写入到磁盘,这个过程叫刷盘。那么这个刷盘策略啊,方式是不一样的啊,复制方式也是不一样的。所以我们来看什么是复制策略啊,那复制策略是broke the master slave间数据的同步方式。分为同步复制和异步复制。啊,什么是同步复制呢?消息写入master以后,Master会等待s slave同步数据成功后才会向呃,向这个producer返回成功的阿。什么?一部分是形容master以后master立即向produce返回成功的阿,无需等待。六、同步处理成功什么意思呢?就是所谓的同步啊同步。
05:01
就说我把消息啊。珊珊这把消息往它里边一写,一旦写到了我们这个这个这个呃,Master成功了。我不管你给他复制成功了没有。我马上给你回复。这是什么?这叫义不复制。我不管你怎么样,我直接给你返回,哎,我master只要成功了,我就给你返回这个这个这个返回上去啊,我要成功了啊,所谓的同步复制是什么呢?我将消息写到。Master。Master把消息同步到我们的slave也成功了,这两步都成功了,我才给你生产者响应啊,我这边这个成功了,你可以发下一条消息了。这是同步和异步,那这边就有一个问题啊,我刚才说到了,说这个交息啊,写到我们master成功了,然后就给他响应,这是一步,什么叫成功。
06:03
什么叫什么叫写入到master就成功了呢?另外。啊,我们说这个同步啊,我这个master把消息复制给你这个slave,你slave成功了,Master也成功了,Slave也成功了,实际上是成功也会告诉master。Master收到他的成功的响应以后,他会给生产者说,啊,我们这都成功了,你可以发下一条消息了。所以这里边就有个问题,就是slave怎么就就就叫成功了呢?哎,这就涉及到刷盘了。我们看刷盘策略啊。再说啊,上完策略是指brokeer中的消息的。中消息的落盘方式,注意啊,这有个词叫落盘。强调一下啊。落盘。什么是落盘?接着消息发送到博客内存以后,消息持久化到磁盘的方式叫落盘方式。
07:08
分为同步刷盘和异步刷盘。什么叫同步刷盘?当消息持久化到broke磁盘以后,才算消息就成功,你注意写到磁盘了才叫成功。什么样异步刷分呢?就要学的博客内存就算成功了。不需要。啊,世界化的磁盘。那大来看啊。我生日日把消息。发送master master说成功了啊,你,你给我发下一条吧,什么叫成功了?就是如果你这个刷盘采用的是。同步刷盘。那你把消息写到我内存了,我把内存的消息写到磁盘了,这才叫成功,这时候我才会给你说,给你伤害着说啊,我这个消息啊,已经。
08:07
提交成功了。那。再来说这个这个这个异步刷盘啊,异步刷盘只要深深的把消息写到内存了。我就马上告诉你,生,可以,可以来下一条了。但我不用管你是不是写到磁盘了。所以我们这两个啊,是逻辑上是关联的啊,什么叫。这个这个呃,成功啊,我甚至把消息发送到master成功了,马上回复,马上给他响应。啊,你就可以发下一条了,所谓的成功你也分两种情况。对不对啊,这是我们说的,呃,复制策略和刷盘策略当然需要大家注意啊,复制策略和刷盘策略不仅仅。
09:01
呃,存在于我们这个这个这个这个卡Q啊,他的他的博克的master和之间啊,其实这个复制策略啊,上盘策略啊,这就是一种同步策略。就数据同步策略啊,数据同步策略,那么在这种做数据同步的里边都存在这个问题。呃,那么咱们在这啊,老雷再给大家往深里面说一下啊,再再引申一些。大家看一下啊,这个复制策略实际上。这个复制策略它是不是。整体啊,我们的异步复制是不是降低了系统的。写入的延迟啊。异步复制降低了写入延迟。就是我我就不用管你这。是吧,你只要给我这样成功了,我马上就给你响应了,这RT。
10:01
变短了对吧。所以它写入延迟啊,这个就变小了,写入延迟小了,所以他紧接着下一条就发过来了,紧接着下一条就发过来了,为什么提高了系统的整体的吞吐量。对不对,那咱们写上这么一句话吧。嗯。异步。复制。呃,策略。降低。系统的。写入。电池是吧,呃,RT是吧。啊,不要写时间了啊,二题。变小。对吧,然后呢,就是就是就是呃,提高是吧,系统是吧啊。吞。
11:00
土哎,吞吐量。对吧。这是复制策略,那我们再来看它。这个刷盘策略啊,刷盘策略呢,呃,它它首先肯定也是这样。是吧,只不过这是异步刷盘。异步刷盘策略,它也是降低了系统的写入延迟,然后RT变小,提高了系统的存储量,这没问题是吧?那么老雷在这给大家说的更详细一些啊,就是其实我们消息啊写入到我们的内存。实际上是写到内存在哪。叫page catch。消息。写入到。Broker。的内存。啊,一般是写。
12:01
很有道理。Page。Catch。呃,然后我们异步刷盘,刚才说到异步刷盘啊,是上异步刷盘的时候,消息只要写到了page catch。他是直接给了A响应了。然后。这个这个配置catch啊,它是个缓存,这缓存肯定有容量啊,哎,当当你这个配置catch啊,达到一定的量的时候,他才会去做这种。落盘是自动的落盘。这个我们说的什么一波啊。嗯。对,异步。异度沙盘。策略吧,啊这个。消息会写入等。
13:01
Catch。立即返回成功。对吧。啊,但并不。会。呃,立即。呃。做。落盘。落。入盘操作。而是什么。而是当。Page catch。达到一定。一定量。是。嗯。会自动。进行。罗盘。自动进行模板。一。二。算了,哎,这是我们进一步引申啊,给大家要引申一下。好,这就是我们说的数据的复制与刷盘策略。
我来说两句