Faster.Transport 0.0.4

⚡ Faster.Transport

Ultra-low-latency, high-throughput transport layer for real-time distributed systems

Faster.Transport is a modern, zero-allocation, high-performance networking library designed for real-time data transport.
It provides an event-driven TCP Reactor (server) and multiple specialized Particles (clients) for different concurrency and throughput models — optimized for trading engines, telemetry, simulation, and multiplayer networking.

🚀 Core Components

🧩 Architecture Overview

 ┌────────────────────────────┐
 │        Reactor (Server)    │
 │  ────────────────────────  │
 │  Accepts clients as        │
 │  Connection objects         │
 │  Handles framed messages    │
 └─────────────┬──────────────┘
               │
      ┌────────┴────────┐
      │                 │
┌────────────┐   ┌────────────┐
│  Particle   │   │ ParticleFlux │
│ (Async)     │   │ (Concurrent) │
└────────────┘   └────────────┘
       │                 │
       └─────────┬───────┘
                 │
          ┌────────────┐
          │ ParticleBurst │
          │ (Fire & Forget) │
          └────────────┘

Each Particle connects to a Reactor and communicates using a lightweight framed protocol:

[length:int32][payload:byte[]]

This enables efficient, zero-copy parsing of variable-length messages.

🧠 What Are Particles?

Particles are clients that connect to a Reactor.
Each type offers a specific balance between throughput, latency, and concurrency safety.

🧩 Example — Reactor + Particle

Reactor (Server)

using Faster.Transport;
using System.Net;

var reactor = new Reactor(new IPEndPoint(IPAddress.Any, 5555));
reactor.OnReceived = (conn, data) =>
{
    // Echo message back
    conn.Return(data);
};

reactor.OnConnected = conn => Console.WriteLine("New client connected!");
reactor.Start();

Console.WriteLine("Reactor started on port 5555.");
Console.ReadLine();

Particle (Async Client)

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

var particle = new ParticleBuilder()
    .ConnectTo(new IPEndPoint(IPAddress.Loopback, 5555))
    .OnReceived(data => Console.WriteLine("Echo: " + Encoding.UTF8.GetString(data.Span)))
    .OnParticleDisconnected((cli, ex) => Console.WriteLine("Disconnected: " + ex?.Message))
    .Build();

await particle.SendAsync(Encoding.UTF8.GetBytes("Hello Reactor!"));

⚡ Example — ParticleBurst (Fire-and-Forget)

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

var burst = new ParticleBuilder()
    .ConnectTo(new IPEndPoint(IPAddress.Loopback, 5555))
    .AsBurst()
    .WithParallelism(32)
    .OnBurstDisconnected((cli, ex) => Console.WriteLine("Burst disconnected: " + ex?.Message))
    .BuildBurst();

var payload = Encoding.UTF8.GetBytes("Hello Reactor ⚡");

// Send 100k messages as fast as possible
for (int i = 0; i < 100_000; i++)
{
    burst.Send(payload);
}

🧰 Features

✅ Zero-copy, framed protocol
✅ Lock-free buffer management (ConcurrentBufferManager)
✅ Pooled SocketAsyncEventArgs for zero allocation
✅ High-performance frame parser with inline feed
✅ Full duplex I/O
✅ Supports hundreds of concurrent connections
✅ Works with .NET Framework 4.8 and .NET 6+

⚙️ Configuration via ParticleBuilder

📦 Example Project Scenarios

🧪 Performance Targets (on modern hardware)

(Tested with 8192-byte payloads on loopback with 32 parallel senders.)

🧩 License

MIT © Faster.Transport
Engineered for speed, stability, and real-time data flow.