知识大全 wcf多线程和异步操作

Posted 2022-07-14 操作

篇首语：时间会告诉我们，简单的喜欢，最长远；平凡中的陪伴，最安心。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 wcf多线程和异步操作相关的知识，希望对你有一定的参考价值。

　　按照操作执行所需的资源类型我们可以将操作分为cpu绑定型操作和I/O绑定型操作前者主要是利用cpu进行密集运算后者大部分操作处理时间花在I/O处理上（比如文件系统网络资源）对于I/O绑定型的操作我们可以充分利用多线程机制让多个操作在各自的线程上并行执行服务调用就是典型的I/O绑定型操作所以多线程在服务调用具有广泛应用按照异步操作发生的位置可以将wcf应用的异步操作分为下面中类型异步信道调用客户端通过绑定创建的信道向服务端发送消息从而实现了对服务的调用客户端可以通过代理对象异步的调用信道从而实现异步服务的调用单向消息交换客户端的信道通过单向的消息交换模式向服务端发送消息消息一旦抵达传输层马上返回从而达到异步服务调用的效果异步服务实现服务端在具体实现服务操作的时候采用异步调用的方式 一异步服务的调用 异步服务代理的创建一般的服务代理继承自ClientBase<TChannel> 默认情况下是不具有异步服务调用的操作但我们可以通过添加引用的方式创建异步服务代理并对服务进行异步调用在添加服务引用的时候在弹出的服务引用对话框中点击高级按钮会弹出服务引用设置对话框然后勾选生成异步操作即可

　　对应生成的服务代理类中就会多出几个方法（下面都以计算的服务为例）以下几个方法在接下来都会介绍到的 [csharp] public partial class CalculatorClient:ClientBase<ICalculator> ICalculator public event System EventHandler<AddCompleteArgs> AddComplete; public IAsyncResult BeginAdd（double x double y AsyncCallback callback object asuncState） public double EndAdd（System IAsyncReuslt result） public AddAsync（double x double y） public AddAsync（double x double y object userState）其中Add用于同步服务调用 BeginAdd/EndAdd则用于异步调用注意应用在BeginAdd方法上的OperationContractAttributes特性的AsyncPattern属性被设置成True 通过BeginXxx/EndXxx进行异步服务调用调用BeginXxx方法让相应的操作在另一个线程执行方法会立即返回一个IAsyncResult类型的对象此时我们可以在当前线程执行额外的操作异步操作执行的结果通过调用EndXxx方法得到而该方法的参数为调用BeginXxx方法得到的IAsyncResult对象通过添加计算服务引用生成的代理类型CalculatorClient为例 [csharp] CalculatorClient proxy=new CalculatorClient（） IAsyncResult asyncResult=proxy BeginAdd（ null null） //其他操作 //Endxx方法可以根据异步操作可能的执行时间来决定调用执行一旦Endxxx方法被调用后当前线程会被阻塞直到异步操作之行结束 double result=proxy EndAdd（asyncResult） proxy Close（） Console WriteLine（ x+y= when x= and y= result）注意一个极端的例子是在调用BeginXxx方法后就直接调用EndXxx方法虽然在不同的线程中但基本没有起到异步的作用这里可以用回调的方式来解决这个问题

通过回调的方式进行异步服务调用我们可以看看上面服务代理类中多出来的几个方法中BeginAdd方法 public IAsyncResult BeginAdd（double x double y AsyncCallback callback object asyncState） ①其中参数类型为AsyncCallback的callback AsyncCallback是个参数类型为IAsyncResult无返回值的委托 ②参数asyncState可以用于向回调操作传递一些额外的参数在BeginAdd方法中指定的asyncState可以通过IAsyncResult的AsyncState属性获得 [csharp] public delegate void AsyncCallback（IAsyncResult ar） public interface IAsyncResult object AsyncState get; WaitHandle AsyncWaitHandle get; bool CompletedSynchronously get; bool IsCompleted get; 下面通过一个匿名方法的形式定义回调操作由于在回调操作中输出运算结果时需要用到参与的运算数我们通过BeginAdd方法的asyncState参数实现向回调操作传递数据在回调操作中通过IAsyncResult对象的AsyncState获得操作数 [csharp] CalculatorClient proxy=new CalculatorClient（） proxy BeginAdd（ delegate（IAsyncResult asyncResult） double[] operNums=asyncResult AsyncState as double[]; double result=proxy EndAdd（asyncResult） proxy Close（） Console WriteLine（ x+y= when x= and y= operNums[ ] operNums[ ] result） new double[] ）通过事件注册的方式进行异步服务调用在那个异步服务代理类中还有两个异步执行的AddAsync方法重载和一个AddComplete事件 public AddAsync（double x double y） public AddAsync（double x double y object userState）其中userState参数和BeginAdd方法的asyncState参数具有相同的作用 [csharp] public event System EventHandler<AddCompleteEventArgs> AddComplete; public class AddCompleteEventArgs:EventArgs public bool Cancelledget; public Exception Errorget; public object UserState get; 事件参数AddCompleteEventArgs定义了个只读属性其中Cancelled表示异步操作是否取消异步操作抛出异常可以通过属性Error得到 UserState返回的是Addsync方法中的userState参数由于AddAsync方法是以异步方式执行的所以调用后会立即返回如果我们注册了CalculatorClient的AddComplete事件他将在异步服务调用结束后被触发所以我们可以按照如下方式调用服务代理Addsync方法 [csharp] CalculatorClient proxy=new CalculatorClient（） proxy AddComplete+=delegate（object sender AddCompleteEventArgs args） double[] operNums=args UserState as double[]; double result=args Result; proxy Close（） Console WriteLine（ x+y= when x= and y= operNums[ ] operNums[ ] result） ; proxy AddAsync（ new double[] ） 二异步服务的实现 上面介绍了如何调用异步服务但如何服务操作是如何以异步模式实现呢？异步操作模式前面提到过在OperationContractAttributes特性的AsyncPattern属性如果将应用到某个操作的方法上设为True 则意味着对应的操作需要采用异步模式来实现实际上客户端生成的异步服务代理类实现的契约接口中也包含了这样的异步操作异步服务操作是通过BeginXxx/EndXxx两个配对的方法实现的只需将BeginXx方法的特性将属性AsyncPattern设置为True即可三实例演示下面通过异步模式来定义一个读取文件的服务

　　客户端读取

cha138/Article/program/net/201311/13034