WCF实现事件通知相关应用技巧介绍
创始人
2024-06-16 20:01:06
0

WCF中有一些方法的应用对于初学者来说还是比较容易应用。只要熟练的联系这些方法操作,一般都能牢固的掌握。看了一些WCF的例子,实现事件通知使用的是多播委托的特性,有点复杂,操作起来也不是很直观,看到一堆委托和事件我一般头就晕了。#t#

下面介绍一种使用观察者模式WCF实现事件通知的简单方法。没别的,就是简单,简单最美。
工程代码如下:

WCF实现事件通知1.定义接口

  1. [ServiceContract(SessionModeSessionMode =
     SessionMode.Required, CallbackContract 
    = typeof(IWriteLogCallback))]  
  2. public interface ILogService  
  3. {  
  4. [OperationContract(IsInitiating = 
    true, IsTerminating = false)]  
  5. void Write(string logMsg);  
  6. [OperationContract(IsInitiating = 
    true, IsTerminating = false)]  
  7. void RegisterListener();  
  8. [OperationContract(IsInitiating = 
    false, IsTerminating = false)]  
  9. void UnregisterListener();  
  10. }  
  11. [ServiceContract]  
  12. public interface IWriteLogCallback  
  13. {  
  14. [OperationContract(IsOneWay = true)]  
  15. void OnWriteLog(string logMsg);  

为了简单举了一个写日志的例子, Write(string logMsg)就是写入日志的方法,参数logMsg是需要写入的日志信息。当客户单没有调用RegisterListener()订阅事件的时候,是不会收到写日志的事件通知的,相应的要获得写日志的事件通知,就需要调用RegisterListener()方法。如果要取消订阅就调用UnregisterListener()方法。写日志的功能和事件的订阅功能是分开的。

WCF实现事件通知2.服务实现

  1. [ServiceBehavior(  
  2. IncludeExceptionDetailInFaults = true,  
  3. InstanceContextModeInstanceContextMode =
     InstanceContextMode.Single,  
  4. ConcurrencyModeConcurrencyMode = 
    ConcurrencyMode.Multiple)]  
  5. class LogService:ILogService  
  6. {  
  7. public LogService()  
  8. {  
  9. Trace.WriteLine("Create LogService Instance.");  
  10. }  
  11. Dictionary 
    listeners = new Dictionary OperationContext>();  
  12. private void BroadCast(string logMsg)  
  13. {  
  14. List errorClints = new List();  
  15. foreach (KeyValuePair 
    listener in listeners)  
  16. {  
  17. try  
  18. {  
  19. listener.Value.GetCallbackChannel
    ().OnWriteLog(logMsg);  
  20. }  
  21. catch (System.Exception e)  
  22. {  
  23. errorClints.Add(listener.Key);  
  24. Trace.WriteLine("BROAD EVENT ERROR:" + e.Message);  
  25. }  
  26. }  
  27. foreach (string id in errorClints)  
  28. {  
  29. listeners.Remove(id);  
  30. }  
  31. }  
  32. #region ILogService 成员  
  33. public void Write(string logMsg)  
  34. {  
  35. Trace.WriteLine("Write LOG:"+logMsg);  
  36. BroadCast(logMsg);  
  37. }  
  38. public void RegisterListener()  
  39. {  
  40. listeners.Add(OperationContext.Current.
    SessionId, OperationContext.Current);  
  41. Trace.WriteLine("SessionID:" +
     OperationContext.Current.SessionId);  
  42. Trace.WriteLine("Register listener. 
    Client Count:" + listeners.Count.ToString());  
  43. }  
  44. public void UnregisterListener()  
  45. {  
  46. listeners.Remove(OperationContext
    .Current.SessionId);  
  47. Trace.WriteLine("SessionID:" + 
    OperationContext.Current.SessionId);  
  48. Trace.WriteLine("Unregister listener.
     Client Count:" + listeners.Count.ToString());  
  49. }  
  50. #endregion  
  51. } Dictionary 

listeners包含了所有的事件订阅者。发布事件的时候,如果调用订阅者的回调函数失败,就把该订阅者从listeners移除。代码很简单,就不多说了。

WCF实现事件通知3.客户端访问

定义回调的客户端:

  1. class LogClient:IWrite
    LogCallback  
  2. {  
  3. #region IWriteLog
    Callback 成员  
  4. public void OnWriteLog
    (string logMsg)  
  5. {  
  6. Trace.WriteLine("RECV 
    LOG EVENT:" + logMsg);  
  7. }  
  8. #endregion  

然后在程序中使用它:

  1. class Program  
  2. {  
  3. static void Main(string[] args)  
  4. {  
  5. Trace.Listeners.Add(new
     ConsoleTraceListener());  
  6. LogClient client = new LogClient();  
  7. ILogService service =
     DuplexChannelFactory.
    CreateChannel(client,  
  8. new WSDualHttpBinding(), new 
    EndpointAddress("http:
    //localhost:8888/log"));  
  9. //订阅消息  
  10. service.RegisterListener();  
  11. service.Write("Client start");  
  12. Console.WriteLine("Press 
    enter key to exit.");  
  13. Console.ReadLine();  
  14. service.UnregisterListener();  

WCF实现事件通知需要注意的问题:
A. 因为客户也要监听端口,所以确保防火墙没有对它进行阻止。
B. 这里使用的是单实例的服务,所以需要进行多进程访问的保护,才能实际使用。

相关内容

热门资讯

如何允许远程连接到MySQL数... [[277004]]【51CTO.com快译】默认情况下,MySQL服务器仅侦听来自localhos...
如何利用交换机和端口设置来管理... 在网络管理中,总是有些人让管理员头疼。下面我们就将介绍一下一个网管员利用交换机以及端口设置等来进行D...
施耐德电气数据中心整体解决方案... 近日,全球能效管理专家施耐德电气正式启动大型体验活动“能效中国行——2012卡车巡展”,作为该活动的...
20个非常棒的扁平设计免费资源 Apple设备的平面图标PSD免费平板UI 平板UI套件24平图标Freen平板UI套件PSD径向平...
Windows恶意软件20年“... 在Windows的早期年代,病毒游走于系统之间,偶尔删除文件(但被删除的文件几乎都是可恢复的),并弹...
德国电信门户网站可实时显示全球... 德国电信周三推出一个门户网站,直观地实时提供其安装在全球各地的传感器网络检测到的网络攻击状况。该网站...
为啥国人偏爱 Mybatis,... 关于 SQL 和 ORM 的争论,永远都不会终止,我也一直在思考这个问题。昨天又跟群里的小伙伴进行...
《非诚勿扰》红人闫凤娇被曝厕所... 【51CTO.com 综合消息360安全专家提醒说,“闫凤娇”、“非诚勿扰”已经被黑客盯上成为了“木...