首页标签消息队列 MQ

#消息队列 MQ

高可用、高并发、高可扩展、低延时的分布式消息队列服务

Redis发布订阅:我想着应该是全网讲解最简单最通俗的文章了吧!

我是阿沐

可能小伙伴的工作年限大部分已经超过三年甚至四年五年,不知道是否有一种危机感,我们写了那么多的需求代码没有20w行也有个10w行了吧,但是出去找工作的时候不是笔试...

8400

高可用DevHa实践,告诉你生产环境0性能故障是如何做到的!

数列科技

导读:近日,数列科技CTO陆学慧参加ArchSummit全球架构师峰会,并进行了题为《0性能故障是如何做到的:高可用性能领域的DevHA实践》的主题演讲,详细介...

9820

5、深潜KafkaProducer——Sender线程

杨四正

通过上一课时的介绍我们了解到,业务线程通过 KafkaProducer.send() 方法将 message 放入 RecordAccumulator 中进行能...

9600

玩转直播系列之消息模块演进(3)

2020labs小助手

vivo · 技术编辑 (已认证)

即时消息(IM)系统是直播系统重要的组成部分,一个稳定的,有容错的,灵活的,支持高并发的消息模块是影响直播系统用户体验的重要因素。IM长连接服务在直播系统有发挥...

12540

3、深潜 kafka producer —— 核心架构

杨四正

kafka 自定义了一套网络协议,我们可以使用任意语言来实现这套协议,实现向 kafka 集群 push message 以及从 kafka 集群 pull m...

7500

如何让消息队列达到最大吞吐量?

kevwan

最佳吞吐量是让其中之一打满,而一般情况下内网带宽都会非常高,不太可能被打满,所以自然就是讲消息队列的写入速度打满,这就就有两个点需要平衡

19430

python大型项目后台异步这一篇就够了

python编程从入门到实践

点击python编程从入门到实践,置顶 公众号重磅 python入门资料,第一时间送达

6440

Kafka 是怎么存储的?为什么速度那么快?

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

Kafka 依赖于文件系统(更底层地来说就是磁盘)来存储和缓存消息。在我们的印象中,对于各个存储介质的速度认知大体同下图所示的相同,层级越高代表速度越快。很显然...

15781

消息的前生今世——从rabbimq的一条消息的生命周期引出的思考

Yerik

作为中间件的杠把子选手,rabbimq在系统架构中承担着承上启下的作用,常问到,你们为何选用rabbimq?则答曰,为了削峰填谷,为了系统解耦合,为了提高系统性...

31200

Kafka 生产者哪些重要的参数是我们需要注意的?

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

在 KafkaProducer 中大部分的参数都有合理的默认值,一般不需要修改它们。不过了解这些参数可以让我们更合理地使用生产者客户端,其中还有一些重要的参数涉...

9870

Kafka 在哪些场景下会造成重复消费或消息丢失?

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

kafka消费者在消费的时候对于位移提交的具体时机的把握也很有讲究,有可能会造成重复消费和消息丢失的现象。

9760

Kafka 在哪些场景下会造成重复消费或消息丢失?

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

kafka消费者在消费的时候对于位移提交的具体时机的把握也很有讲究,有可能会造成重复消费和消息丢失的现象。

8750

Kafka 消费者提交消费位移时提交的是当前消费到的最新消息的 offset 还是 offset+1?

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

对于 Kafka 中的分区而言,它的每条消息都有唯一的 offset,用来表示消息在分区中对应的位置。对于消费者而言,它也有一个 offset 的概念,消费者使...

9460

开发 Kafka 消费者客户端需要注意哪些事项?

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

在了解了消费者与消费组之间的概念之后,我们就可以着手进行消费者客户端的开发了。在 Kafka 的历史中,消费者客户端同生产者客户端一样也经历了两个大版本:第一个...

11040

怎么理解 Kafka 消费者与消费组之间的关系?

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

与生产者对应的是消费者,应用程序可以通过 KafkaConsumer 来订阅主题,并从订阅的主题中拉取消息。不过在使用 KafkaConsumer 消费消息之前...

11450

图解分析:Kafka 生产者客户端工作原理

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

消息在真正发往 Kafka 之前,有可能需要经历拦截器、序列化器和分区器等一系列的作用,前面已经做了一系列分析。那么在此之后又会发生什么呢?先看一下生产者客户端...

11161

Kafka 发送消息过程中拦截器的用途?

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

消息在通过 send() 方法发往 broker 的过程中,有可能需要经过拦截、序列化器 和 分区器 的一系列作用之后才能被真正地发往 broker。

11051

图解分析:Kafka 生产者客户端工作原理

码农架构

蚂蚁科技集团股份有限公司 · 高级软件架构师 (已认证)

消息在真正发往 Kafka 之前,有可能需要经历拦截器、序列化器和分区器等一系列的作用,前面已经做了一系列分析。那么在此之后又会发生什么呢?先看一下生产者客户端...

15380

使用 Docker 部署 RabbitMQ 没有日志?添加这两条配置,轻松搞定

AlwaysBeta

使用 Docker 部署完 RabbitMQ 服务,到 /var/log/rabbitmq 目录下一看,空空如也,并没有日志文件生成。

12010

CMQ测试TOPIC报错

大大刺猬

{"code":6000,"message":"(10050)server internal error","requestId":"2077840488935...

15240

扫码关注云+社区

领取腾讯云代金券