WCFIDisposable接口应用功能详解

WCF是由微软公司开发的一款功能强大的.NET Framework 3.5的重要组成部件,主要作用于通信方面,在.NET Framework中,一个资源(尤其是非托管资源)通常都需要实现WCF IDisposable接口。一旦实现了该接口,我们就可以使用using语句来管理资源,这是最便捷的方式。但是,一旦在using语句中抛出了异常,就可能不会正确完成资源的回收,尤其是连接,很可能会一直打开,既占用了通道和端口,还可能出现资源的浪费,从而影响系统的性能和稳定性。

微软推荐的***实践是抛弃using语句,转而利用try/catch(/finally)语句。它要求在try语句中调用Close()方法,而在catch中调用Abort()方法。在新闻中已经说明了Close()与Abort()方法的区别,即后者可以强制地关闭客户端,包括关闭客户端连接,释放资源。由于Close()方法可能会抛出CommunicationException和TimeoutException异常,通常的客户端代码应该是这样:

 
 
 
  1. var myClient = new MyClient();
  2. try
  3. {
  4. //其他代码
  5. myClient.Close();
  6. }
  7. catch (CommunicationException)
  8. {
  9. myClient.Abort();
  10. }
  11. catch (TimeoutException)
  12. {
  13. myClient.Abort();
  14. }
  15. catch (Exception)
  16. {
  17. myClient.Abort();
  18. throw;
  19. }

***在WCF IDisposable接口增加对Exception异常的捕获很有必要,因为我们不知道Close()方法会否抛出某些不可预知的异常,例如OutOfMemoryException等。新闻中提到Steve Smith的方法其实就是对这段冗长代码的封装,封装方式是采用扩展方法,扩展的类型为ICommunicationObject。这是因为所有的客户端对象都实现了ICommunicationObject接口。以下是Steve Smith的扩展方法代码:

 
 
 
  1. public static class Extensions
  2. {
  3. public static void CloseConnection(this 
    ICommunicationObject myServiceClient)
  4. {
  5. if (myServiceClient.State != CommunicationState.Opened)
  6. {
  7. return;
  8. }
  9. try
  10. {
  11. myServiceClient.Close();
  12. }
  13. catch (CommunicationException ex)
  14. {
  15. Debug.Print(ex.ToString());
  16. myServiceClient.Abort();
  17. }
  18. catch (TimeoutException ex)
  19. {
  20. Debug.Print(ex.ToString());
  21. myServiceClient.Abort();
  22. }
  23. catch (Exception ex)
  24. {
  25. Debug.Print(ex.ToString());
  26. myServiceClient.Abort();
  27. throw;
  28. }
  29. }
  30. }

利用该扩展方法,在本应调用Close()方法的地方,代替为CloseConnection()方法,就可以避免写冗长的catch代码。而使用Lambda表达式的方式可以说是独辟蹊径,使用起来与using语法大致接近。实现方法是定义一个静态方法,并接受一个ICommunicationObject对象与Action委托:

 
 
 
  1. public class Util
  2. {
  3. public static void Using(T client, Action action)
  4. where T : ICommunicationObject
  5. {
  6. try
  7. {
  8. action(client);
  9. client.Close();
  10. }
  11. catch (CommunicationException)
  12. {
  13. client.Abort();
  14. }
  15. catch (TimeoutException)
  16. {
  17. client.Abort();
  18. }
  19. catch (Exception)
  20. {
  21. client.Abort();
  22. throw;
  23. }
  24. }
  25. }

使用时,可以将原本的客户端代码作为Action委托的Lambda表达式传递给Using方法中:

 
 
 
  1. Util.Using(new MyClient(), client =>
  2. {
  3. client.SomeWCFOperation();
  4. //其他代码;
  5. });

还有一种方法是定义一个自己的ChannelFactory,让其实现WCF IDisposable接口,并作为ChannelFactory的Wrapper类。在该类中定义Close()和Dispose()方法时,考虑到异常抛出的情况,并在异常抛出时调用Abort()方法。这样我们就可以在using中使用自定义的ChannelFactory类。例如:

 
 
 
  1. public class MyChannelFactory:IDisposable
  2. {
  3. private ChannelFactory m_innerFactory;
  4. public MyChannelFactory(ChannelFactory factory)
  5. {
  6. m_innerFactory = factory;
  7. }
  8. ~MyChannelFactory()
  9. {
  10. Dispose(false);
  11. }
  12. public void Close()
  13. {
  14. Close(TimeSpan.FromSeconds(10));
  15. }
  16. public void Close(TimeSpan span)
  17. {
  18. if (m_innerFactory != null)
  19. {
  20. if (m_innerFactory.State != CommunicationState.Opened)
  21. {
  22. return;
  23. }
  24. try
  25. {
  26. m_innerFactory.Close(span);
  27. }
  28. catch (CommunicationException)
  29. {
  30. m_innerFactory.Abort();
  31. }
  32. catch (TimeOutException)
  33. {
  34. m_innerFactory.Abort();
  35. }
  36. catch (Exception)
  37. {
  38. m_innerFactory.Abort();
  39. throw;
  40. }
  41. }
  42. }
  43. private void Dispose(booling disposing)
  44. {
  45. if (disposing)
  46. {
  47. Close();
  48. }
  49. }
  50. void IDisposable.Dispose()
  51. {
  52. Dispose(true);
  53. GC.SuppressFinalize(this);
  54. }
  55. }

对WCF IDisposable接口的相关介绍就为大家介绍到这里。

网站标题:WCFIDisposable接口应用功能详解
当前地址:http://www.shufengxianlan.com/qtweb/news33/362283.html

网站建设、网络推广公司-创新互联,是专注品牌与效果的网站制作,网络营销seo公司;服务项目有等

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联