Disruptor.NET 예제

Question

Disruptor.NET 메시징 프레임 워크를 사용하는 방법을 배우려고하는데 실용적인 예제를 찾을 수 없습니다. 어떻게 작동하는지에 대한 사진이있는 꽤 많은 기사가 있지만 실제로 갈 곳을 찾지 못하고 메서드를 구현하는 방법을 보여줍니다. 예를 들면?

Answer 1

Disruptor-net에 대해 'Hello World'를 찾을 수 없다는 사실에 좌절감을 느꼈습니다. 다행히도 그것은 자명하다. Console.WriteLine 라인은 물건이 어떻게 작동하는지보기에 편리합니다. 예를 들어, RingBuffer가 시작할 때 각 엔트리 인스턴스를 만듭니다 (이는 의미가 있습니다).

희망이 있으면 Disruptor on .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

스럽 패턴에 대한 자세한 블로그 게시물이 있습니다, The Latency Issue. Disruptor를 시작하고 사용하는 방법을 자세히 보여줍니다.