Distribution 2.2.1

dotnet add package Distribution --version 2.2.1                
NuGet\Install-Package Distribution -Version 2.2.1                
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Distribution" Version="2.2.1" />                
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add Distribution --version 2.2.1                
#r "nuget: Distribution, 2.2.1"                
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install Distribution as a Cake Addin
#addin nuget:?package=Distribution&version=2.2.1

// Install Distribution as a Cake Tool
#tool nuget:?package=Distribution&version=2.2.1                

Distribution - Virtual Actor Framework

There is decent amount of actor-like frameworks, including those that support an idea of Virtual Actors, e.g. Orleans and Proto.Actor

The two mentioned frameworks are the most flexible but have some drawbacks, like extra build step or inability to use different transport protocol. Below is the list of features built in the current framework. Each of them can be considered as an advantage or a disadvantage depending on specific use-case.

Status

For virtual actors and reactive store

Install-Package Distribution

For clusters and interserver communication

Install-Package Distribution.Cluster

GitHub Workflow Status (with event) GitHub GitHub

Features

  • Safe single-threaded execution in a background worker without locks
  • Zero configuration
  • Local actors and store are cross-platform .NET Standard 2.0
  • UDP broadcasting for automatic service discovery without a single point of failure
  • Peer-To-Peer network of independent nodes without consensus leaders
  • Random placement of virtual actors within a cluster
  • Ability to create multiple instances of the same type of actor using unique ID
  • Ability to override any layer, including protocol, actor placement strategy, service discovery, etc
  • No dangerous binary serialization or 3rd party serialization libraries
  • Simple C# POCO structs for messages, no attributes or other decorators
  • Process messages using single or multiple actors with [Subscription] attribute
  • Kestrel server middleware to process message queries
  • Automatic loading and mapping for actors and messages at startup

Sample

This is an example of using actors locally within the same app.

// Define message and response format 

public class DemoMessage { public string Name { get; set; }}
public class DemoResponse { public string Data { get; set; }}

// Define actor processing this particular message   

public class DemoActor
{
  [Processor]
  public virtual Task<DemoResponse> SomeAction(DemoMessage message)
  {
    return Task.FromResult(new DemoResponse { Data = "Response from actor" });
  }
}

// Processing

public class Client
{
  async Task SendMessageToActor()
  {
    var scene = new Scene();
    var message = new DemoMessage { Name = "Message to actor" };
    var response = await scene.Send<DemoResponse>("Custom Actor ID", message);

    Console.WriteLine("Response : " + response.Data);
  }
}

An example with a distributed network of actors in the cluster is a bit more complex and can be found in the Samples directory.

Also, can be used as an alternative to RX.NET.

Disclaimer

In order to keep things simple and flexible, the main focus was on simplicity and scalability rather than performance.

Notes

Practically all parts of this framework use the most basic implementation of each layer meaning that it's a general purpose implementation that may need to be extended to solve more specific problems.

  1. HTTP and JSON are somewhat slow, but were chosen for communication instead of sockets to make it easier to build a network of a million of nodes without a need to manage permanent connections between peers.
  2. UDP broadcasting can detect nodes within the same network segment. To make peer discovery global there will be a need for services like Consul or manual NAT traversing.
  3. There is a heavy use of reflection for mapping between actors and messages. No benchmarks, but switching to compiled delegates may improve latency.

Improvements

Even though existing modules are the most basic at the core, they can be easily extended or overridden to achieve more specific goals.

  1. When there is no requirement to have millions of nodes, it's possible to implement ICommunicator and use sockets with Message Pack or Flat Buffers for lower latency.
  2. Peer discovery is encapsulated inside of the Beacon class. When needed, it's easy to override any of its method or implement IBeacon to use it with Consul or some other service discovery tool.
Product Compatible and additional computed target framework versions.
.NET net5.0 was computed.  net5.0-windows was computed.  net6.0 was computed.  net6.0-android was computed.  net6.0-ios was computed.  net6.0-maccatalyst was computed.  net6.0-macos was computed.  net6.0-tvos was computed.  net6.0-windows was computed.  net7.0 was computed.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
.NET Core netcoreapp2.0 was computed.  netcoreapp2.1 was computed.  netcoreapp2.2 was computed.  netcoreapp3.0 was computed.  netcoreapp3.1 was computed. 
.NET Standard netstandard2.0 is compatible.  netstandard2.1 was computed. 
.NET Framework net461 was computed.  net462 was computed.  net463 was computed.  net47 was computed.  net471 was computed.  net472 was computed.  net48 was computed.  net481 was computed. 
MonoAndroid monoandroid was computed. 
MonoMac monomac was computed. 
MonoTouch monotouch was computed. 
Tizen tizen40 was computed.  tizen60 was computed. 
Xamarin.iOS xamarinios was computed. 
Xamarin.Mac xamarinmac was computed. 
Xamarin.TVOS xamarintvos was computed. 
Xamarin.WatchOS xamarinwatchos was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages (4)

Showing the top 4 NuGet packages that depend on Distribution:

Package Downloads
Canvas.Core

Internal package used in Canvas.Views.Web

Distribution.Stream

HTTP service with streaming and parallel execution.

Distribution.Service

HTTP service with streaming and parallel execution.

Distribution.Cluster

General purpose virtual actor framework for peer-to-peer microservices or in-process communication within the same app with possible extension to blockchains.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
2.2.1 315 10/25/2024
2.2.0 98 10/25/2024
2.1.9 96 10/25/2024
2.1.8 142 9/10/2024
2.1.7 406 8/24/2024
2.1.6 435 6/2/2024
2.1.5 148 5/26/2024
2.1.2 181 5/22/2024
2.1.1 193 5/19/2024
2.1.0 112 5/19/2024
2.0.9 101 5/17/2024
2.0.8 103 5/16/2024
2.0.7 101 5/16/2024
2.0.6 98 5/15/2024
2.0.5 366 3/25/2024
2.0.4 288 3/18/2024
2.0.3 125 3/18/2024
2.0.2 117 3/18/2024
2.0.1 224 3/15/2024
2.0.0 115 3/15/2024
1.3.5 151 3/14/2024
1.3.3 119 3/14/2024
1.3.2 129 3/14/2024
1.3.1 148 3/14/2024
1.3.0 145 3/7/2024
1.2.6 116 3/7/2024
1.2.5 216 3/3/2024
1.2.4 169 3/3/2024
1.2.3 179 3/1/2024
1.2.2 119 2/26/2024
1.2.1 113 2/26/2024
1.2.0 158 2/26/2024
1.1.8-prerelease 124 2/24/2023
1.1.6-prerelease 98 2/19/2023
1.1.5-prerelease 127 2/14/2023
1.1.1-prerelease 92 2/13/2023
1.1.0-prerelease 267 11/6/2022
1.0.9-prerelease 110 11/6/2022
1.0.8-prerelease 130 6/9/2022
1.0.7-prerelease 136 6/7/2022
1.0.6-prerelease 133 6/3/2022
1.0.5-prerelease 131 5/31/2022
1.0.3-prerelease 137 4/4/2022
1.0.2-prerelease 236 4/3/2022