Disruptor.NET ejemplo

Question

Estoy tratando de aprender a usar el marco de mensajería Disruptor.NET, y no puedo encontrar ningún ejemplo práctico. Hay bastantes artículos con imágenes sobre cómo funciona, pero no puedo encontrar ningún lugar que realmente funcione y le muestra cómo implementar los métodos. ¿Qué sería un ejemplo?

Answer 1

Frustrado de que no pude encontrar un 'Hola mundo' viable para Disruptor-net, jugueteé hasta que conseguí uno funcionando - ver abajo. Es de esperar que sea bastante auto explicativo. Las líneas Console.WriteLine son prácticas para ver cómo funcionan las cosas, por ejemplo, que RingBuffer crea cada instancia de entrada al inicio (lo cual tiene sentido).

Espero que esto ayude a cualquiera que busque ayuda con Disruptor en .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

Hay una entrada en el blog detallada sobre el patrón disruptor, The Latency Issue. Demuestra cómo comenzar y usar Disruptor en detalle.