RocketMQ发送消息原理分析
1. 路由注册 RocketMQ路由注册是通过Broker与NameServer的心跳功能实现的。Broker启动后每隔30s向集群中所有NameServer发送心跳包，然后Name Server每隔10s扫描Broker信息，如果连续120s没有收到心跳包，NameServer将移除 ...
原文：RocketMQ原理分析&场景问题
硬核干货分享，欢迎关注 Java补习课 成长的路上，我们一起前行 高可用系列文章 已收录在专栏，欢迎关注 一 RocketMQ的基本原理 RocketMQ基本架构图如下 从这个架构图上我们可以知道，RocketMQ有 块核心部分： NameServer：管理Broker的信息，让使用MQ的系统感知到集群里面的broker Broker：主从架构实现数据多副本存储和高可用 producer：生产者 ...
2021-08-16 15:56 0 277 推荐指数：
相关推荐
rocketmq （一）运行原理以及使用问题
使用消息中间件可以解决高并发，那是因为消息中间件可以将消息缓存到队列之中。 但是 当消息 过多的时候,几万,几十万...消息中间件也可能会宕机,所以我们可以对消息中间件进行集群，在之前的active ...
RocketMQ延迟消息的代码实战及原理分析
RocketMQ简介 RocketMQ是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠、万亿级容量、灵活可伸缩的消息发布与订阅服务。 它前身是MetaQ，是阿里基于Kafka的设计使用Java进行自主研发的。在2012年，阿里将其开源 ...
RocketMQ延迟消息的代码实战及原理分析
RocketMQ简介 RocketMQ是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠、万亿级容量、灵活可伸缩的消息发布与订阅服务。 它前身是MetaQ，是阿里基于Kafka的设计使用Java进行自主研发的。在2012年，阿里将其开源， 在2016年，阿里将其捐献 ...
ThreadLocal 原理和使用场景分析
ThreadLocal 不知道大家有没有用过，但至少听说过，今天主要记录一下 ThreadLocal 的原理和使用场景。 使用场景 直接定位到 ThreadLocal 的源码，可以看到源码注释中有很清楚的解释：它是线程的局部变量，这些变量只能在这个线程内被读写，在其他线程内是无法访问 ...
DelayQueue实现原理及应用场景分析
DelayQueue基本原理DelayQueue是一个没有边界BlockingQueue实现，加入其中的元素必需实现Delayed接口。当生产者线程调用put之类的方法加入元素时，会触发Delayed接口中的compareTo方法进行排序，也就是说队列中元素的顺序是按到期时间排序的，而非它们进入 ...
ThreadLocal原理分析与使用场景
什么是ThreadLocal变量 ThreadLoal 变量，线程局部变量，同一个 ThreadLocal 所包含的对象，在不同的 Thread 中有不同的副本。这里有几点需要注意： 因为每 ...
RocketMQ原理
此篇幅将从以下几个方面来分析RocketMQ其中运作原理： 消息的生产 消息的存储 indexFile（客户端指定key） 消息的消费 订阅关系的一致性 offset管理 消费幂等 消息堆积与消费延迟 消息的清理 一、消息的生产 Producer可以将消息写入到某Broker中的某Queue中 ...