国内最专业的IT技术学习网

UI设计

当前位置:主页 > UI设计 >

微服务架构之–消息队列Kafka图解最全知识点

发布时间:2019/09/23标签:   消息    点击量:

原标题:微服务架构之–消息队列Kafka图解最全知识点
MQ(新闻行列)是跨过程通讯的方法之一,可懂得为异步rpc,下游体系对换用成果的立场每每是主要不紧迫。应用新闻行列有以下利益:营业解耦、流量削峰、机动扩大。接上去先容新闻旁边件Kafka。Kafka是甚么?Kafka是一个散布式的新闻引擎。存在以下特点 可能公布和定阅新闻流(相似于新闻行列) 以容错的、长久的方法存储新闻流 多分区观点,进步了并行才能Kafka架构总览

微服务架构之–消息队列Kafka图解最全知识点
Topic新闻的主题、行列,每一个新闻都有它的topic,Kafka经过topic抵消息停止归类。Kafka中能够将Topic从物理上分别成一个或多个分区(Partition),每个分区在物理上对应一个文件夹,以”topicName_partitionIndex”的定名方法定名,该dir包括了这个分区的全部新闻(.log)和索引文件(.index),这使得Kafka的吞吐率能够程度扩大。Partition每个分区都是一个 次序的、弗成变的新闻行列, 而且能够连续的增加;分区中的新闻都被分了一个序列号,称之为偏移量(offset),在每个分区中此偏移量都是独一的。producer在公布新闻的时间,能够为每条新闻指定Key,如许新闻被发送到broker时,会依据分区算法把新闻存储到对应的分区中(一个分区存储多个新闻),假如分区规矩设置的公道,那末全部的新闻将会被平均的散布到差别的分区中,如许就完成了负载平衡。
微服务架构之–消息队列Kafka图解最全知识点
BrokerKafka server,用来存储新闻,Kafka集群中的每一个效劳器都是一个Broker,花费者将从broker拉取定阅的新闻Producer向Kafka发送新闻,出产者会依据topic散发新闻。出产者也担任把新闻关系到Topic上的哪一个分区。最简略的方法从分区列表中轮番抉择。也能够依据某种算法按照权重抉择分区。算法可由开辟者界说。CousumerConsermer实例能够是自力的过程,担任定阅和花费新闻。花费者用consumerGroup来标识本人。统一个花费组能够并发地花费多个分区的新闻,统一个partition也能够由多个consumerGroup并发花费,然而在consumerGroup中一个partition只能由一个consumer花费CousumerGroupConsumer Group:统一个Consumer Group中的Consumers,Kafka将响应Topic中的每个新闻只发送给此中一个ConsumerKafka producer 计划道理发送新闻的流程
微服务架构之–消息队列Kafka图解最全知识点

上一篇:一文搞定Java热更新

下一篇:没有了

返回
版权信息Copyright © 银河官网 版权所有    ICP备案编号:鲁ICP备09013610号