当前位置：文江博客话题详情

Disruptor.NET 示例

发布于 2024-12-26 17:55:42 字数 103 浏览 0 评论 0原文

我正在尝试学习如何使用 Disruptor.NET 消息传递框架，但找不到任何实际示例。有很多文章带有关于其工作原理的图片，但我找不到任何实际可以向您展示如何实现这些方法的地方。举个什么例子？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

油焖大侠 2025-01-02 17:55:42

由于无法为 Disruptor-net 找到一个可行的“Hello World”，我感到很沮丧，所以我一直在摆弄，直到找到一个可以工作的。见下文。 Console.WriteLine 行可以方便地查看事情是如何工作的。例如，RingBuffer 在启动时创建每个条目实例（这是有道理的）。

希望这可以帮助任何在 .NET 上寻求 Disruptor 帮助的人。

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 power 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);
            }
        }
    }
}

Frustrated that I couldn't find a workable 'Hello World' for Disruptor-net, I fiddled around until I got one working. See below. The Console.WriteLine lines are handy for seeing how things work. For example, the RingBuffer creates each entry instance at start-up (which makes sense).

Hopefully this helps anyone looking for help with 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 power 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);
            }
        }
    }
}

回复收藏 0 原文