Disruptor.NET उदाहरण

Question

मैं समझने की कोशिश कर रहा हूं कि Disruptor.NET मैसेजिंग फ्रेमवर्क का उपयोग कैसे करें, और मुझे कोई व्यावहारिक उदाहरण नहीं मिल रहा है। चित्रों के साथ वहां कुछ लेख हैं जो यह काम करता है, लेकिन मुझे वास्तव में कहीं भी नहीं मिल रहा है और आपको दिखाता है कि विधियों को कैसे कार्यान्वित किया जाए। एक उदाहरण क्या होगा?

Answer 1

निराश है कि मुझे विघटनकारी-नेट के लिए एक काम करने योग्य 'हैलो वर्ल्ड' नहीं मिल सका, मैं एक काम करने तक चारों ओर झुका हुआ - नीचे देखें। उम्मीद है कि यह काफी आत्म-व्याख्यात्मक है। Console.WriteLine लाइनें यह देखने के लिए आसान हैं कि चीजें कैसे काम करती हैं - उदाहरण के लिए, कि रिंगबफर स्टार्ट-अप (जो समझ में आता है) पर प्रत्येक प्रविष्टि उदाहरण बनाता है।

आशा है कि यह किसी को भी .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। यह दर्शाता है कि कैसे शुरू किया जाए और विघटनकर्ता को विस्तार से उपयोग करें।