我有一个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();
}