C#はサードパーティ製MQに依存しない分散イベントバスを実装するためにSocketを使用

Code WF.EventBus.Socketは、分散アーキテクチャでのイベント通信を簡素化するために設計された軽量のSocketベースの分散イベントバスシステムです。外部のメッセージキューサービスに依存することなく、パブリッシュ/サブスクライブモードでプロセス間の通信を可能にする。

** Socketを使用して実装された分散イベントバス、CQRSをサポート、サードパーティ製MQに依存しません。**

CodeWF.EventBus.Socket 是一个轻量级的、基于 Socket 的分布式事件总线系统，旨在简化分布式架构中的事件通信。它允许进程之间通过发布/订阅模式进行通信，无需依赖外部消息队列服务。

Command

Command

Query

Query

プロパティ

軽量：外部のMQサービスに依存しないため、システムの複雑さと依存性を低減します。
** 高性能 **：低遅延、高スループットのメッセージングを実現するSocketベースのダイレクト通信。
** 柔軟性 ***：カスタムイベントタイプとメッセージプロセッサをサポートし、既存のシステムに簡単に統合できます。
** 拡張性** 分散システム環境に適したマルチクライアント接続をサポートします。

通信プロトコル（通信プロトコル）

通过 TCP 协议进行数据交互，协议包结构如下：

0.0.8@2x

インストールする。

通过NuGet包管理器安装CodeWF.EventBus.Socket：

Install-Package CodeWF.EventBus.Socket

サーバーの利用

イベントサービスの実行

在服务端代码中，创建并启动EventServer实例以监听客户端连接和事件：

using CodeWF.EventBus.Socket;

// 创建事件服务器实例
IEventServer eventServer = new EventServer();

// 启动事件服务器，监听指定IP和端口
eventServer.Start("127.0.0.1", 9100);

イベントサービスの停止

当不再需要事件服务时，调用Stop方法以优雅地关闭服务器：

eventServer.Stop();

クライアントの利用

イベントサービスの接続

在客户端代码中，创建EventClient实例并连接到事件服务器：

using CodeWF.EventBus.Socket;

// 创建事件客户端实例
IEventClient eventClient = new EventClient();

// 连接到事件服务器，使用eventClient.ConnectStatus检查连接状态
eventClient.Connect("127.0.0.1", 9100));

イベントを購読する

特定のタイプのイベントをサブスクライブし、イベントハンドラを指定します。

eventClient.Subscribe<NewEmailCommand>("event.email.new", ReceiveNewEmailCommand);

private void ReceiveNewEmail(NewEmailCommand command)
{
    // 处理新邮件通知
    Console.WriteLine($"收到新邮件，主题是{message.Subject}");
}

パブリッシュコマンドCommand

サブスクライブクライアントが処理するために、指定されたトピックにイベントをパブリッシュする：

// 发布新邮件通知事件
eventClient.Publish("event.email.new", new NewEmailCommand { Subject = "恭喜您中GitHub一等奖", Content = "我们很开心，您在2024年7月...", SendTime = new DateTime(2024, 7, 27) });

クエリー Query

クエリはトピックを指定し、同じトピック（すなわちプロデューサー）をサブスクライブするためにクエリを受信し、リクエストを受信した後、同じトピックでクエリ結果を公開する必要があります。

eventClient.Subscribe<EmailQuery>("event.email.query", ReceiveEmailQuery);

private void ReceiveEmailQuery(EmailQuery query)
{
    // 执行查询请求，准备查询结果
    var response = new EmailQueryResponse { Emails = EmailManager.QueryEmail(request.Subject) };

    // 以相同的主题，发布查询结果
    if (_eventClient!.Publish("event.email.query", response,
        out var errorMessage))
    {
        Logger.Info($"Response query result: {response}");
    }
    else
    {
        Logger.Error($"Response query failed: {errorMessage}");
    }
}

他のエンド（すなわち、コンシューマ）は同じトピックを使用できます。

var response = _eventClient!.Query<EmailQuery, EmailQueryResponse>("event.email.query",
    new EmailQuery() { Subject = "Account" },
    out var errorMessage);
if (string.IsNullOrWhiteSpace(errorMessage) && response != null)
{
    Logger.Info($"Query event.email.query, result: {response}");
}
else
{
    Logger.Error(
        $"Query event.email.query failed: [{errorMessage}]");
}

イベントの購読解除

特定のイベントを受信する必要がなくなった場合、サブスクリプションをキャンセルできます。

eventClient.Unsubscribe<NewEmailNotification>("event.email.new", ReceiveNewEmail);

イベント·サービスの切断

完成事件处理或需要断开与服务器的连接时，调用Disconnect方法：

eventClient.Disconnect();
Console.WriteLine("断开与事件服务的连接");

注意事項について

サーバとクライアントが使用するアドレスとポート番号が一致していること、およびポートが他のサービスによって占有されていないことを確認します。
本番環境では、サーバはパブリックIPアドレスまたは適切なネットワークインターフェイスをリッスンするように構成する必要があります。
ネットワーク異常やサービス再開などの状況を考慮すると、クライアントは再接続ロジックを実装する必要があります。
根据实际需求，可以扩展EventServer和EventClient类以支持更复杂的功能，如消息加密、认证授权等。