Пример disruptor.NET

Question

Я пытаюсь узнать, как использовать инфраструктуру обмена сообщениями Disruptor.NET, и я не могу найти никаких практических примеров. Существует немало статей с фотографиями о том, как это работает, но я не могу найти нигде, что действительно происходит, и показывает вам, как реализовать методы. Какой пример?

Answer 1

Разочарованный, что я не смог найти работоспособный «Hello World» для Disruptor-net, я поиграл, пока не получил работу, как показано ниже. Надеюсь, это довольно понятно. Строки Console.WriteLine удобны для просмотра того, как все работает - например, RingBuffer создает каждый экземпляр записи при запуске (что имеет смысл).

Надеюсь, что это поможет любому, кто ищет помощь с Disruptor на .NET.

using System; 
using System.Linq; 
using System.Threading; 
using System.Threading.Tasks; 
using Disruptor; 
using Disruptor.Dsl; 

namespace DisruptorTest 
{ 
    public sealed class ValueEntry 
    { 
     public long Value { get; set; } 

     public ValueEntry() 
     { 
      Console.WriteLine("New ValueEntry created"); 
     } 
    } 

    public class ValueAdditionHandler : IEventHandler<ValueEntry> 
    { 
     public void OnNext(ValueEntry data, long sequence, bool endOfBatch) 
     { 
      Console.WriteLine("Event handled: Value = {0} (processed event {1}", data.Value, sequence); 
     } 
    } 

    class Program 
    { 
     private static readonly Random _random = new Random(); 
     private static readonly int _ringSize = 16; // Must be multiple of 2 

     static void Main(string[] args) 
     { 
      var disruptor = new Disruptor.Dsl.Disruptor<ValueEntry>(() => new ValueEntry(), _ringSize, TaskScheduler.Default); 

      disruptor.HandleEventsWith(new ValueAdditionHandler()); 

      var ringBuffer = disruptor.Start(); 

      while (true) 
      { 
       long sequenceNo = ringBuffer.Next(); 

       ValueEntry entry = ringBuffer[sequenceNo]; 

       entry.Value = _random.Next(); 

       ringBuffer.Publish(sequenceNo); 

       Console.WriteLine("Published entry {0}, value {1}", sequenceNo, entry.Value); 

       Thread.Sleep(250); 
      } 
     } 
    } 
} 

Answer 2

Существует подробный блог по образцу Disruptor, The Latency Issue. Он демонстрирует, как начать работу и использовать Disruptor в деталях.