Disruptor helloworld的例子

我想学习Disruptor框架 。 谁可以给我一个helloworld示例，可以使用Java程序语言在main方法中运行？

Answer 1

这是一个如何使用Disruptor库的简单，可运行的示例。 使用Disruptor库的2.10.4版编写示例。

https://github.com/trevorbernard/disruptor-examples

我也在这个post上发布了： LMAX Disruptor最简单实际的示例代码

Answer 2

这里还有一个来自我身边。 我尝试了一个使用开源Lmax库的破坏程序示例。
我认为使用lmax disruptor（不是disruptor的内部）背后的想法是创建消息调度程序和注册事件监听器，如消费者。

您创建一个Disruptor，并指定消息类型。

Disruptor disruptor = new Disruptor(Message.EVENT_FACTORY, 2048, exec);` 

您创建一个处理程序

  final EventHandler handler = new EventHandler() { // event will eventually be recycled by the Disruptor after it wraps public void onEvent(final Message event, final long sequence, final boolean endOfBatch) throws Exception { Integer value = event.getMsg(); if(value % 10000 == 0){ System.out.println("ValueEvent: " + value + " Sequence: " + sequence); double timeINnanos = (System.nanoTime()-startTime); double timetaken = (timeINnanos/1e9); System.out.println("Time Taken till now in sec " + timetaken ); } } }; 

注册处理程序与disruptor

  disruptor.handleEventsWith(handler); 

启动该破坏程序并将返回的RingBuffer传递给您的生产者

  RingBuffer ringBuffer = disruptor.start(); Producer producer = new Producer(ringBuffer); 

完整的代码可以在这里找到Github链接

Answer 3

我建议你看一下LMAX代码LMAX源代码测试目录中的测试目录 。 在我看来，它是你可以用LMAX做的所有事情的最佳来源。 对于简单示例，请查看以下链接简单示例

我还建议你看一下DSL的例子。