CodeWF.EventBus.Socket 1.2.0

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.