我们一起学习WCF 第九篇聊天功能

说到聊天,那么其实就是传输数据,把自己写的东西传给自己想发送的那么人。我总结一下传输常见的有三种方式

1:就是我们常见的数据库传输

2:就是文件(流)传输

3:就是socket传输

今天我们说的wcf实现聊天其实是基于socket的聊天功能

今天我先说说基于WCF聊天的原理

1:需要一个回调函数(当用户发送的时候会吧信息回调给客户端本身)

2:需要一个委托(把服务器传来的信息显示给前台)

3:需要一个触发点击事件(目的是为了触发把发送信息传到服务器)

基本主要由以上三个就能完成这个简单的聊天功能,下面我用图来描述我这个程序的基本流程

我们一起学习WCF 第九篇聊天功能

ok现在和我一起进行编码:

第一步:我们建立回调接口

    [ServiceContract]
public interface ICallBack
{
[OperationContract(IsOneWay = true)]
void SendMessage(string nick, string Onick, string content, DateTime sendTime);
}

第二步:我们建立两个类,一个作为返回用户登录信息类,一个用户发送信息类

 ///
发送类
///
public class SendInfo
{
/// <summary>
/// 发送者名字
/// </summary>
public string SendName { get; set; }
/// <summary>
/// 接受者名字
/// </summary>
public string RevName { get; set; }
/// <summary>
/// 发送内容
/// </summary>
public string SendContent { get; set; }
/// <summary>
/// 发送时间
/// </summary>
public DateTime SendTime { get; set; }
/// <summary>
/// 聊天模式(0表示群聊,1表示单聊)
/// </summary>
public int State { get; set; }
}
///
错误信息
/// [DataContract]
public class ResultMessage
{
/// <summary>
/// 错误信息
/// </summary>
[DataMember]
public string ErrorMessage { set; get; }
/// <summary>
/// 是否登录成功
/// </summary>
[DataMember]
public bool IsTrue { set; get; }
}

第三步:建立契约

   [ServiceContract(CallbackContract = typeof(ICallBack), SessionMode = SessionMode.Required)]
public interface IChatService
{
[OperationContract( IsInitiating = true, IsTerminating = false)]
ResultMessage Login(string UserName, string Pwd);
[OperationContract(IsOneWay = true)]
void sendMessage(SendInfo sendInfo);
[OperationContract(IsInitiating = false, IsTerminating = true)]
ResultMessage End(string UserName);
}

第四步:实现功能

  public void sendMessage(SendInfo sendInfo)
{
if (sendInfo.State == )
{
if (Clients != null)
{
foreach (ICallBack cb in Clients.Values.ToArray())
{
if (cb != null)
{
cb.SendMessage(sendInfo.SendName, sendInfo.RevName, sendInfo.SendContent, sendInfo.SendTime);
}
}
}
}
else
{
if (Clients.ContainsKey(sendInfo.RevName))
{
ICallBack cb1 = Clients[sendInfo.RevName];
cb1.SendMessage(sendInfo.SendName, sendInfo.RevName, sendInfo.SendContent, sendInfo.SendTime);
ICallBack cb2 = Clients[sendInfo.SendName];
cb2.SendMessage(sendInfo.SendName, sendInfo.RevName, sendInfo.SendContent, sendInfo.SendTime);
}
else
{
ICallBack cb = Clients[sendInfo.SendName];
cb.SendMessage(sendInfo.SendName, sendInfo.RevName, "对方不在线", sendInfo.SendTime);
}
}
}

注释1:Clients.Values.ToArray() 获取所有的用户信息,然后得到通道给每一个用户发送信息

注释2:ICallBack cb1 = Clients[sendInfo.RevName]; 获取回调接口,然后通过接口来返回用户发送信息

第五步:客户端实现回调接口

  public event EventHandler<CallbackRecEventArgs> ChatEvent;
public void SendMessage(string NickOne, string NickTwo, string Message, DateTime sendTime)
{
CallbackRecEventArgs crg = new CallbackRecEventArgs(NickOne, NickTwo, Message, sendTime);
ChatEvent(this, crg);
}

注释3:建立事件的目的是为了把信息传给前台进行显示

第六步:客户端实现

请参照我传的源码

第七步:看看运行效果

单聊效果

我们一起学习WCF 第九篇聊天功能

群聊效果:

我们一起学习WCF 第九篇聊天功能我们一起学习WCF 第九篇聊天功能

如果遇到什么地方不懂的可以私信给我

附上源码

上一篇:java Socket实现简单在线聊天(二)


下一篇:jquery事件学习笔记(转载)