CodeWF.EventBus.Socket 1.2.1

CodeWF.EventBus.Socket

English | 简体中文

CodeWF.EventBus.Socket is a lightweight TCP event bus for C# processes. It provides Publish/Subscribe messaging and Query-style request/response over sockets, so local processes or lightweight services can communicate without introducing RabbitMQ, Kafka, Redis, or other external MQ infrastructure.

Highlights

• TCP socket transport based on CodeWF.NetWrapper
• Publish/Subscribe for cross-process notifications
• Query/response flow on the same subject
• Query correlation by request TaskId, including concurrent queries on the same subject
• Reuses CodeWF.NetWrapper transport objects such as TcpSocketServer, TcpSocketClient, SocketCommand, and Heartbeat
• No external MQ dependency
• Demo application in src/EventBusDemo

Installation

dotnet add package CodeWF.EventBus.Socket

or

Install-Package CodeWF.EventBus.Socket

Quick Start

Start the server

using CodeWF.EventBus.Socket;

IEventServer eventServer = new EventServer();
await eventServer.StartAsync("127.0.0.1", 9100);

Connect a client

using CodeWF.EventBus.Socket;

IEventClient eventClient = new EventClient();
await eventClient.ConnectAsync("127.0.0.1", 9100);

Subscribe and publish

eventClient.Subscribe<NewEmailCommand>("event.email.new", command =>
{
    Console.WriteLine($"Received: {command.Subject}");
});

eventClient.Publish("event.email.new", new NewEmailCommand
{
    Subject = "Welcome",
    Content = "Your account is ready",
    SendTime = DateTime.Now
}, out _);

Query and respond

eventClient.Subscribe<EmailQuery>("event.email.query", query =>
{
    var response = new EmailQueryResponse
    {
        Emails = EmailManager.QueryEmail(query.Subject)
    };

    eventClient.Publish("event.email.query", response, out _);
});

var result = await eventClient.QueryAsync<EmailQuery, EmailQueryResponse>(
    "event.email.query",
    new EmailQuery { Subject = "Account" },
    3000);

Documentation

• Design document
• 中文设计文档
• Demo application

Communication Protocol

Data packets are exchanged over TCP.

Notes

• This library is designed for lightweight event distribution and IPC-style communication.
• The transport layer is implemented with CodeWF.NetWrapper, and same-name transport objects are reused directly instead of being duplicated locally.
• Event-bus-specific request/query/update packets remain defined in this project because they carry library-specific semantics.
• Messages are kept in memory only. There is no persistence, broker-side retry queue, or delivery guarantee after a process restart.
• For production use, consider whether you need authentication, encryption, retry, monitoring, and back-pressure around the socket transport.

Third-Party Open Source Audit (2026-05-20)

Checked with dotnet restore CodeWF.EventBus.Socket.slnx, dotnet list package --include-transitive, NuGet .nuspec metadata, NuGet.org, and upstream source/license links. MIT / Apache-2.0 / BSD are preferred; other source-open licenses are noted when source and transitive dependencies are traceable.

Remediation:

• Migrated the solution from CodeWF.EventBus.Socket.sln to CodeWF.EventBus.Socket.slnx.
• Added Directory.Packages.props and centralized direct package versions.
• Upgraded the demo package line to Avalonia 12.0.3, Semi.Avalonia 12.0.1, Irihi.Ursa 2.0.0, ReactiveUI.Avalonia 12.0.1, CodeWF.NetWrapper 2.1.1, CodeWF.EventBus 3.4.5.5, and CodeWF.LogViewer.Avalonia 12.0.3.1.
• Removed Avalonia.Diagnostics because it does not have an Avalonia 12 package line.
• Kept Prism.Avalonia / Prism.DryIoc.Avalonia on MIT 8.1.97.11073; the newer 9.x line is intentionally not used.
• Removed unused Irihi.Ursa.PrismExtension 9.0.1 and pinned old transitive system packages to 10.0.8.

Transitive dependency check: the effective dependency graph does not contain Prism 9 preview packages, or old System.Drawing.Common 4.7.0 / System.Configuration.ConfigurationManager 4.7.0 / System.Security.Cryptography.ProtectedData 4.7.0 chains. CodeWF.NetWrapper is now resolved to 2.1.1.