Disruptor高性能缓存队列入门指导
Disruptor是什么,怎么使用,网上有很多教材,但有些过于复杂,剖析了Disruptor的方方面面,实际上对应普通的开发人员,使用这个工具,只需要指导知道大概原理和使用方法,并不需要知道非常深入的原理。
有些文章则是写了错误的实例,或者只是摘取了项目的一段代码,实际上,要把这些代码转化成项目的实际代码,却发现困难重重。
这个文章主要是针对想提高性能,在项目组使用Disruptor的开发人员写的,会简单讲解它的一些原理,尽量把代码简单,但又包括项目使用中必须的方方面面。
——Disruptor的使用场景
一个字,就是快,经过测试,Disruptor的速度比LinkedBlockingQueue提高了七倍。所以,当你在使用LinkedBlockingQueue出现性能瓶颈的时候,你就可以考虑采用Disruptor的代替。
当然,Disruptor性能高并不是必然的,所以,是否使用还得经过测试。
Disruptor的最常用的场景就是“生产者-消费者”场景,对场景的就是“一个生产者、多个消费者”的场景,并且要求顺序处理。
举个例子,我们从MySQL的BigLog文件中顺序读取数据,然后写入到ElasticSearch(搜索引擎)中。在这种场景下,BigLog要求一个文件一个生产者,那个是一个生产者。而写入到ElasticSearch,则严格要求顺序,否则会出现问题,所以通常意义上的多消费者线程无法解决该问题,如果通过加锁,则性能大打折扣。
——一个生产者,多消费者例子
在贴出代码之前,这里简单讲一下代码的结构和说明。简单的图示如下,先有Producer来作为生产者,发送事件。由EventHandler作为消费者,处理事件。
这个实例代码很简单,就是由生产者发送一个字符串到Disruptor,然后消费者处理该事件,并把字符串打印处理。
下面是各个Java类的说明:
HelloEventProducer:生产者,负责传递一个字符串,并发布事件
HelloEventHandler:消费者,负责消费事件,并打印字符串
HelloEventFactory:事件工厂类,负责初始化一个事件
HelloEvent:表示一个事件
DisruptorMain:运行的主程序,负责将整个逻辑连接起来
- package com.disruptor;
- import java.util.concurrent.ExecutorService;
- import java.util.concurrent.Executors;
- import com.lmax.disruptor.EventFactory;
- import com.lmax.disruptor.EventHandler;
- import com.lmax.disruptor.RingBuffer;
- import com.lmax.disruptor.WaitStrategy;
- import com.lmax.disruptor.YieldingWaitStrategy;
- import com.lmax.disruptor.dsl.Disruptor;
- import com.lmax.disruptor.dsl.ProducerType;
- public class DisruptorMain {
- public static void main(String[] args){
- ExecutorService executor = Executors.newFixedThreadPool(3);
- // WaitStrategy blockingWaitStrategy = new BlockingWaitStrategy();
- // WaitStrategy sleepingWaitStrategy = new SleepingWaitStrategy();
- WaitStrategy yieldingWaitStrategy = new YieldingWaitStrategy();
- EventFactory<HelloEvent> eventFactory = new HelloEventFactory();
- int ringBufferSize = 1024 * 1024;
- Disruptor<HelloEvent> disruptor = new Disruptor<HelloEvent>(eventFactory,
- ringBufferSize, executor, ProducerType.SINGLE
- , yieldingWaitStrategy);
- EventHandler<HelloEvent> eventHandler = new HelloEventHandler();
- disruptor.handleEventsWith(eventHandler);
- disruptor.start();
- RingBuffer<HelloEvent> ringBuffer = disruptor.getRingBuffer();
- HelloEventProducer producer = new HelloEventProducer(ringBuffer);
- for(long l = 0; l<100; l++){
- producer.onData("黄育源:Hello World!!!:" + l);
- }
- }
- }
- package com.disruptor;
- public class HelloEvent {
- private String value;
- public String getValue() {
- return value;
- }
- public void setValue(String value) {
- this.value = value;
- }
- }
- package com.disruptor;
- import com.lmax.disruptor.EventFactory;
- public class HelloEventFactory implements EventFactory<HelloEvent>{
- @Override
- public HelloEvent newInstance() {
- return new HelloEvent();
- }
- }
- package com.disruptor;
- import com.lmax.disruptor.EventHandler;
- public class HelloEventHandler implements EventHandler<HelloEvent>{
- @Override
- public void onEvent(HelloEvent event, long sequence, boolean endOfBatch) throws Exception {
- System.out.println(event.getValue());
- }
- }
- package com.disruptor;
- import com.lmax.disruptor.RingBuffer;
- public class HelloEventProducer implements Runnable{
- private final RingBuffer<HelloEvent> ringBuffer;
- public HelloEventProducer(RingBuffer<HelloEvent> ringBuffer){
- this.ringBuffer = ringBuffer;
- }
- /**
- * onData用来发布事件,每调用一次就发布一次事件
- * 它的参数会用过事件传递给消费者
- */
- public void onData(String str){
- long sequence = ringBuffer.next();
- System.out.println(sequence);
- try{
- HelloEvent event = ringBuffer.get(sequence);
- event.setValue(str);
- }finally{
- ringBuffer.publish(sequence);
- }
- }
- @Override
- public void run() {
- for(long l = 0; l<100; l++){
- this.onData("黄育源:Hello World!!!:" + l);
- }
- }
- }
转载于:https://www.cnblogs.com/kekexuanxaun/p/9480302.html
Disruptor高性能缓存队列入门指导相关推荐
- JAVA高性能内存队列-disruptor
JAVA内置队列 高性能内存队列-disruptor disruptor为啥这么快 无锁设计 内部采用CAS方式获取下一个任务序列号,没有锁竞争,不需要线程上下文切换 伪共享问题解决 当多线程修改互相 ...
- 高性能内存队列Disruptor
一.简介 Disruptor是英国外汇交易公司LMAX开发的一个高性能队列,研发的初衷是解决内存队列的延迟问题(在性能测试中发现竟然与I/O操作处于同样的数量级). 基于Disruptor开发的系统单 ...
- 如何快速实现分布式定时器丨红黑树|跳表|堆|时间轮|缓存|锁|事务|架构|高性能|消息队列丨C/C++Linux服务器开发丨C++后端开发
如何快速实现分布式定时器 视频讲解如下,点击观看: 如何快速实现分布式定时器丨红黑树|跳表|堆|时间轮|缓存|锁|事务|架构|高性能|消息队列丨C/C++Linux服务器开发丨C++后端开发丨中间件 ...
- java 手写 jvm高性能缓存
java 手写 jvm高性能缓存,键值对存储,队列存储,存储超时设置 缓存接口 1 package com.ws.commons.cache; 2 3 import java.util.functio ...
- Redis高性能缓存数据库
Redis高性能缓存数据库 Redis 基础入 Redis 介绍 特性 使用场景 正确安装与启动 重要的指令使用 全局命令 单线程架构 字符串 - String 内部编码 应用场景 哈希 - Hash ...
- osg自学笔记1——《OpenSceneGraph 快速入门指导》
这里写自定义目录标题 <OpenSceneGraph Quick Start Guide>学习笔记 1. 1.3 运行 osgviewer 2.1.5 场景图形初步 3. 1.6 Open ...
- Redis一通百通~P8架构师带你玩转Redis高性能缓存设计实战
前言 高并发十分考验架构师功底,它也是分布式架构设计中必须考虑的因素之一.要知道,光靠服务器堆是没有出路的. 想看看大牛是怎么面对高并发的?想知道BATJ大厂是怎么设计高可用架构的?这里有可参考的实践 ...
- 高性能缓存服务器 Nuster
Nuster 是一个基于 HAProxy 的高性能缓存服务器.Nuster 完全兼容 HAProxy,并且利用 HAProxy 的 ACL 功能来提供非常细致的缓存规则,比如 请求地址为某某时缓存 请 ...
- java高性能阻塞队列,Linux c/c 后台开发组建之:高性能阻塞队列
Linux c/c 后台开发组建之:高性能阻塞队列 (2015-12-01 06:01:47) 标签: Linux c/c 杂谈 分类: c/c 阻塞队列是后台开发中多线程异步架构的基本数据结构, ...
最新文章
- git常用命令的使用
- Jupyter notebook入门教程(上)
- java main是多线程的吗_Java多线程之线程及其常用方法
- php中改变函数路由,php – 如何修改codeigniter中的路由
- 最早的齿轮计算机,世界最古老“计算机”出土后110年,科学家终于解开它的秘密...
- 浅析Kerberos原理,及其应用和管理
- bootstrapr表格父子框_JS组件系列——表格组件神器:bootstrap table(二:父子表和行列调序)...
- 2013阿里技术嘉年华:阿里数据同步前世今生
- java 怎么获取object的数据_自学java,想将来从事大数据工作,现实吗?怎么学?...
- 分离圆环图显示百分比_excel这个百分比图,你不一定会制作
- MySQL主从同步的概述_MySQL主从同步原理介绍
- VMware系统运维(十一)部署虚拟化桌面 Horizon View 5.2 HTML ACCESS安装
- ubuntu上编译fortran_Ubuntu下安装Intel Fortran编译器(ifort)
- python 返回列表长度_Python通过len函数返回对象长度
- html缩小照片尺寸像素不变,怎么修改照片像素,但又不改变照片大小呢?——解决照片因大小无法上传的方案...
- 神舟战神换cpu教程_神舟战神能换什么cpu 神舟战神Z7可以换CPU吗
- 118、交换机配置规范
- 导出excel file-saver XLSX
- html5青蛙过河,[推荐]===PS4上的本地多人游戏推荐心得===家庭聚会,欢乐时光 (持续更新)...
- ubuntu 18.04 使用intel核显画面撕裂解决办法
热门文章
- 用VisualBrush定制复杂的按钮样式
- 大快HanLP自然语言处理技术介绍
- 勒索软件好多都使用恶意LNK链接文件欺骗用户 来看趋势科技分析新型LNK-PowerShell攻击...
- OpenResty(nginx)操作mysql的初步应用
- 第六课-Android四大组件之Activity
- 密钥怎么存储在数据库中
- [原创]利用WM_COPYDATA实现进程间通信
- .Net/C# 实现真正的只读的 Hashtable 类型的属性 (ReadOnly Hashtable Property)
- 批处理查找html,批处理(bat)实现全盘搜索指定文件获取其完整路径方法大全,bat大全分享...
- 485通讯的校验和_RS485通讯如何实现三菱PLC对三菱变频器的控制?