写在前面 _作者Doug Lea_如此描述这个类：A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads com ...
QMQ源码分析之Actor
发表于
|
分类于
技术分享
前言 QMQ有关actor的一篇文章阐述了actor的应用场景。即client消费消息的请求会先进入一个RequestQueue，在client消费消息时，往往存在多个主题、多个消费组共享一个RequestQueue消费消息。在这个Queue中，存在不同主题的有不同消费组数量，以及不同消费组有不同 ...
QMQ源码分析之delay-server篇【三】
发表于
|
分类于
技术分享
前言 上篇我们分析了QMQ delay-server关于存储的部分，这一篇我们会对投递的源码进行分析。 投递投递的相关内容在WheelTickManager这个类。提前加载schedule_log、wheel根据延迟时间到时进行投递等相关工作都在这里完成。而关于真正进行投递的相关类是在send ...
QMQ源码分析之delay-server篇【二】
发表于
|
分类于
技术分享
前言 本来是固定时间周六更博，但是昨天临时失恋了，所以心情不好，晚了一天。那么上一篇我们梳理了下QMQ延迟消息的主要功能，这一篇在此基础上，对照着功能分析一下源码。 整体结构要了解delay-server源码的一个整体结构，需要我们跟着源码，从初始化开始简单先过一遍。重试工作都在startup ...
QMQ源码分析之delay-server篇【一】
发表于
|
分类于
技术分享
前言 QMQ是一款去哪儿网内部使用多年的mq。不久前(大概1-2年前)已在携程投入生产大规模使用，年前这款mq也开源了出来。关于QMQ的相关设计文章可以看这里。在这里，我假设你已经对QMQ前世今生以及其设计和实现等背景知识已经有了一个较为全面的认识。 我的阅读姿势对一款开源产品愈来愈感兴趣，想 ...