网站首页 > 博客文章 正文
1、Kafka为什么比RocketMQ的吞吐量要高
Kafka的生产者采用的是异步消息发送机制,当发送一条消息时,消息并没有发送到Broker而是缓存起来,然后直接想业务返回成功,当缓存的消息达到一定数量时再批量发送给Broker。这种做法减少了网络IO,从而提高了消息发送的吞吐量,但是如果消息生产者宕机,会导致消息丢失,业务出错,所以理论上kafka利用此机制提高了性能却降低了可靠性。
2、Kafka的pull和push分别有什么优缺点
1、pull表示消费者主动拉取,可以批量拉取,也可以单条拉取,所以pull可以由消费者自己控制,根据自己的消息处理能力来进行控制,但是消费者不能及时知道是否有消息,可能会拉到的消息是空的。
2、push表示Broker主动给消费者推送多少消息,所以可能会造成网络堵塞,消费者压力大等问题。
3、RocketMQ底层实现原理
RocketMQ由NameServer集群、Producer集群、Consumer集群、Broker集群组成,消息生产和消费的大致原理如下:
1、broker在启动的时候想所有的NameServer注册,并保持长连接,每30秒发送一次心跳检测。
2、Producer在发送消息的时候从NameServer获取Broker服务器地址,根据负载均衡算法选择一台服务器来发送消息
3、Conusmer消费消息的时候同样从NameServer获取Broker地址,然后主动拉取消息来消费。
- 上一篇: RocketMQ架构最全详解(图文全面总结)
- 下一篇: Kafka与RocketMq文件存储机制对比
猜你喜欢
- 2024-09-17 MQ 技术产品井喷,今天来详聊一下腾讯开源消息中间件 TubeMQ | 原力计划
- 2024-09-17 消息队列专栏(三)RocketMQ和Kafka
- 2024-09-17 全网最通俗易懂的Kafka入门(kafka 入门)
- 2024-09-17 Kafka、RabbitMQ、RocketMQ等中间件对比—消息发送性能和区别
- 2024-09-17 17个方面对比Kafka、RabbitMQ、RocketMQActiveMQ分布式消息队列
- 2024-09-17 Kafka与RocketMq文件存储机制对比
- 2024-09-17 RocketMQ架构最全详解(图文全面总结)
- 2024-09-17 滴滴出行基于RocketMQ构建企业级消息队列服务的实践
- 2024-09-17 7张图,带你5分钟入门RocketMQ(rocketmq简介)
- 2024-09-17 大数据相关,Kafka与MQ的区别(kafka跟rabbitmq的区别)
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- powershellfor (55)
- messagesource (56)
- aspose.pdf破解版 (56)
- promise.race (63)
- 2019cad序列号和密钥激活码 (62)
- window.performance (66)
- qt删除文件夹 (72)
- mysqlcaching_sha2_password (64)
- ubuntu升级gcc (58)
- nacos启动失败 (64)
- ssh-add (70)
- jwt漏洞 (58)
- macos14下载 (58)
- yarnnode (62)
- abstractqueuedsynchronizer (64)
- source~/.bashrc没有那个文件或目录 (65)
- springboot整合activiti工作流 (70)
- jmeter插件下载 (61)
- 抓包分析 (60)
- idea创建mavenweb项目 (65)
- vue回到顶部 (57)
- qcombobox样式表 (68)
- vue数组concat (56)
- tomcatundertow (58)
- pastemac (61)
本文暂时没有评论,来添加一个吧(●'◡'●)