BlackHole.Messaging 3.0.0

BlackHole Messaging 🕳️

High-performance network messaging for .NET 10. A custom length-prefixed binary protocol over TCP with RPC, Pub/Sub, Streaming and Batching — built on System.IO.Pipelines so the steady state allocates nothing per message.

Built by Gravicode Studios, led by Kang Fadhil.

Bahasa Indonesia · English · Documentation · Benchmarks

<a name="english"></a>

🇬🇧 English

Install

dotnet add package BlackHole.Messaging

The id BlackHole was already taken on nuget.org, so the package ships as BlackHole.Messaging. The assembly and every namespace are still BlackHole.*.

Thirty seconds

using BlackHole.Hosting;

// Server
await using var server = new BlackHoleServer(5000);
server.Rpc.RegisterText("upper", text => text.ToUpperInvariant());
server.Start();

// Client
await using var client = await BlackHoleClient.ConnectAsync("127.0.0.1", 5000);
string result = await client.Rpc.CallTextAsync("upper", "halo blackhole");   // "HALO BLACKHOLE"

// Pub/Sub, with MQTT-style wildcards
client.PubSub.Received += (topic, payload) => Console.WriteLine($"{topic}: {payload.Length} B");
await client.PubSub.SubscribeAsync("sensor/+/temperature");
await client.PubSub.PublishAsync("sensor/tank-3/temperature", "28.4");

What it does

Measured on this machine

.NET 10.0.11, Windows 11, 8 logical cores, loopback TCP, both ends in one process.

Full numbers, method, and how to reproduce them: docs/benchmarks.md.

Run it

dotnet run --project src/BlackHole.Demo          # every pattern, end to end
dotnet run --project src/BlackHole.IoTGateway    # the Avalonia gateway panel
dotnet test tests/BlackHole.Tests                # 40 tests

The IoT Gateway simulator

An Avalonia desktop panel that runs a real BlackHole gateway and attaches as many simulated sensor devices as you like — each one a genuine client on a genuine socket. Nothing in it is mocked.

dotnet run --project src/BlackHole.IoTGateway -- --demo 12

Every pattern in the library is operable from the panel: devices publish telemetry, the gateway calls RPC methods back down the same connection the device dialled out on, and Firmware uploads 4 MiB as a stream while the traces keep running. See docs/iot-gateway.md.

Documentation

Bahasa Indonesia: docs/id/.

<a name="bahasa-indonesia"></a>

🇮🇩 Bahasa Indonesia

Instalasi

dotnet add package BlackHole.Messaging

Nama BlackHole sudah dipakai orang lain di nuget.org, jadi paket ini bernama BlackHole.Messaging. Nama assembly dan seluruh namespace tetap BlackHole.*.

Tiga puluh detik

using BlackHole.Hosting;

// Server
await using var server = new BlackHoleServer(5000);
server.Rpc.RegisterText("upper", text => text.ToUpperInvariant());
server.Start();

// Client
await using var client = await BlackHoleClient.ConnectAsync("127.0.0.1", 5000);
string hasil = await client.Rpc.CallTextAsync("upper", "halo blackhole");   // "HALO BLACKHOLE"

// Pub/Sub, dengan wildcard ala MQTT
client.PubSub.Received += (topik, isi) => Console.WriteLine($"{topik}: {isi.Length} B");
await client.PubSub.SubscribeAsync("sensor/+/temperature");
await client.PubSub.PublishAsync("sensor/tank-3/temperature", "28.4");

Apa saja yang tersedia

Hasil pengukuran di mesin ini

.NET 10.0.11, Windows 11, 8 core logis, TCP loopback, kedua sisi dalam satu proses.

Angka lengkap, metode pengukuran, dan cara mengulanginya: docs/benchmarks.md.

Menjalankannya

dotnet run --project src/BlackHole.Demo          # semua pola, dari ujung ke ujung
dotnet run --project src/BlackHole.IoTGateway    # panel gateway Avalonia
dotnet test tests/BlackHole.Tests                # 40 tes

Simulator IoT Gateway

Panel desktop Avalonia yang menjalankan gateway BlackHole sungguhan dan menyambungkan sebanyak apa pun perangkat sensor simulasi — masing-masing klien sungguhan di atas soket sungguhan. Tidak ada bagian yang dipalsukan.

dotnet run --project src/BlackHole.IoTGateway -- --demo 12

Semua pola di pustaka ini bisa dioperasikan dari panel: perangkat mengirim telemetri, gateway memanggil metode RPC balik lewat koneksi yang sama yang tadi dibuka perangkat, dan tombol Firmware mengunggah 4 MiB sebagai stream sementara grafiknya tetap berjalan. Lihat docs/id/iot-gateway.md.

Dokumentasi

Dokumentasi berbahasa Indonesia ada di docs/id/: Panduan awal · Arsitektur · Protokol · Pola · Performa · IoT Gateway

License

MIT. See LICENSE.

Built by Gravicode Studios, led by Kang Fadhil.