ZeroComm.Core 2.0.0

ZeroComm

ZeroComm is an ultra-high-performance industrial communications library, PLC master runtime, and SCADA telemetry engine for .NET with zero external dependencies. Written in 100% pure C#, it delivers asynchronous non-blocking TCP and serial transport, zero-allocation ring buffers, transaction channels, and native protocol implementations for the world's top 5 industrial automation ecosystems: Siemens S7, Mitsubishi MELSEC, Modbus TCP/RTU, Omron FINS, and Allen-Bradley CIP / EtherNet/IP.

🌟 Key Capabilities

• 100% Pure C# Sovereign Drivers: No external native binaries (libplctag), no proprietary commercial DLLs (HslCommunication), no runtime bloatware.
• Unified Industrial PLC Client (IIndustrialPlcClient): Polymorphic tag read/write API (ReadAsync<T>, WriteAsync<T>, ReadRawBytesAsync, WriteRawBytesAsync) across all vendors.
• Intelligent Address Resolution (PlcAddressParser): Automatically compiles vendor-specific string addresses into binary memory areas, byte offsets, and bit masks at microsecond speed.
• High-Frequency SCADA Polling Engine (PlcPollingEngine):
  • Batch Coalescing Engine (BatchCoalescingEngine): Automatically merges hundreds of scattered tag read requests into optimal contiguous block transfers to minimize network round-trips.
  • Zero-Allocation Deadband Filter (DeadbandFilterSlot): Suppresses sub-threshold sensor noise and edge jitter while enforcing periodic heartbeat liveness events.
  • ZeroUI Off-Heap Telemetry Integration: High-throughput delegate pipeline streaming directly into off-heap unmanaged memory series without boxing or GC pressure.
• Zero-Allocation Request/Response Channel (HalfDuplexChannel): Reusable state machine eliminating per-request TaskCompletionSource, CancellationTokenSource, and closure allocations.
• Automatic Protocol Session Renegotiation (IProtocolSession): Transparently executes protocol handshakes upon transport reconnection.

🏭 Supported PLC Ecosystems

📦 Installation

Install via the .NET CLI:

dotnet add package ZeroComm.Core

🚀 Usage Examples

1. Unified Multi-Vendor Tag Access (IIndustrialPlcClient)

using ZeroComm.Core.Abstractions;
using ZeroComm.Core.Siemens;
using ZeroComm.Core.Transport;

// Connect to Siemens S7-1500 PLC
var transport = new AsyncTcpTransport("192.168.1.10", port: 102);
await transport.ConnectAsync();

using IIndustrialPlcClient plc = new S7TcpClient(transport, S7CpuType.S71500, rack: 0, slot: 1);
await plc.ConnectAsync();

// Strongly-typed reading across unified address syntax
float temperature = await plc.ReadAsync<float>("DB1.DBD0");
short motorSpeed = await plc.ReadAsync<short>("DB1.DBW4");
bool isRunning = await plc.ReadAsync<bool>("DB1.DBX6.0");

// Strongly-typed writing
await plc.WriteAsync<float>("DB1.DBD0", 75.5f);

2. Allen-Bradley EtherNet/IP & CIP Tag Client

using ZeroComm.Core.AllenBradley;
using ZeroComm.Core.Transport;

var transport = new AsyncTcpTransport("192.168.1.50", port: 44818);
await transport.ConnectAsync();

using var abClient = new EtherNetIpClient(transport) { Slot = 0 };
await abClient.ConnectHandshakeAsync();

// Read primitive tag values by symbol name
int processCount = await abClient.ReadInt32Async("Tag_ProcessCount");
float pressure = await abClient.ReadFloatAsync("Pressure_Tank1");
string recipeName = await abClient.ReadStringAsync("ActiveRecipe_Name");

// Write tag value
await abClient.WriteFloatAsync("Pressure_Setpoint", 12.5f);

3. Omron FINS TCP Client

using ZeroComm.Core.Omron;
using ZeroComm.Core.Transport;

var transport = new AsyncTcpTransport("192.168.1.30", port: 9600);
await transport.ConnectAsync();

using var finsClient = new FinsTcpClient(transport);
await finsClient.ConnectHandshakeAsync(); // Negotiates node address allocation

// Read/write DM words
ushort[] dmWords = await finsClient.ReadWordsAsync(FinsMemoryArea.DmWord, address: 100, wordCount: 10);
await finsClient.WriteWordsAsync(FinsMemoryArea.DmWord, address: 100, new ushort[] { 100, 200, 300 });

// Read/write single bit
bool pumpStatus = await finsClient.ReadBitAsync(FinsMemoryArea.WorkBit, address: 10, bitOffset: 2);

4. High-Frequency SCADA Polling Engine with Tag Coalescing

using ZeroComm.Core.Abstractions;
using ZeroComm.Core.Engine;
using ZeroComm.Core.Siemens;
using ZeroComm.Core.Transport;

var transport = new AsyncTcpTransport("192.168.1.10", port: 102);
await transport.ConnectAsync();

var s7Client = new S7TcpClient(transport, S7CpuType.S71500, rack: 0, slot: 1);
await s7Client.ConnectAsync();

// Initialize batch polling engine (max block size: 500 bytes, bridge gaps <= 10 bytes)
using var engine = new PlcPollingEngine(s7Client, maxContiguousBytes: 500, maxAllowedGapBytes: 10);

// Register tags with individual deadband thresholds and heartbeat liveness
engine.RegisterTag(tagId: 1, "DB1.DBD0", TagDataType.Float, deadbandAbsolute: 0.1);
engine.RegisterTag(tagId: 2, "DB1.DBD4", TagDataType.Float, deadbandAbsolute: 0.5);
engine.RegisterTag(tagId: 3, "DB1.DBW8", TagDataType.Int16, deadbandAbsolute: 1.0, heartbeatIntervalMs: 5000);
engine.RegisterTag(tagId: 4, "DB1.DBX10.0", TagDataType.Bool);

// Connect zero-allocation telemetry stream directly to ZeroUI off-heap pipeline
engine.OnTelemetrySampled = (tagId, value, timestampMs) =>
{
    // Fast path: writes straight into off-heap buffer without heap allocations or boxing
};

// Start high-speed background polling at 50ms (20 Hz)
engine.Start(intervalMs: 50);

📊 Benchmark & Performance

Tested on local PLC simulation rig (10,000 requests, Release x64, .NET 8.0):

📜 Release History

📄 License

MIT License © 2026 Phong Võ. Part of the ZeroPlatform project.