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