深入理解RocketMQ（四）--消息存储
一、MQ存储分类 MQ存储主要分为以下三类： 文件系统：RocketMQ/Kafka/RabbitMQ 关系型数据库DB：ActiveMQ（默认采用的KahaDB做消息存储）可选用JDBC的方式来做消息持久化 分布式KV存储：ZeroMQ 对比： 存储效率， 文件系统>分布式KV ...
原文：深入理解RocketMQ延迟消息
延迟消息是实际开发中一个非常有用的功能，本文第一部分从整体上介绍秒级精度延迟消息的实现思路，在第二部分结合RocketMQ的延迟消息实现，进行细致的讲解，点出关键部分的源码。第三步介绍延迟消息与消息重试的关系。 延迟消息介绍 基本概念：延迟消息是指生产者发送消息发送消息后，不能立刻被消费者消费，需要等待指定的时间后才可以被消费。 场景案例：用户下了一个订单之后，需要在指定时间内 例如 分钟 进行支 ...
2022-02-12 21:19 0 1723 推荐指数：
相关推荐
深入理解RocketMQ消息查询机制
在实际开发中，经常需要查看MQ中消息的内容，RocketMQ提供了多种消息查询方式，给开发和运维带来了极大的便利，一些其他消息中间件，如Kafka，并不具备消息查询能力。 本文对RocketMQ提供到的查询机制和背后原理进行深入的介绍。文章主要包括3个部分： 消息查询介绍：介绍消息查询 ...
深入理解RocketMQ（一）---阅读源码准备
本文主要描述使用Idea获取rocketMQ源码及源码的读取。 在演示搭建源码环境前，先简要描述一下RocketMQ的设计目标。 1、架构模式 和大多数消息中间件一样，采用的是发布订阅模式，基本组件包括：消息发送者、消息服务器（消息存储）、消息消费和路由发现 2、顺序消息 ...
RocketMQ定时（延迟）消息
RocketMQ 不支持任意时间自定义的延迟消息，仅支持内置预设值的延迟时间间隔的延迟消息。 预设值的延迟时间间隔为：1s、 5s、 10s、 30s、 1m、 2m、 3m、 4m、 5m、 6m、 7m、 8m、 9m、 10m、 20m、 30m、 1h、 2h 延时消息 ...
消息队列模型深入理解
消息队列模型深入理解 代码地址：消息队列模型测试代码 RabbitMQ提供了6种消息模型，但是第6种其实是RPC，并不是MQ，因此不予学习。那么也就剩下5种。 但是其实3、4、5这三种都属于订阅模型，只不过进行路由的方式不同。 2.1 基本消息模型 RabbitMQ是一个消息代理 ...
深入理解 Handler 消息机制
UI 和消息传递。不光在我们自己的应用中，在整个 Android 体系中，Handler 消息机制也是极 ...
深入理解Mysql数据库主从延迟
1什么会增加主从延迟？ 1 网络不好 2 从库硬件差 3 索引没做好，从库执行慢 4 从库锁等待，多见于myisam 5 主库写频繁，从库单线程执行慢 6 使用row复制，或mix使用行复制 2如何优化，减少延迟时间？ 1 如何写频繁，水平拆分，减少单片写数量 2 避免复杂DML操作 ...
深入理解JVM（③）低延迟的Shenandoah收集器
前言 Shenandoah作为第一款不由Oracle(包括一起的Sun)公司的虚拟机团队所领导开发的HotSpot垃圾收集器。是只存在于OpenJDK当中的，最初由RedHat公司创建的，在2014 ...