客户端公共配置 DefaultMQProducer、 TransactionMQProducer、 DefaultMQPushConsumer、 DefaultMQPullConsumer 都继承于ClientConfi…

目录 手动创建topic 发送消息(同步) 发送消息(异步)   手动创建topic   topic是broker中的一个个分组,如果设置topic自动创建的话如果创建多了，可能会影响电脑的运行速度，…

RocketMQ的介绍 RocketMQ版本发展 Metaq1.x是RocketMQ前身的第一个版本，本质上把Kafka做了一次java版本的重写（Kafka是scala语言开发）。 Meta2.x，主要是对存储部分进行…

楔子：新一天的旅程，掠过天空海湾，越过低谷高山，跃过深渊浅滩，在天南地北，走两江四岸，与日月星辰，看锦绣山河。   1. 两种消费模式 RocketMQ 有两种消费模式： 集群消费模式：CLUSTERING，可…

前言 生产者和消费者是消息队列的两个重要角色，生产者向消息队列写人数据， 消费者从消息队列里读取数据。本篇讲解两种类型的消费者，一个是 DefaultMQPushConsumer，由系统控制读取操作，收到消息后自动调用传…

文章目录 场景分析 全局顺序消费 局部顺序消费 Demo Producer Demo Normal Consumer Demo Order Consumer Demo 源码分析 锁定MessageQueue 客户端实现 …

一、 MQ背景&选型 消息队列作为高并发系统的核心组件之一，能够帮助业务系统解构提升开发效率和系统稳定性。主要具有以下优势： 削峰填谷（主要解决瞬时写压力大于应用服务能力导致消息丢失、系统奔溃等问题） 系统解耦（…

文章摘要：在发送消息给RocketMQ后，消费者需要消费。消息的消费比发送要复杂一些，那么RocketMQ是如何来做的呢？ 在RocketMQ系列文章的前面几篇幅中已经对其“RPC通信部分”和“普通消息发送”两部分进行了…

这篇文章写成距今(201808)已经两年半了，其中的内容我已经不能保证是否已经过时，由于当前的业务中也没有在使用RocketMQ，因此很少有时间再去刨代码，很多实践方面的问题也不能很好的为大家解决。因此，建议大家权当入门…

概述     其实一直想写一篇rocketMq和kafka在架构设计上的差别，但是一直有个问题没搞明白所以迟迟没动手，今天无意中听人点播了一下似乎明白了这个问题，所以就有了这篇对比。   &…

关于RocketMQ的基本原理与实践，可拜读大神的文章：分布式开放消息系统(RocketMQ)的原理与实践 大神的文章分析了RocketMQ实现顺序消息的原理，由此引出一个新问题：如何解决重复消息问题？ 大神给出的回答是…