发表于 | 分类于 |
“Java进程咋又突然没了？还没任何报错，都好几天了好奇怪啊。”上午刚上班不久，旁边的同事就遇到了棘手的技术问题。大概打听下，原来是某个Java应用在执行某个耗时的定时任务的过程中，大概率进程会突然退出，而且应用日志、中间件日志都找不到任何异常。听起来还挺有意思，我默默地登上了出问题的docker容 ...
阅读全文 »

发表于 | 分类于 |
今天和大家聊一聊Disruptor中的RingBuffer。代码版本基于3.3.6，逻辑和3.4.x变化不大。 0x01 Disruptor中的RingBufferRingBuffer在Disruptor早期功能比较多，承载着数据存储、生产消费的数据交换等任务。现在只保留了存储的能力，像发布数据这些 ...
阅读全文 »

发表于 | 分类于 |
之前我们已经熟悉了Disruptor的启动和事件生产操作，接下来我们一同探究Disruptor如何消费事件。 0x00 概念回顾我们先回顾下Disruptor消费相关的名词概念：Event： Disruptor中传输的事件。RingBuffer： 存储和更新事件的容器。EventHandler： 用 ...
阅读全文 »

发表于 | 分类于 |
0x00 背景介绍最近遇到了一个消息队列阻塞的问题，查了好几天，才终于把这个问题解决。首先交代下我们的环境：支付业务，使用ActiveMQ配合Spring-jms收发消息，Spring版本3.2.16.RELEASE，ActiveMQ客户端版本5.11.1，ActiveMQ服务端版本5.13.2。消 ...
阅读全文 »

发表于 | 分类于 |
之前我们一起分析了Disruptor的初始化和启动代码，接下来我们来分析下生产者的发布代码。还不太了解的同学建议看看我之前发的Disruptor原理翻译和导读文章，尤其是一些名词概念最好要清楚是做什么用的。 1 生产者线程生产者一般就是我们的应用线程，在发布通常使用一个EventTranslator ...
阅读全文 »

发表于 | 分类于 |
解读Disruptor源码系列文章将从一个demo入手，逐步探究Disruptor中的源码实现。对原理不熟悉的同学建议先看我之前的两个翻译和导读文章。对Disruptor源码感兴趣的同学，可以下载我注释的Disruptor代码。 完整版Demo1234567891011121314151617181 ...
阅读全文 »

发表于 | 分类于 |
本篇文章是后续解读Disruptor源码的导读，适合对Disruptor还不了解的同学。如果有兴趣，还可以看下我之前发的Disruptor系列文章。要大概弄明白Disruptor是个什么玩意，可以先回答这几个问题：Disruptor是什么？为什么要用Disruptor？Disruptor为什么那么快 ...
阅读全文 »

发表于 | 分类于 |
本文是笔者在研究Disruptor过程中翻译的Disruptor1.0论文精选，中间穿插了一些感想和说明，均以“译注”的形式说明。论文原地址：https://lmax-exchange.github.io/disruptor/files/Disruptor-1.0.pdf Disruptor: 用于 ...
阅读全文 »

发表于 | 分类于 |
最近一直在忙着处理数据，以下是我作为python和数据分析的入门小白，在最近几周的工作中总结的一些经验。 Pandas高性能、简单易用的数据结构和数据分析工具 DataFrame/Series常用DataFrame构建DataFrame123456789df = pd.DataFrame(numpy ...
阅读全文 »