CodeWF.EventBus.Socket

CodeWF.EventBus.Socket 是一个面向 C# 进程间通信的轻量级 TCP 事件总线库。它基于 Socket 提供发布订阅与 Query 式请求响应能力，让本地多进程或轻量服务之间可以通信，而不必先引入 RabbitMQ、Kafka、Redis 等外部 MQ 基础设施。

特性

基于 CodeWF.NetWrapper 的 TCP Socket 传输。
支持 Publish/Subscribe 跨进程事件通知。
支持同一主题下的 Query/Response 交互。
查询请求按 TaskId 关联，支持同主题并发查询。
不依赖第三方 MQ，适合轻量级事件分发和 IPC 场景。
自带示例工程 src/EventBusDemo。

安装

Install-Package CodeWF.EventBus.Socket

也可以使用 .NET CLI：

dotnet add package CodeWF.EventBus.Socket

快速开始

启动服务端：

using CodeWF.EventBus.Socket;

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

连接客户端：

using CodeWF.EventBus.Socket;

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

订阅并发布事件：

eventClient.Subscribe<NewEmailCommand>("event.email.new", command =>
{
    Console.WriteLine($"收到邮件主题：{command.Subject}");
});

eventClient.Publish("event.email.new", new NewEmailCommand
{
    Subject = "欢迎使用",
    Content = "您的账号已经准备完成",
    SendTime = DateTime.Now
}, out _);

Query/Response：

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 = "账户" },
    3000);

使用边界

这个库适合轻量事件分发、本机多进程通信和小型服务间通知。当前消息仅保存在内存中，不提供持久化、重试队列或进程重启后的投递保证；如果用于生产环境，应按业务需要补充认证、加密、监控、限流和重试策略。

仓库

GitHub：https://github.com/dotnet9/CodeWF.EventBus.Socket
NuGet：https://www.nuget.org/packages/CodeWF.EventBus.Socket