Chinaunix首页 | 论坛 | 博客
  • 博客访问: 486121
  • 博文数量: 33
  • 博客积分: 4168
  • 博客等级: 上校
  • 技术积分: 675
  • 用 户 组: 普通用户
  • 注册时间: 2006-12-26 20:21
文章分类

全部博文(33)

文章存档

2013年(8)

2012年(2)

2011年(7)

2010年(1)

2009年(4)

2008年(11)

分类:

2011-04-01 14:35:26

   WCF双工通信中,如果服务端要向客户端推送消息的话,必须要在服务端首先获得了Client端的Callback对象,通过该回调对象来发起对Client的回调。

   这样问题就出来了,如Client意外中止,而此时保存在服务端的客户回调对象虽存在,但已失去意义。对于该问题,其实从最简单的方式来考虑,处理也可能很简单,对于循环向保留在服务端的每个回调对象推送消息时,都用异常扑捉来捕获异常,一旦发现某个回调对象做回调时发生异常,则将该回调对象从服务端移除。

   看起来这样处理很简单,但是存在相当的不足。对于做客户端回调时,只有在执行到超时时才能引发超时异常,这种超时由绑定的SendTimeOut确定,设长了等待过长,设短了会引起其他正常调用超时,同时该回调是线程阻塞的,也就是如果超时异常没有到达前,服务端就完全等待了,也就是说管理回调的整个方法体如果没有完成的话,所有需要获得服务端回调的客户端都没有办法接收到回调的消息。在这里只能采用多线程的方式来对所有Client回调对象进行管理。

demo:

     Thread t = new Thread(delegate()
      {

            lock (_connectedUsers)
            {
                UserInfo ui;
                if (_connectedUsers.TryGetValue(toUser.Id, out ui))
                {
                    try
                    {
                        ui.callBack.NewMessage(fromUser, toUser.Id, message, messageType);  //回调客户端方法
                    }
                    catch (Exception ex)
                    {
                        CallBackShowError(fromUser.Id, "NewMessage", toUser.Id, ex.Message); //到客户端:{0} 的回调:{1} 发生错误:{2}
                    }
                }
            }

       });

       t.Start();

阅读(1429) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~