wanber

消息队列

ElasticSearch(1) Java(19) JavaWeb(5) Netty系列(1) Python基础(3) 分布式系列(1) 前端全栈(6) 数据库(2) 未归档(29) 机器学习(4) 算法刷题(43) 精读JDK源码(3) 面经(4) 项目(1)

/ 注册

全部文章 / 消息队列（共6篇）

如何解决消息队列的延时？消息队列满了以后该怎么处理？

大量消息在 mq 里积压了几个小时了还没解决几千万条数据在 MQ 里积压了七八个小时，从下午 4 点多，积压到了晚上 11 点多。这个是我们真实遇到过的一个场景，确实是线上故障了，这个时候要不然就是修复 consumer 的问题，让它恢复消费速度，然后傻傻的等待几个小时消费完毕。这个肯定不能在面试...

2019-07-30

0 726

消息队列（五）：如何保证消息的顺序性？

先看看顺序会错乱的俩场景： RabbitMQ：一个 queue，多个 consumer。比如，生产者向 RabbitMQ 里发送了三条数据，顺序依次是 data1/data2/data3，压入的是 RabbitMQ 的一个内存队列。有三个消费者分别从 MQ 中消费这三条数据中的一条，结果消费者2先...

2019-07-30

0 1081

消息队列（四）：如何保证消息的可靠性传输？

数据的丢失问题，可能出现在生产者、MQ、消费者中，咱们从 RabbitMQ 和 Kafka 分别来分析一下吧。 RabbitMQ 生产者弄丢了数据生产者将数据发送到 RabbitMQ 的时候，可能数据就在半路给搞丢了，因为网络问题啥的，都有可能。此时可以选择用 RabbitMQ 提供的事务功...

2019-07-30

0 1064

消息队列（三）：如何保证消息不被重复消费？

说一说可能会有哪些重复消费的问题。首先，比如 RabbitMQ、RocketMQ、Kafka，都有可能会出现消息重复消费的问题，正常。因为这问题通常不是 MQ 自己保证的，是由我们开发来保证的。挑一个 Kafka 来举个例子，说说怎么重复消费吧。 Kafka 实际上有个 offset 的概念，就是...

2019-07-30

0 908

消息队列（二）：如何保证消息队列的高可用？

如果有人问到你 MQ 的知识，高可用是必问的。 RabbitMQ 的高可用性 RabbitMQ 是比较有代表性的，因为是基于主从（非分布式）做高可用性的，我们就以 RabbitMQ 为例子讲解第一种 MQ 的高可用性怎么实现。 RabbitMQ 有三种模式：单机模式、普通集群模式、镜像集群模式。单...

2019-07-30

0 658

消息队列（一）：消息队列优缺点及其选型

为什么使用消息队列使用消息队列的场景有很多，比较核心的有3个：解耦、异步、削峰。解耦如下场景，A系统要发送数据给BCD三个系统。如果新增E系统要调用A系统呢？如果过一段时间C系统不需要了呢？A系统负责人几乎要崩溃了... 在这个场景中，A 系统跟其它各种乱七八糟的系统严重耦合，A ...

2019-07-30

0 1029