我們一起學習WCF 第九篇聊天功能

說到聊天，那么其實就是傳輸數據，把自己寫的東西傳給自己想發送的那么人。我總結一下傳輸常見的有三種方式

1：就是我們常見的數據庫傳輸

2：就是文件（流）傳輸

3：就是socket傳輸

今天我們說的wcf實現聊天其實是基於socket的聊天功能

今天我先說說基於WCF聊天的原理

1：需要一個回調函數（當用戶發送的時候會吧信息回調給客戶端本身）

2：需要一個委托（把服務器傳來的信息顯示給前台）

3：需要一個觸發點擊事件（目的是為了觸發把發送信息傳到服務器）

基本主要由以上三個就能完成這個簡單的聊天功能，下面我用圖來描述我這個程序的基本流程

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 == 0)
            {
                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：建立事件的目的是為了把信息傳給前台進行顯示

第六步：客戶端實現

請參照我傳的源碼

第七步：看看運行效果

單聊效果

群聊效果：

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

附上源碼