分类:
2011-04-01 14:35:26
这样问题就出来了,如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();