涡阳在北京做网站的名人,电子商务网站建设 期末考试试卷以及答案,网站首页是什么,中信建设有限责任公司中标项目为什么要使用kafka#xff1f;kafka是什么东西#xff1f;
案例场景
A服务向B服务发送消息#xff0c;A服务传输数据很快#xff0c;B服务处理数据很慢#xff0c;这样B服务就会承受不住#xff0c;怎么办#xff1f;通过添加消息队列作为缓冲。kafka就是消息队列中的…为什么要使用kafkakafka是什么东西
案例场景
A服务向B服务发送消息A服务传输数据很快B服务处理数据很慢这样B服务就会承受不住怎么办通过添加消息队列作为缓冲。kafka就是消息队列中的其中一种。其他的还有比如rocketMQ。
第一种方式在B服务的内存添加队列用于存储A服务快速发送而来的信息。
缺点在B服务重启的时候内存中所有消息将会丢失。
因此我们将队列从内存中挪出来成为一个单独的进程这样即使B服务重启的时候队列里堆积的消息也不会丢失。
此时我们称
产生消息的服务A为生产者
接收消息的服务B为消费者
优化消息队列
1. 高性能
方式增加消费者增加生产者提高了消息队列的吞吐量。
缺点争夺同一个消息队列等待。
解决
添加topic不同消费者消费不同topic的消息 同一个topic里面消息还是很多就分区降低消费者争抢的可能性。
高扩展性partition分在不同的机器上一台机器就成为一个broker。多机器来缓解机器CPU压力 高可用万一其中一个机器broker挂了怎么办
因此需要做备份。如果 Leader partition 挂了那么就会 有Flower Partition来做备份。 持久化和过期策略如果都挂了呢因此需要将数据同步在磁盘中到那时磁盘又不是无限的因此也需要进行定时的清理。每个partition内部写入磁盘都是顺序写入的因此效率很高但是不同的partition之间在磁盘的写入并不是顺序写入的。
