我有一个Windows服务，它接收一堆文件的名称并对这些文件执行操作（压缩/解压缩、更新数据库等）。根据发送到服务的文件的大小和数量，操作可能需要花费一定的时间。
(1) 发送请求给该服务的模块将等待文件被处理。我想知道是否有一种方式在服务中提供回调，以便在完成文件处理时通知调用模块。请注意，多个模块可以同时调用服务来处理文件，因此服务需要提供某种类型的TaskId。
(2) 如果调用了一个正在运行的服务方法，并且再次调用了同一个服务，那么该调用将如何被处理（我认为只有一个线程与该服务相关）。我发现当服务处理方法需要花费时间时，与服务关联的线程开始增加。
WCF确实提供了双工绑定，允许您指定回调协定，以便服务可以回调到调用客户端进行通知。
然而，在我看来，这种机制相当不稳定，不建议使用。
在这种情况下，当调用导致一个相当长时间的操作发生时，我会这样做：
如果您想坚持使用HTTP/NetTcp绑定，我会：
因此，在您的情况下，您可以将压缩一些文件的请求放下。服务将离开并执行其工作，并将生成的ZIP存储在临时位置。然后稍后客户端可以检查ZIP是否准备好，如果准备好，就可以检索它。
这个方法甚至可以通过消息队列（MSMQ）来更好地实现，因为每台 Windows 服务器上都有它（但似乎很少有人知道它或使用它）：
通过阅读优秀的 MSDN 文章 Foudnations: Build a queue WCF Response Service，您可以有效地了解如何实现这一切 - 强烈推荐！
在我看来，基于消息队列的系统比基于双工/回调合同的系统更加稳定且出错率更低。
Codeproject Article WCF Duplex Service（WCF双工服务的Codeproject文章）
然后按照以下步骤添加自己的代码：
Define the call back interface with an event manager method to send results from the server and receive them in the client.
public interface ILongOperationCallBack
{
[OperationContract(IsOneWay = true)]
void OnResultsSend(....);
}
Define the Service Interface with a method to pass the parameters needed by the long operation (refer the previous ILongOperationCallBack interface in the CallBackContractAttribute)
[ServiceContract(CallbackContract=typeof(ILongOperationCallBack))]
public interface ILongOperationService
{
[OperationContract]
bool StartLongOperation(...);
}
In the Service class that implements the Service Interface, first get the proxy of the client call back and save it in a class field, then start the long operation work asynchronously and return the bool value immediately. When the long operation work is finished send the results to the client using the client call back proxy field.
public class LongOperationService:ILongOperationService
{
ILongOperationCallBack clientCallBackProxy;
public ILongOperationCallBack ClientCallBackProxy
{
get
{
return OperationContext.Current.GetCallbackChannel<ITrialServiceCallBack>());
}
}
public bool StartLongOperation(....)
{
if(!server.IsBusy)
{
//set server busy state
//**Important get the client call back proxy here and save it in a class field.**
this.clientCallBackProxy=ClientCallBackProxy;
//start long operation in any asynchronous way
......LongOperationWorkAsync(....)
return true; //return inmediately
}
else return false;
}
private void LongOperationWorkAsync(.....)
{
.... do work...
//send results when finished using the cached client call back proxy
this.clientCallBackProxy.SendResults(....);
//clear server busy state
}
....
}
In the client create a class that implements ILongOperationCallBack to receive results and add a method to start the long operation in the server (the start method and the event manager don't need to be in the same class)
public class LongOperationManager: ILongOperationCallBack
{
public busy StartLongOperation(ILongOperationService server, ....)
{
//here you can make the method async using a TaskCompletionSource
if(server.StartLongOperation(...)) Console.WriteLine("long oper started");
else Console.Writeline("Long Operation Server is busy")
}
public void OnResultsSend(.....)
{
... use long operation results..
//Complete the TaskCompletionSource if you used one
}
}
注意事项：
在StartLongOperation方法中，我使用bool返回值来表示服务器忙碌而不是宕机，但仅当长操作不能并发时才需要，例如在我的实际应用程序中，可能有更好的方法在WCF中实现非并发（要发现服务器是否宕机，请像通常一样添加Try/Catch块）。
我没有看到的重要引用是需要在StartLongOperation方法中缓存回调客户端代理。我的问题是我试图在工作方法中获取代理（是的，所有示例都在服务方法中使用回调客户端代理，但文档中没有明确说明，在长操作的情况下，我们必须延迟回调直到操作结束）。
在服务方法返回后，在下一个服务方法之前不要获取和缓存两次回调代理。
免责声明：我没有添加控制错误等代码。