一篇文章把RabbitMQ、RocketMQ、Kafka三元归一(二)

一篇文章把RabbitMQ、RocketMQ、Kafka三元归一(二)

KafkaKafka是一个分布式、支持分区的、多副本的, 基于ZooKeeper 协调的分布式消息系统。它最大的特性就是可以实时的处理大量数据以满足各种需求场景:比如基于Hadoop的批处理系统、低延迟的实时系统、Storm/Spark流式处理引擎,Web/Nginx日志、访问日志,消息服务等等,用...

一篇文章把RabbitMQ、RocketMQ、Kafka三元归一(一)

一篇文章把RabbitMQ、RocketMQ、Kafka三元归一(一)

RabbitMQRabbitMQ各组件的功能Broker :一个RabbitMQ实例就是一个BrokerVirtual Host :虚拟主机。相当于MySQL的DataBase ,一个Broker上可以存在多个vhost,vhost之间相互隔离。每个vhost都拥有自己的队列、交换机、绑定和权限机制...

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图
消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(下)

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(下)

就是来了波狸猫换太子,其实延时消息也是这么实现的,最终将换了皮的消息入盘。Broker 处理提交或者回滚消息的处理方法是 EndTransactionProcessor#processRequest,我们来看一看它做了什么操作。可以看到,如果是提交事务就是把皮再换回来写入真正的topic所属的队列中...

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(上)

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(上)

每个时代,都不会亏待会学习的人。大家好,我是 yes。今天我们来谈一谈消息队列的事务消息,一说起事务相信大家都不陌生,脑海里蹦出来的就是 ACID。通常我们理解的事务就是为了一些更新操作要么都成功,要么都失败,不会有中间状态的产生,而 ACID 是一个严格的事务实现的定义,不过在单体系...

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(下)

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(下)

Kafka 中的长轮询像 Kafka 在拉请求中有参数,可以使得消费者请求在 “长轮询” 中阻塞等待。简单的说就是消费者去 Broker 拉消息,定义了一个超时时间,也就是说消费者去请求消息,如果有的话马上返回消息,如果没有的话消费者等着直到超时,然后再次发起拉消息请求。并且 Broker 也得配合...

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(上)

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(上)

每个时代,都不会亏待会学习的人大家好,我是 yes。今天我们就来谈一谈消息队列的推拉模式,这也是一个面试热点,例如你在简历里面写了 RocketMQ ,基本上会问你 RocketMQ 采用的是推模式还是拉模式啊?是拉模式?不是有 PushConsumer 吗?今天我们就来谈谈推拉模式&...

RabbitMQ、RocketMQ、Kafka应该如何选择?

RabbitMQ、RocketMQ、Kafka应该如何选择?分别适用于哪些场景?

RocketMQ/Kafka等消息队列复制的最佳实践

MQ在Pro、Con端,依靠业务代码,配合请求确认机制保证在服务端,采用持久化和复制保证不会丢消息。把消息复制到多节点,可解决丢消息问题保证消息服务的HA所以都会把MQ配置成集群模式,并开启消息复制。那么消息复制需要解决哪些问题呢?1 消息复制的指标期望MQ具备高性能、高可用和数据一致性。很多MQ都...

消息中间件ActiveMQ、RabbitMQ、RocketMQ、ZeroMQ、Kafka如何选型?

消息中间件ActiveMQ、RabbitMQ、RocketMQ、ZeroMQ、Kafka如何选型?

最近要为公司的消息队列中间件进行选型,市面上相关的开源技术又非常多,如ActiveMQ、RabbitMQ、ZeroMQ、Kafka,还有阿里巴巴的RocketMQ等。这么多技术,如何进行选型呢?首先对于阿里的RocketMQ,因为是阿里开源的,对于国内开源的保持谨慎的态度,暂时不采取该...

将 Flink 融合进消息系统,RocketMQ 为什么选择了与 Kafka 不一样的路

将 Flink 融合进消息系统,RocketMQ 为什么选择了与 Kafka 不一样的路

5.0 版本进行了架构重塑,新增或者修改了超过 60% 的代码,但是对 4.0 的所有功能以及整体架构进行了无缝兼容,且没有引入任何外部依赖。而且其中非常重要的一点是,RocketMQ 兼容了开源 Flink 生态。与 Kafka 只是作为 Flink 的上下游数据不同,RocketMQ 直接实现了...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载