Faster.Transport 0.0.9

🚀 Faster.Transport

Faster.Transport is a high-performance, unified transport layer for .NET that abstracts multiple communication backends — including In-Process, Shared Memory (IPC), TCP, and UDP / Multicast — under a single IParticle interface.

It is designed for ultra-low-latency, high-throughput messaging across local, inter-process, and network boundaries.

✨ Features

🧱 Supported Transports

⚙️ Benchmark Results

All benchmarks were run using BenchmarkDotNet on a .NET 9.0 build targeting x64 in Release mode.

🧩 Inproc Transport (Single Process)

Interpretation:
🚀 The Inproc transport achieves ~2.2 ms median latency for 10,000 asynchronous message sends,
with under 1 MB total allocations, demonstrating near-zero overhead and outstanding local throughput.

🔧 Quick Start

1️⃣ Create a TCP echo server and client

using Faster.Transport;
using System.Net;
using System.Text;

// 🖥️ Server
var server = new ParticleBuilder()
    .UseMode(TransportMode.Tcp)
    .BindTo(new IPEndPoint(IPAddress.Loopback, 5000))
    .OnReceived((p, msg) =>
    {
        Console.WriteLine($"Server received: {Encoding.UTF8.GetString(msg.Span)}");
        p.Send(msg.Span); // echo back
    })
    .Build();

// 💻 Client
var client = new ParticleBuilder()
    .UseMode(TransportMode.Tcp)
    .ConnectTo(new IPEndPoint(IPAddress.Loopback, 5000))
    .OnReceived((_, msg) =>
        Console.WriteLine($"Client got echo: {Encoding.UTF8.GetString(msg.Span)}"))
    .Build();

await Task.Delay(200); // wait for connect
await client.SendAsync(Encoding.UTF8.GetBytes("Hello TCP!"));

2️⃣ In-Process Messaging

var server = new ParticleBuilder()
    .UseMode(TransportMode.Inproc)
    .WithChannel("local-bus", isServer: true)
    .OnReceived((_, msg) =>
        Console.WriteLine($"Server received: {Encoding.UTF8.GetString(msg.Span)}"))
    .Build();

var client = new ParticleBuilder()
    .UseMode(TransportMode.Inproc)
    .WithChannel("local-bus")
    .Build();

await client.SendAsync(Encoding.UTF8.GetBytes("Ping Inproc!"));

3️⃣ IPC (Shared Memory)

var server = new ParticleBuilder()
    .UseMode(TransportMode.Ipc)
    .WithChannel("shared-map", isServer: true)
    .OnReceived((_, msg) =>
        Console.WriteLine($"IPC Server: {Encoding.UTF8.GetString(msg.Span)}"))
    .Build();

var client = new ParticleBuilder()
    .UseMode(TransportMode.Ipc)
    .WithChannel("shared-map")
    .Build();

await client.SendAsync(Encoding.UTF8.GetBytes("Hello from IPC!"));

4️⃣ UDP / Multicast Messaging

Now with auto-configuring multicast — no need to manually bind or connect!

using Faster.Transport;
using System.Net;
using System.Text;

var group = IPAddress.Parse("239.10.10.10");
var port = 50000;

// 🛰️ Multicast Sender
var server = new ParticleBuilder()
    .EnableMulticast(group, port, disableLoopback: false)
    .Build();

// 📡 Multicast Clients
var client1 = new ParticleBuilder()
    .EnableMulticast(group, port)
    .OnReceived((_, msg) =>
        Console.WriteLine($"Client 1 got: {Encoding.UTF8.GetString(msg.Span)}"))
    .Build();

var client2 = new ParticleBuilder()
    .EnableMulticast(group, port)
    .OnReceived((_, msg) =>
        Console.WriteLine($"Client 2 got: {Encoding.UTF8.GetString(msg.Span)}"))
    .Build();

Console.WriteLine("Press ENTER to send 3 multicast messages...");
Console.ReadLine();

for (int i = 0; i < 3; i++)
{
    var msg = Encoding.UTF8.GetBytes($"Broadcast #{i + 1}");
    await server.SendAsync(msg);
    Console.WriteLine($"[Server] Sent Broadcast #{i + 1}");
    await Task.Delay(300);
}

✅ Output

[Server] Sent Broadcast #1
Client 1 got: Broadcast #1
Client 2 got: Broadcast #1
...

🧩 ParticleBuilder Overview

🧪 Testing UDP Multicast Locally

If messages are not received:

1. Ensure disableLoopback: false in .EnableMulticast() for local tests.
2. Disable the firewall or open UDP port 50000.
3. Verify via Wireshark: filter udp.port == 50000.
4. Loopback works only if MulticastLoopback is enabled.

⚙️ Requirements

🧑‍💻 Example Projects

🧰 License

MIT License © 2025 — Designed for speed, simplicity, and reliability.