文章 2024-06-12 来自:开发者社区

【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka

1.概述 1.1.MQ简介 消息中间件,其实准确的叫法应该叫消息队列(message queue),简称MQ。其本质上是个队列,有FIFO的性质,即first in first out,先入先出。 目前市场上主流的MQ有三款: RabbitMQ RocketMQ Kafka 1.2.MQ的应用场景 MQ一般...

【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
文章 2024-05-15 来自:开发者社区

MQ产品使用合集之对于Kafka作为数据源的情况,官方比较推荐哪种使用方式

问题一:在MQTT中,微消息队列topic有规划可以自定义吗? 问下微消息队列topic有规划可以自定义吗? 参考回答: topic的设置支不支持+、#这种通配符 关于本问题的更多...

MQ产品使用合集之对于Kafka作为数据源的情况,官方比较推荐哪种使用方式
文章 2023-10-19 来自:开发者社区

MQ - 闲聊MQ一二事儿 (Kafka、RocketMQ 、Pulsar )

MQ的发展史如上图我们可以把消息队列的发展切分成了三个大的阶段阶段一:追求解耦2003-2010年,计算机软件行业兴起。系统间强耦合是程序设计的难题。ActiveMQ和RabbitMQ等消息队列出现。消息队列致力于解决系统间耦合和异步化操作问题。系统间解耦和异步化是消息队列最主要的功能和使用场景。阶段二:追求吞吐量与一致性10 -12 年期间,大数据时代实时计算需求增长,数据规模扩大,Kafka....

MQ - 闲聊MQ一二事儿 (Kafka、RocketMQ 、Pulsar )
文章 2023-09-02 来自:开发者社区

MQ相关(Kafka实现原理)

MQ是什么?消息队列,直接上定义可能不太好理解,咱们直接举几个生活的例子来说明这个消息队列都有啥妙用吧,先总的来说吧有以下几个用处:1.应用解耦,2.消息消峰,3.异步处理等,接着咱们来一个一个看看。解耦:比如,网购的东西,快递员送货给收货人,以前都要给收货人打电话问什么时候有时间,联系具体时间送货,后来我们现在都有快递柜或者便利店收快递,快递员只需要把快递放到代收点,代收点通知收件人来拿货即可....

MQ相关(Kafka实现原理)
文章 2023-08-15 来自:开发者社区

【MQ】Kafka如何保证幂等性

kafka默认情况下,提供的是至少一次的可靠性保障。即broker保障已提交的消息的发送,但是遇上某些意外情况,如:网络抖动,超时等问题,导致Producer没有收到broker返回的数据ack,则Producer会继续重试发送消息,从而导致消息重复发送。如果我们禁止Producer的失败重试发送功能,消息要么写入成功,要么写入失败,但绝不会重复发送。这样就是最多一次的消息保障模式。但对于消息组....

【MQ】Kafka如何保证幂等性
文章 2023-08-15 来自:开发者社区

【MQ】Kafka如何保证消息不丢失

没时间的朋友建议直接看总结Kafka存在丢消息的问题,消息丢失会发生在Broker,Producer和Consumer三种。Producer端保证消息不丢失为了提升效率,减少IO,producer在发送数据时可以将多个请求进行合并后发送。被合并的请求发送之前缓存在本地buffer中。但是,buffer中的数据是危险的。一旦producer被非法的停止了,那么buffer中的数据将丢失,broke....

文章 2023-08-15 来自:开发者社区

限时开源!阿里内部消息中间件合集:MQ+Kafka+体系图+笔记

近好多小伙伴说在准备金三银四的面试突击了,但是遇到消息中间件不知道该怎么学了,问我有没有成体系的消息中间件的学习方式。额,有点不知所措,于是乎小编就想着做一次消息中间件的专题,归类整理了一些纯手绘知识体系图、面试以及相关的学习笔记。先看下纯手绘知识体系图Kafka知识体系大纲由于我手绘这些知识体系大纲是用的xmind软件,无法上传,所以都以截图的形式展示,细节处不清楚(毕竟图片形式有限),不过可....

限时开源!阿里内部消息中间件合集:MQ+Kafka+体系图+笔记
文章 2023-07-29 来自:开发者社区

MQ 学习日志(四) kafka的选举机制

kafka的选举机制 一个Kafka集群中有多个Broker,最开始的时候,这些Broker中的有一个Broker会被选举为控制器(KafKa Controller),他负责管理整个集群中所有的分区和副本的状态,每个Topic的partition的多个Replication中只有一个Replication会被选举为Leader,...

MQ 学习日志(四) kafka的选举机制
问答 2023-05-26 来自:开发者社区

rocketmq和其他mq之间是否有性能压力测试报告。例如,Kafka

rocketmq和其他mq之间是否有性能压力测试报告。例如,Kafka 原提问者GitHub用户TsingLiang

问答 2023-05-03 来自:开发者社区

使用原生的mq发到kafka,binlog日志的数据为什么没有偏移量信息。。写代码的时候可以拿到偏移

如题,之前写过代码试过拿binlog日志,可以拿到该条binlog日志的偏移量。但是使用原生的mq发送到kafka里时候,只有数据操作的一些信息,没有这条信息在binlog的偏移量。 原提问者GitHub用户everior

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问