disruptor是一個JAVA高效能併發框架，為什麼快，原理是什麼這類的話題百度有很多文件描述，這裡不再重複。

本文的目的是把實際如何使用這一框架解決實際工作中遇到的問題儘可能的詳細介紹。

本文使用的disruptor版本是3.3.2。

新建一個簡單的disruptor工程。

一，構建工程

普通java工程，web工程都可以。這裡例項使用java工程。

新建一個普通的maven工程，在pom檔案裡寫入如下依賴

</span><dependency>
			<groupId>com.lmax</groupId>
			<artifactId>disruptor</artifactId>
			<version>3.3.2</version>
		</dependency>
 

工程build之後，即可在依賴裡面看到disruptor的依賴包。

二，基本程式碼編寫

2.1，首先先建立一個Event類。該類的作用就用來傳遞資料。如下：

public class LongEvent {
	private long value;
    public long getValue() { 
        return value; 
    } 
 
    public void setValue(long value) { 
        this.value = value; 
    } 
}

2.2，建立EventFactory介面的實現類

import com.lmax.disruptor.EventFactory;

public class LongEventFactory implements EventFactory<LongEvent> {

	@Override
	public LongEvent newInstance() {
		return new LongEvent(); 
	}

}

2.3，再來建立一個事件實現類，這裡我們預設建立一個 EventHandler；

import java.util.Date;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.lmax.disruptor.EventHandler;

public class LongEventHandler implements EventHandler<LongEvent> {
	private static final Logger LOG =  LoggerFactory
			.getLogger(LongEventHandler.class);
	@Override
	public void onEvent(LongEvent longEvent, long sequence, boolean endOfBatch)
			throws Exception {
		boolean chk = true;
		long l = longEvent.getValue();
		LOG.info("開始處理" + l + "");
		Date dtStart = new Date();
		
		while(chk){
			Date dt = new Date();
			if(dt.getTime() - dtStart.getTime() >=20){
				chk = false;
				LOG.info("結束處理" + l + "");
			}
		}
	}
}
 

2.4，最後，我們來建立一個disruptor，來啟動事件

public static void main(String[] args) throws InterruptedException {
		Executor executor = Executors.newCachedThreadPool();
		LongEventFactory factory = new LongEventFactory();
		int bufferSize = 1024;
		Disruptor<LongEvent> disruptor = new Disruptor<LongEvent>(factory,
				bufferSize, executor, ProducerType.SINGLE,
				new SleepingWaitStrategy());

		disruptor.handleEventsWith(new LongEventHandler() );
		disruptor.start();
		// 啟動
		RingBuffer<LongEvent> ringBuffer = disruptor.getRingBuffer();
		LongEventProducer producer = new LongEventProducer(ringBuffer);
		for (long l = 0; l < 3; l++) {
			long sequence = ringBuffer.next();
			try {
				LongEvent event = ringBuffer.get(sequence);
				event.setValue(l);
			} finally {
				// 釋出事件
				ringBuffer.publish(sequence);
			}
			Thread.sleep(1000);
		}
	}

2015-06-04 23:18:12,146 INFO [com.xuyang.test.disruptor.LongEventHandler] batch開始處理0
2015-06-04 23:18:12,168 INFO [com.xuyang.test.disruptor.LongEventHandler] batch結束處理0
2015-06-04 23:18:13,145 INFO [com.xuyang.test.disruptor.LongEventHandler] batch開始處理1
2015-06-04 23:18:13,165 INFO [com.xuyang.test.disruptor.LongEventHandler] batch結束處理1
2015-06-04 23:18:14,149 INFO [com.xuyang.test.disruptor.LongEventHandler] batch開始處理2
2015-06-04 23:18:14,169 INFO [com.xuyang.test.disruptor.LongEventHandler] batch結束處理2