Description
This project aims to provide the full functionality of the Disruptor to CLR projects.
.NET port of LMAX Disruptor alternatives and similar packages
Based on the "Distributed Computing" category
-
Akka.net
Akka.NET is a port of the popular Java/Scala framework Akka to .NET. This is a community driven port and is not affiliated with Typesafe who makes the original Java/Scala version. -
Orleankka
Orleankka is a functional API for Microsoft Orleans framework. It is highly suitable for scenarios where having composable, uniform communication interface is preferable, such as: CQRS, event-sourcing, re-routing, FSM, etc. Additional API avaiable for F# called Orleankka.FSharp. -
Zebus
Zebus is a lightweight, higlhy versatile, peer to peer service bus, built with CQRS principles in mind. It allows applications to communicate with each other in a fast and easy manner. Most of the complexity is hidden in the library and you can focus on writing code that matters to you, not debugging messaging code. A very fundamental base for any distributed application. -
FsShelter
F# library for authoring Apache Storm components and topologies. Offering high-level abstractions for distributed and fault-tolerant event stream processing.
* Code Quality Rankings and insights are calculated and provided by Lumnify.
They vary from L1 to L5 with "L5" being the highest. Visit our partner's website for more details.
Do you think we are missing an alternative of .NET port of LMAX Disruptor or a related project?
README
Disruptor-net
Overview
The Disruptor is a high performance inter-thread message passing framework. This project is the .NET port of LMAX Disruptor.
The Disruptor can be succinctly defined as a circular queue with a configurable sequence of consumers. The key features are:
- Zero memory allocation after initial setup (the events are pre-allocated).
- Push-based consumers.
- Optionally lock-free.
- Configurable wait strategies.
Most of the information from the Java documentation is applicable to the .NET version, especially the core concepts.
The quickest way to get started with the disruptor is by using the NuGet package.
Sample code
First, you need to define your event (message) type:
public class SampleEvent
{
public int Id { get; set; }
public double Value { get; set; }
}
You also need to create a consumer:
public class SampleEventHandler : IEventHandler<SampleEvent>
{
public void OnEvent(SampleEvent data, long sequence, bool endOfBatch)
{
Console.WriteLine($"Event: {data.Id} => {data.Value}");
}
}
Then you can setup the Disruptor:
var disruptor = new Disruptor<SampleEvent>(() => new SampleEvent(), bufferSize: 1024);
disruptor.HandleEventsWith(new SampleEventHandler());
disruptor.Start();
Finally, you can publish events:
using (var scope = disruptor.PublishEvent())
{
var data = scope.Event();
data.Id = 42;
data.Value = 1.1;
}
Other event publication options are described in the Wiki.
Roadmap
- Include latest changes made to the future Java versions
- Remove exception-based APIs
- Improve documentation
Build from source and run tests
You may build the Disruptor directly from the source, run Cake-Build.bat: it will compile, run the tests and output binaries and results into \output\assembly folder
You can also run all the performance tests by running Cake-Perf.bat.
License
Copyright Olivier Deheurles
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this project except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
*Note that all licence references and agreements mentioned in the .NET port of LMAX Disruptor README section above
are relevant to that project's source code only.