
发送普通消息 发送顺序消息 发送延迟消息 发送事务消息 发送单向消息 批量发送消息 | 消息类型 | 优点 | 缺点 | 备注 || 普通消息(...
下面以DefaultMQProducer.send(Message msg)接口讲解发送流程: 具体代码如下: 具体实现如下: 具体实现如下:
DefaultMQProducer是RocketMQ中默认的生产者实现,DefaultMQProducer的类之间的继承关系如下所示: 可以看到...
生产者原理 生产者概述 消息结构和消息类型 生产者高可用 1. 客户端保证机制 2. Broker端保证 (1)1个Slave掉电。Broker...
什么是消息队列 为什么需要消息队列 削峰填谷 程序间解耦 异步处理 数据的最终一致性 常见的消息队列 | 消息队列名字 | Apache Act...
1. 为什么要使用ConcurrentHashMap? ConcurrentHashMap是线程安全且高效的HashMap。在并发编程中,如...
与前面介绍的锁和volatile相比,对final域的读和写更像是普通的变量访问。下面将介绍final域的内存语义 1.final域的重排序规则...
众所周知,锁可以让临界区互斥执行,这里将介绍锁的另一个同样重要,但常常被忽视的功能:锁的内存语义 1.锁的释放-获取简历的happens-bef...
当声明共享变量为volatile后,对这个变量的读/写将会很特别。为了揭开volatile的神秘面纱,下面将介绍volatile的内存语义及其实...