如何在 C# 中等待事件处理程序的响应？

Question

我有一个分为多层的应用程序 (A1)。有些层用于用户交互，有些用于与不同的数据库交互，有些包含业务逻辑。我们有另一个第三方应用程序 (A2) 向 (A1) 发送请求，A1 需要响应该请求。下面是A1的架构。

T3（此层接收来自 A2 应用程序的请求）

T2（业务逻辑）

T1（用户界面）

T2 包含所有的业务逻辑。我面临的问题是当我收到来自 A2 应用程序的请求时。我需要根据 T2 中出现的一些业务逻辑来响应请求。我可以从 T2 订阅的 T3 调用事件，但我必须从事件处理程序中获取数据，如下所示；

T3：

public Response CanStore(string materialType){
    //Invoke event and wait to get response from T2
    return response.;

}

T2：订阅了T3的事件

 public async void canStore(object sender, EventArgs e){
     //Perform some logic and response result to T3
}

有可能吗？

Answer 1

在我看来，你的架构是错误的

如果 T2 有业务逻辑，并且 T1 是一个用户界面，可能需要访问业务逻辑，而 T3 是一个从外部方接收消息的应用程序，也需要访问业务逻辑，那么 T1 和 T3 都需要对 T2 的引用。

那么这只是将业务逻辑依赖注入到 T3 中的简单一点！

public class T3Service
{
    private readonly IT2BusinessLogic businessLogic;

    public T3Service(IT2BusinessLogic businessLogic)
    {
        this.businessLogic = businessLogic;
    }

    public Response CanStore(string materialType)
    {
        var t2Response = businessLogic.CanStore(materialType);
        // Do what you like to build response to external service
        return response;

    }
}

Answer 2

除了架构问题并假设您可以修改 T3 和 T2，您可以使用一些自定义 EventType 来解决滥用 EventArgs 的问题。不是我最喜欢的，但可以解决你的问题。

让 T2 操作 EventArg 以在其中存储所需的结果。 完成 Eventhandler 后，调用站点 T3 可以从 eventArg 中获取结果。

类似

public Response CanStore(string materialType){
    //Invoke event and wait to get response from T2
    myEvent.Invoke?(sender, myCustomEventArgs);
    await myCustomEvent.Completion.Task;

    return myCustomEvent.ResponseFromSubscriber;
}

myCustomEvent 使用两个属性扩展您当前的事件，

MyCustomEventArgs: MyCurrentEventArgs
{
    // makes your Event "awaitable";
    TaskCompletionSource<bool> Completion{ get; } = new TaskCompletionSource<bool>; 
    Response ResponseFromSubscriber{ get; set; } // As you need 
}

和订阅者

public async void canStore(object sender, EventArgs e){
    //Perform some logic and response result to T3
    if(e is MyCustomEventArgs myCustomEventArgs)
    {
        myCustomEventArgs.ResponseFromSubscriber = new Reponse(); // Your whatever 
        myCustomEventArgs.Completion.SetResult(true); // Triggers the Task completion for your awaiting EventInvoker
    }
}