Silverlight与WCF之间的通信(2)利用WCF的双工通信“推送”给SL数据
来源:本站原创 更新时间:2012-11-12
一,Duplex简介
上一个随笔记录了SL利用Timer定时去WCF上取数据再绑定到界面上的问题,今天尝试用了WCF的Duplex双工通信来做这个事情,也以这个例子来说明WCF中Duplex的使用。
双工通信的原理很简单,我们平时用的是客户端调用服务端的方法来获取数据,而Duplex是将客户端也当作了服务器,客户端上的方法也可以被调用,以聊天功能为例子,用户A连接到服务器后,之前的做法是客户端定时取数据,而Duplex是在服务端定时检测数据变化,如果发现了发送给A的信息,那么立即会调用客户端的方法来推送信息到A。
二,建立Duplex模式的WCF服务
这里以一个简单的聊天功能来说明,WCF提供了三个方法,连接到服务器方法,发送信息方法和接收信息方法。从服务契约上来说分为两个接口,分别是为客户端提供发送信息和开始聊天方法的IChatService接口和服务器调用客户端方法的IChatServiceCallBack接口
IChatService.cs文件
namespace ChatWCF { [ServiceContract(CallbackContract=typeof(IChatServiceCallBack))]//这里需要定义IChatService接口的回调接口IChatServiceCallBack public interface IChatService { [OperationContract] bool SendMessage(MessageInfo msg); //发送信息 [OperationContract] bool LoginChat(string User,string Partner);//开始聊天模式 } [ServiceContract] public interface IChatServiceCallBack //供服务端回调的接口 { [OperationContract(IsOneWay=true)] void ReceiveMessages(List<MessageInfo> listMessages);//客户端被服务端回调后接收信息 } }
接下来需要实现这接口,IChatService.svc.cs
namespace ChatWCF { public class ChatService : IChatService { IChatServiceCallBack chatserviceCallBack; string _user; string _partner; //开始聊天 public bool LoginChat(string User, string Partner) { try { chatserviceCallBack = OperationContext.Current.GetCallbackChannel<IChatServiceCallBack>(); _user = User; _partner = Partner; Timer timer = new Timer(new TimerCallback(CheckMessages), this, 100, 100); return true; } catch(Exception ex) { return false; } } //检查消息并回调客户端接收此消息,此处是回调的重点 private void CheckMessages(object o) { chatserviceCallBack.ReceiveMessages(GetMessages(_user,_partner)); } //发送信息 public bool SendMessage(MessageInfo msg) { [将MessageInfo写入数据库...] } //检测数据库 private List<MessageInfo> GetMessages(string User, string Partner) { List<MessageInfo> listMsg = new List<MessageInfo>(); [检测数据库并返回检测到的MessageInfo...] return listMsg; } //执行简单的sql语句 private DataSet Excutesql(string strsql) { string strServer = "server=LEON-PC\\sql2005;database=jplan;uid=sa;pwd=sa;"; sqlConnection con = new sqlConnection(strServer); con.open(); sqlDataAdapter dataAdapter = new sqlDataAdapter(strsql, con); DataSet ds = new DataSet(); dataAdapter.Fill(ds); con.Close(); return ds; } } }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。