说到聊天,那么其实就是传输数据,把自己写的东西传给自己想发送的那么人。我总结一下传输常见的有三种方式
1:就是我们常见的数据库传输
2:就是文件(流)传输
3:就是socket传输
今天我们说的wcf实现聊天其实是基于socket的聊天功能(QQ聊天发展到今天肯定是很牛的了,但是最初肯定也是这样的思想)
今天我先说说基于WCF聊天的原理
1:需要一个回调函数(当用户发送的时候会吧信息回调给客户端本身)
2:需要一个委托(把服务器传来的信息显示给前台)
3:需要一个触发点击事件(目的是为了触发把发送信息传到服务器)
基本主要由以上三个就能完成这个简单的聊天功能,下面我用图来描述我这个程序的基本流程
ok现在和我一起进行编码:
第一步:我们建立回调接口
1[ServiceContract]2publicinterfaceICallBack3{4[OperationContract(IsOneWay =true)]5voidSendMessage(stringnick,stringOnick,stringcontent, DateTime sendTime);6}
第二步:我们建立两个类,一个作为返回用户登录信息类,一个用户发送信息类
1///2发送类3///4publicclassSendInfo5{6///<summary>7///发送者名字8///</summary>9publicstringSendName {get;set; }10///<summary>11///接受者名字12///</summary>13publicstringRevName {get;set; }14///<summary>15///发送内容16///</summary>17publicstringSendContent {get;set; }18///<summary>19///发送时间20///</summary>21publicDateTime SendTime {get;set; }22///<summary>23///聊天模式(0表示群聊,1表示单聊)24///</summary>25publicintState {get;set; }26}27///28错误信息29///3031[DataContract]32publicclassResultMessage33{34///<summary>35///错误信息36///</summary>37[DataMember]38publicstringErrorMessage {set;get; }39///<summary>40///是否登录成功41///</summary>42[DataMember]43publicboolIsTrue {set;get; }44}
第三步:建立契约
1[ServiceContract(CallbackContract =typeof(ICallBack),sessionMode =SessionMode.Required)]2publicinterfaceIChatService3{4[OperationContract( IsInitiating =true, IsTerminating =false)]5ResultMessage Login(stringUserName,stringPwd);6[OperationContract(IsOneWay =true)]7voidsendMessage(SendInfo sendInfo);8[OperationContract(IsInitiating =false, IsTerminating =true)]9ResultMessage End(stringUserName);10}
第四步:实现功能
1publicvoidsendMessage(SendInfo sendInfo)2{3if(sendInfo.State ==0)4{5if(Clients !=null)6{7foreach(ICallBack cbinClients.Values.ToArray())8{9if(cb !=null)10{11cb.SendMessage(sendInfo.SendName, sendInfo.RevName, sendInfo.SendContent, sendInfo.SendTime);12}13}14}15}16else17{18if(Clients.ContainsKey(sendInfo.RevName))19{20ICallBack cb1 =Clients[sendInfo.RevName];21cb1.SendMessage(sendInfo.SendName, sendInfo.RevName, sendInfo.SendContent, sendInfo.SendTime);22ICallBack cb2 =Clients[sendInfo.SendName];23cb2.SendMessage(sendInfo.SendName, sendInfo.RevName, sendInfo.SendContent, sendInfo.SendTime);24}25else26{27ICallBack cb =Clients[sendInfo.SendName];28cb.SendMessage(sendInfo.SendName, sendInfo.RevName,"对方不在线", sendInfo.SendTime);29}30}31}
注释1:Clients.Values.ToArray() 获取所有的用户信息,然后得到通道给每一个用户发送信息
注释2:ICallBack cb1 = Clients[sendInfo.RevName]; 获取回调接口,然后通过接口来返回用户发送信息
第五步:客户端实现回调接口
publiceventEventHandler<CallbackRecEventArgs>ChatEvent;publicvoidSendMessage(stringNickOne,stringNickTwo,stringMessage, DateTime sendTime)
{
CallbackRecEventArgs crg=newCallbackRecEventArgs(NickOne, NickTwo, Message, sendTime);
ChatEvent(this, crg);
}
注释3:建立事件的目的是为了把信息传给前台进行显示
第六步:客户端实现
请参照我传的源码
第七步:看看运行效果
单聊效果
群聊效果:
如果遇到什么地方不懂的可以私信给我
附上源码