从WCF服务调用基于任务的异步单向回调方法



我有一个WCF服务,它使用回调约定来通知客户端,类似于这个

public interface IClientCallback
{
    [OperationContract(IsOneWay = true)]
    void NotifySomething();
}

调用它的服务代码类似于这个

void NotifySomething()
{
    try
    {
        this.callback.NotifySomething();
    }
    catch (Exception ex)
    {
        // Log the exception and eat it
    }
}

请注意,根据设计,回调通知是可选的,即很好,但不是必需的。这就是为什么它被标记为OneWay,并且实现接受异常。

由于一些误解,我们认为这就足够了,可以采用一种非阻塞性的火灾和遗忘方法。但这当然不是真的,所以在某些情况下它会阻塞一段时间,这会造成问题,因为它是从线程同步块内部调用的。因此,我们决定通过更改定义使其异步化,如下

public interface IClientCallback
{
    [OperationContract(IsOneWay = true)]
    Task NotifySomething();
}

我对客户端实现没有问题,我的问题是如何从服务中调用它。以下是我想做的

async void NotifySomething()
{
    try
    {
        await this.callback.NotifySomething();
    }
    catch (AggregateException ex)
    {
        // Unwrap, log the exception(s) and eat it
    }
    catch (Exception ex)
    {
        // Log the exception and eat it
    }
}

既然每个人都说async void不是一个好的练习,那么在这里使用它可以吗?我还有什么其他选择?在WCF服务上下文中执行此操作的推荐方法是什么?

您编写它的方式非常安全,因为它可以处理异常。你也可以写一个可重用的扩展方法来做到这一点,这样你就不需要重复了

也许是这样的:

public static class Extensions
{
    public static void FireAndForget(this Task task)
    {
        task.ContinueWith(t => 
        {
            // log exceptions
            t.Exception.Handle((ex) =>
            {
                Console.WriteLine(ex.Message);
                return true;
            });
        }, TaskContinuationOptions.OnlyOnFaulted);
    }
}
public async Task FailingOperation()
{
    await Task.Delay(2000);
    throw new Exception("Error");
}   
void Main()
{
    FailingOperation().FireAndForget();
    Console.ReadLine();
}

相关内容

  • 没有找到相关文章

最新更新