Esempio di Disruptor.NET

Question

Sto cercando di imparare come utilizzare il framework di messaggistica Disruptor.NET e non riesco a trovare alcun esempio pratico. Ci sono alcuni articoli là fuori con le immagini su come funziona, ma non riesco a trovare da nessuna parte che in realtà vada e ti mostra come implementare i metodi. Quale sarebbe un esempio?

Answer 1

Frustrato che non riuscivo a trovare un "Hello World" funzionante per Disruptor-net, ho smanettato fino a quando non ne ho avuto uno funzionante - vedi sotto. Spero che sia abbastanza auto-esplicativo. Le linee Console.WriteLine sono utili per vedere come funzionano le cose, ad esempio che RingBuffer crea ogni istanza di entrata all'avvio (che ha senso).

Spero che questo aiuti chiunque cerchi aiuto con Disruptor su .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

C'è un post sul blog dettagliata sul modello Disruptor, The Latency Issue. Dimostra come iniziare e utilizzare Disruptor in dettaglio.