客户端公共配置 DefaultMQProducer、 TransactionMQProducer、 DefaultMQPushConsumer、 DefaultMQPullConsumer 都继承于ClientConfi…
分类：RocketMQ
RocketMQ之手动创建Topic、发送消息(同步&异步)
目录 手动创建topic 发送消息(同步) 发送消息(异步) 手动创建topic topic是broker中的一个个分组,如果设置topic自动创建的话如果创建多了，可能会影响电脑的运行速度，…
【RocketMQ】RocketMQ快速入门
RocketMQ的介绍 RocketMQ版本发展 Metaq1.x是RocketMQ前身的第一个版本，本质上把Kafka做了一次java版本的重写（Kafka是scala语言开发）。 Meta2.x，主要是对存储部分进行…
RocketMQ进击（五）集群消费模式与广播消费模式
楔子：新一天的旅程，掠过天空海湾，越过低谷高山，跃过深渊浅滩，在天南地北，走两江四岸，与日月星辰，看锦绣山河。 1. 两种消费模式 RocketMQ 有两种消费模式： 集群消费模式：CLUSTERING，可…
【RocketMq实战第四篇】-不同类型消费者（DefaultMQPushConsumer&DefaultMQPullConsumer）
前言 生产者和消费者是消息队列的两个重要角色，生产者向消息队列写人数据， 消费者从消息队列里读取数据。本篇讲解两种类型的消费者，一个是 DefaultMQPushConsumer，由系统控制读取操作，收到消息后自动调用传…
RocketMQ-顺序消息Demo及实现原理分析
文章目录 场景分析 全局顺序消费 局部顺序消费 Demo Producer Demo Normal Consumer Demo Order Consumer Demo 源码分析 锁定MessageQueue 客户端实现 …
