写点什么

消息队列

0 人感兴趣 · 205 次引用

  • 最新
  • 推荐

面试官:怎么保证 Kafka 的消息不丢失

这篇文章来聊一聊怎么保证Kafka的消息不丢失.首先,我们可以反向思考一下:Kafka什么情况下消息会丢失。本文将从broker和生产者还有消费者三个端来讨论一下什么情况下消息会丢失,再通过给出解决方案来处理这些丢失的情况。

8 张图带你全面了解 kafka 的核心机制

kafka是目前企业中很常用的消息队列产品,可以用于削峰、解耦、异步通信。特别是在大数据领域中应用尤为广泛,主要得益于它的高吞吐量、低延迟,在我们公司的解决方案中也有用到。既然kafka在企业中如此重要,那么本文就通过几张图带大家全面认识一下kafka,

https://static001.geekbang.org/infoq/8b/8b25a96fbd50dc343873db55c72c0713.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

从原理到实战,手把手教你在项目中使用 RabbitMQ

RabbitMQ 的文章之前写过,但是当时给的示例是 Demo 版的,这篇文章主要是结合之前写的理论知识,将 RabbitMQ 集成到技术派项目中。

代码实现 RabbitMQ 死信队列的创建

之前有写过死信队列的使用场景以及通过管控台创建死信。这次就通过代码实现死信队列的创建,同时也分享一下RabbitMQ封装的类。

面试官:如何保证 RabbitMQ 的消息可靠性

项目开发中经常会使用消息队列来完成异步处理、应用解耦、流量控制等功能。虽然消息队列的出现解决了一些场景下的问题,但是同时也引出了一些问题,其中使用消息队列时如何保证消息的可靠性就是一个常见的问题。如果在项目中遇到需要保证消息一定被消费的场景

云原生技术实践营「微服务 X 消息队列专场」

本次云原生技术实践营为大家带来微服务和消息队列专场,为大家带来这两种主流架构的技术干货和最佳实践。

阿里 RocketMQ 创始人首次分享出这份 RocketMQ 技术内幕神级架构手册

RocketMQ的开源正是源于对这种开源文化的认同,开放是为了更好的协同创新,并将这一技术推向新的高度。在经历了阿里巴巴集团内部多年“双11”交易核心链路工业级场景在验证,2016年11月,团队将RocketMQ捐献给全球享有盛誉的Apache软件基金会正式质为孵化项目

极客时间「大师课·深度剖析 RocketMQ5.0」上线啦,欢迎免费领取!

从初代开源消息队列崛起,到 PC 互联网、移动互联网爆发式发展,再如今 IoT、云计算、云原生引领了新的技术趋势,消息中间件的发展已经走过了 30 多个年头。

Spring Boot 整合 Redis 基于 Stream 消息队列 实现异步秒杀下单

字面意思就是存放消息的队列。最简单的消息队列模型包括3个角色:

爆肝 Java 九大核心专题,666 页内容,我收割了 5 个大厂 offer

随着 Java 开发的薪资的越来越高,越来越多人开始学习 Java 。

一个能在 Linux 下使用 C++ 编写的访问 RabbitMQ 接收发送数据的可编译代码

以下是一个简单的使用C++和AMQP-CPP库连接到RabbitMQ服务器并发送和接收消息的示例代码:

消息队列常见的使用场景

消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题

https://static001.geekbang.org/infoq/37/376c84eccfb336e3e158a5482b61fcaf.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

走进 RocketMQ(五)高性能文件读写

用户头像
白裤
04-12

上一次我们学习了RocketMQ的网络通信的机制与设计,今天将带着大家一起了解RocketMQ的文件读写方面的设计与优化,看看RocketMQ中对于文件的读写跟普通的文件读写有什么区别

https://static001.geekbang.org/infoq/41/41281d404e134f1eb2f03a3382e532f5.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

重新理解 RocketMQ Commit Log 存储协议

Consumer Queue Offset是连续的吗, Commit Log Offset是连续的吗?今天我们一起重新理解RocketMQ Commit Log存储协议。

面试官:kafka 分布式消息系统,你真的了解吗?

Kafka是Apache软件基金会开发的一个基于发布/订阅模式的分布式可靠性消息系统,用于处理实时和流数据。Kafka可以将数据实时地从一个系统移动到另一个系统,它可以支持从一个终端到另一个终端的数据流,并可以支持离线处理和批量处理。Kafka是一个分布式可靠性

RabbitMQ 延迟消息实战

现实生活中有一些场景需要延迟或在特定时间发送消息,例如智能热水器需要 30 分钟后打开,未支付的订单或发送短信、电子邮件和推送通知下午 2:00 开始的促销活动。

阿里云消息队列 Kafka 生态集成的实践与探索

Apache Kafka是一个分布式流平台,作为互联网领域不可或缺的消息组件,在全球获得了广泛的应用。在使用过程中,Kafka一般被作为消息流转的核心枢纽,上下游系统通过Kafka实现异步,削峰填谷。在大数据处理和实时数据处理领域Kafka也是不可替代的组件。

三天吃透 RabbitMQ 面试八股文

本文已经收录到Github仓库,该仓库包含计算机基础、Java基础、多线程、JVM、数据库、Redis、Spring、Mybatis、SpringMVC、SpringBoot、分布式、微服务、设计模式、架构、校招社招分享等核心知识点,欢迎star~

https://static001.geekbang.org/infoq/d0/d052fdd72e8280fb81c051b98977a7b5.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

【深度挖掘 RocketMQ 底层源码】「底层系列」深度挖掘 RocketMQ 底层导致消息丢失透析(Broker Busy 和 ToManyRequest)

通过上一篇文章《【深度挖掘 RocketMQ 底层源码】「底层问题分析系列」深度挖掘 RocketMQ 底层那些导致消息丢失的汇总盘点透析([REJECTREQUEST]》,我们知道了对应的“[REJECTREQUEST]system busy, start flow control for a while”的主要原因。

https://static001.geekbang.org/infoq/fb/fb537cfdfbd23ddcda7723c18079bc3f.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

【深度挖掘 RocketMQ 底层源码】「底层问题分析系列」深度挖掘 RocketMQ 底层那些导致消息丢失的汇总盘点透析([REJECTREQUEST]system busy, start flow control for a while)

最近因为项目的并发量以及数据的吞吐处理量越来越高,我们的RocketMQ的处理数据的能力,已经慢慢成为了我们的问题和瓶颈了,频繁会出现OOM的瓶颈问题,当然内存的问题我们可以扩充资源和调整配额就可以解决了,但是又出现了其他可怕的问题,消息会出现丢失的

三天吃透消息队列面试八股文

本文已经收录到Github仓库,该仓库包含计算机基础、Java基础、多线程、JVM、数据库、Redis、Spring、Mybatis、SpringMVC、SpringBoot、分布式、微服务、设计模式、架构、校招社招分享等核心知识点,欢迎star~

RocketMQ 消息重试机制、死信队列

消息队列中的消息消费时并不能保证总是成功的,那失败的消息该怎么进行消息补偿呢?这就用到今天的主角消息重试和死信队列了。

https://static001.geekbang.org/infoq/f0/f0cd3acb3f13b4b385c4434b6df734fc.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

【深度挖掘 RocketMQ 底层源码】「底层源码挖掘系列」抽丝剥茧贯穿 RocketMQ 的消费者端的运行核心的流程(Pull 模式 - 下)

承接【【深度挖掘 RocketMQ底层源码】「底层源码挖掘系列」透彻剖析贯穿RocketMQ的消费者端的运行核心的流程(Pull模式-上)】

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

最近好多小伙伴说在准备金三银四的面试突击了,但是遇到消息中间件不知道该怎么学了,问我有没有成体系的消息中间件的学习方式。

你都工作两年半了,还不会 RabbitMQ?

RabbitMQ 是一个由 Erlang 语言开发的 AMQP(高级消息队列协议) 的开源实现。

架构实战 - 模块 8 作业

用户头像
mm
01-28

设计消息队列存储消息数据的 MySQL 表格

消息队列_消息队列技术文章_InfoQ写作社区