using System;using System.Collections.Generic;using System.Linq;using System.Runtime.Serialization;using System.ServiceModel;using System.Text;using System.Collections;namespace WCFChatService{  // SessionMode.Required 允許Session會(huì)話。雙工協(xié)定時(shí)的回調(diào)協(xié)定類型為IChatCallback接口  [ServiceContract(SessionMode = SessionMode.Required, CallbackContract = typeof(IChatCallback))]  public interface IChatService  {    [OperationContract(IsOneWay = false, IsInitiating = true, IsTerminating = false)]//----->IsOneWay = false等待服務(wù)器完成對方法處理;IsInitiating = true啟動(dòng)Session會(huì)話,IsTerminating = false 設(shè)置服務(wù)器發(fā)送回復(fù)后不關(guān)閉會(huì)話    string[] Join(string name);//用戶加入    [OperationContract(IsOneWay = true, IsInitiating = false, IsTerminating = false)]    void Say(string msg);//群聊信息    [OperationContract(IsOneWay = true, IsInitiating = false, IsTerminating = false)]    void Whisper(string to, string msg);//私聊信息    [OperationContract(IsOneWay = true, IsInitiating = false, IsTerminating = true)]    void Leave();//用戶加入  }  /// <summary>  /// 雙向通信的回調(diào)接口  /// </summary>  interface IChatCallback  {    [OperationContract(IsOneWay = true)]    void Receive(string senderName, string message);    [OperationContract(IsOneWay = true)]    void ReceiveWhisper(string senderName, string message);    [OperationContract(IsOneWay = true)]    void UserEnter(string name);    [OperationContract(IsOneWay = true)]    void UserLeave(string name);  }  /// <summary>  /// 設(shè)定消息的類型  /// </summary>  public enum MessageType { Receive, UserEnter, UserLeave, ReceiveWhisper };  /// <summary>  /// 定義一個(gè)本例的事件消息類. 創(chuàng)建包含有關(guān)事件的其他有用的信息的變量，只要派生自EventArgs即可。  /// </summary>  public class ChatEventArgs : EventArgs  {    public MessageType msgType;    public string name;    public string message;  }}

using System;using System.Collections.Generic;using System.Linq;using System.Runtime.Serialization;using System.ServiceModel;using System.Text;namespace WCFChatService{  // InstanceContextMode.PerSession 服務(wù)器為每個(gè)客戶會(huì)話創(chuàng)建一個(gè)新的上下文對象。ConcurrencyMode.Multiple 異步的多線程實(shí)例  [ServiceBehavior(InstanceContextMode = InstanceContextMode.PerSession, ConcurrencyMode = ConcurrencyMode.Multiple)]  public class ChatService : IChatService  {    private static Object syncObj = new Object();////定義一個(gè)靜態(tài)對象用于線程部份代碼塊的鎖定，用于lock操作    IChatCallback callback = null;    public delegate void ChatEventHandler(object sender, ChatEventArgs e);//定義用于把處理程序賦予給事件的委托。    public static event ChatEventHandler ChatEvent;//定義事件    static Dictionary<string, ChatEventHandler> chatters = new Dictionary<string, ChatEventHandler>();//創(chuàng)建一個(gè)靜態(tài)Dictionary（表示鍵和值）集合(字典)，用于記錄在線成員，Dictionary<(Of <(TKey, TValue>)>) 泛型類    private string name;    private ChatEventHandler myEventHandler = null;    public string[] Join(string name)    {      bool userAdded = false;      myEventHandler = new ChatEventHandler(MyEventHandler);//將MyEventHandler方法作為參數(shù)傳遞給委托      lock (syncObj)//線程的同步性，同步訪問多個(gè)線程的任何變量，利用lock(獨(dú)占鎖)，確保數(shù)據(jù)訪問的唯一性。      {        if (!chatters.ContainsKey(name) && name != "" && name != null)        {          this.name = name;          chatters.Add(name, MyEventHandler);          userAdded = true;        }      }      if (userAdded)      {        callback = OperationContext.Current.GetCallbackChannel<IChatCallback>();//獲取當(dāng)前操作客戶端實(shí)例的通道給IChatCallback接口的實(shí)例callback,此通道是一個(gè)定義為IChatCallback類型的泛類型,通道的類型是事先服務(wù)契約協(xié)定好的雙工機(jī)制。        ChatEventArgs e = new ChatEventArgs();//實(shí)例化事件消息類ChatEventArgs        e.msgType = MessageType.UserEnter;        e.name = name;        BroadcastMessage(e);        ChatEvent += myEventHandler;        string[] list = new string[chatters.Count]; //以下代碼返回當(dāng)前進(jìn)入聊天室成員的稱列表        lock (syncObj)        {          chatters.Keys.CopyTo(list, 0);//將字典中記錄的用戶信息復(fù)制到數(shù)組中返回。        }        return list;      }      else      {        return null;      }    }    public void Say(string msg)    {      ChatEventArgs e = new ChatEventArgs();      e.msgType = MessageType.Receive;      e.name = this.name;      e.message = msg;      BroadcastMessage(e);    }    public void Whisper(string to, string msg)    {      ChatEventArgs e = new ChatEventArgs();      e.msgType = MessageType.ReceiveWhisper;      e.name = this.name;      e.message = msg;      try      {        ChatEventHandler chatterTo;//創(chuàng)建一個(gè)臨時(shí)委托實(shí)例        lock (syncObj)        {          chatterTo = chatters[to]; //查找成員字典中，找到要接收者的委托調(diào)用        }        chatterTo.BeginInvoke(this, e, new AsyncCallback(EndAsync), null);//異步方式調(diào)用接收者的委托調(diào)用      }      catch (KeyNotFoundException)      {      }    }    public void Leave()    {      if (this.name == null)        return;      lock (syncObj)      {        chatters.Remove(this.name);      }      ChatEvent -= myEventHandler;      ChatEventArgs e = new ChatEventArgs();      e.msgType = MessageType.UserLeave;      e.name = this.name;      this.name = null;      BroadcastMessage(e);    }    //回調(diào)，根據(jù)客戶端動(dòng)作通知對應(yīng)客戶端執(zhí)行對應(yīng)的操作    private void MyEventHandler(object sender, ChatEventArgs e)    {      try      {        switch (e.msgType)        {          case MessageType.Receive:            callback.Receive(e.name, e.message);            break;          case MessageType.ReceiveWhisper:            callback.ReceiveWhisper(e.name, e.message);            break;          case MessageType.UserEnter:            callback.UserEnter(e.name);            break;          case MessageType.UserLeave:            callback.UserLeave(e.name);            break;        }      }      catch      {        Leave();      }    }    private void BroadcastMessage(ChatEventArgs e)    {      ChatEventHandler temp = ChatEvent;      if (temp != null)      {        //循環(huán)將在線的用戶廣播信息        foreach (ChatEventHandler handler in temp.GetInvocationList())        {          //異步方式調(diào)用多路廣播委托的調(diào)用列表中的ChatEventHandler           handler.BeginInvoke(this, e, new AsyncCallback(EndAsync), null);        }      }    }    //廣播中線程調(diào)用完成的回調(diào)方法功能：清除異常多路廣播委托的調(diào)用列表中異常對象（空對象）    private void EndAsync(IAsyncResult ar)    {      ChatEventHandler d = null;      try      {        //封裝異步委托上的異步操作結(jié)果        System.Runtime.Remoting.Messaging.AsyncResult asres = (System.Runtime.Remoting.Messaging.AsyncResult)ar;        d = ((ChatEventHandler)asres.AsyncDelegate);        d.EndInvoke(ar);      }      catch      {        ChatEvent -= d;      }    }  }}

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;using System.Runtime.InteropServices;using System.ServiceModel;namespace WCFChatClient{  public partial class ChatForm : Form, IChatServiceCallback  {    /// <summary>    /// 該函數(shù)將指定的消息發(fā)送到一個(gè)或多個(gè)窗口。此函數(shù)為指定的窗口調(diào)用窗口程序，直到窗口程序處理完消息再返回。　    /// </summary>    /// <param name="hWnd">其窗口程序?qū)⒔邮障⒌拇翱诘木浔?lt;/param>    /// <param name="msg">指定被發(fā)送的消息</param>    /// <param name="wParam">指定附加的消息指定信息</param>    /// <param name="lParam">指定附加的消息指定信息</param>    [DllImport("user32.dll")]    private static extern int SendMessage(IntPtr hWnd, int msg, int wParam, IntPtr lParam);    //當(dāng)一個(gè)窗口標(biāo)準(zhǔn)垂直滾動(dòng)條產(chǎn)生一個(gè)滾動(dòng)事件時(shí)發(fā)送此消息給那個(gè)窗口，也發(fā)送給擁有它的控件    private const int WM_VSCROLL = 0x115;    private const int SB_BOTTOM = 7;    private int lastSelectedIndex = -1;    private ChatServiceClient proxy;    private string userName;    private WaitForm wfDlg = new WaitForm();    private delegate void HandleDelegate(string[] list);    private delegate void HandleErrorDelegate();    public ChatForm()    {      InitializeComponent();      ShowInterChatMenuItem(true);    }    /// <summary>    /// 連接服務(wù)器    /// </summary>    private void InterChatMenuItem_Click(object sender, EventArgs e)    {      lbOnlineUsers.Items.Clear();      LoginForm loginDlg = new LoginForm();      if (loginDlg.ShowDialog() == DialogResult.OK)      {        userName = loginDlg.txtUserName.Text;        loginDlg.Close();      }      txtChatContent.Focus();      Application.DoEvents();      InstanceContext site = new InstanceContext(this);//為實(shí)現(xiàn)服務(wù)實(shí)例的對象進(jìn)行初始化      proxy = new ChatServiceClient(site);      IAsyncResult iar = proxy.BeginJoin(userName, new AsyncCallback(OnEndJoin), null);      wfDlg.ShowDialog();    }    private void OnEndJoin(IAsyncResult iar)    {      try      {        string[] list = proxy.EndJoin(iar);        HandleEndJoin(list);      }      catch (Exception e)      {        HandleEndJoinError();      }    }    /// <summary>    /// 錯(cuò)誤提示    /// </summary>    private void HandleEndJoinError()    {      if (wfDlg.InvokeRequired)        wfDlg.Invoke(new HandleErrorDelegate(HandleEndJoinError));      else      {        wfDlg.ShowError("無法連接聊天室!");        ExitChatSession();      }    }    /// <summary>    /// 登錄結(jié)束后的處理    /// </summary>    /// <param name="list"></param>    private void HandleEndJoin(string[] list)    {      if (wfDlg.InvokeRequired)        wfDlg.Invoke(new HandleDelegate(HandleEndJoin), new object[] { list });      else      {        wfDlg.Visible = false;        ShowInterChatMenuItem(false);        foreach (string name in list)        {          lbOnlineUsers.Items.Add(name);        }        AppendText(" 用戶: " + userName + "--------登錄---------" + DateTime.Now.ToString()+ Environment.NewLine);      }    }    /// <summary>    /// 退出聊天室    /// </summary>    private void OutInterChatMenuItem_Click(object sender, EventArgs e)    {      ExitChatSession();      Application.Exit();    }    /// <summary>    /// 群聊    /// </summary>    private void btnChat_Click(object sender, EventArgs e)    {      SayAndClear("", txtChatContent.Text, false);      txtChatContent.Focus();    }    /// <summary>    /// 發(fā)送消息    /// </summary>    private void SayAndClear(string to, string msg, bool pvt)    {      if (msg != "")      {        try        {          CommunicationState cs = proxy.State;          //pvt 公聊還是私聊          if (!pvt)          {            proxy.Say(msg);          }          else          {            proxy.Whisper(to, msg);          }          txtChatContent.Text = "";        }        catch        {          AbortProxyAndUpdateUI();          AppendText("失去連接： " + DateTime.Now.ToString() + Environment.NewLine);          ExitChatSession();        }      }    }    private void txtChatContent_KeyPress(object sender, KeyPressEventArgs e)    {      if (e.KeyChar == 13)      {        e.Handled = true;        btnChat.PerformClick();      }    }    /// <summary>    /// 只有選擇一個(gè)用戶時(shí)，私聊按鈕才可用    /// </summary>    private void lbOnlineUsers_SelectedIndexChanged(object sender, EventArgs e)    {      AdjustWhisperButton();    }    /// <summary>    /// 私聊    /// </summary>        private void btnWhisper_Click(object sender, EventArgs e)    {      if (txtChatDetails.Text == "")      {        return;      }      object to = lbOnlineUsers.SelectedItem;      if (to != null)      {        string receiverName = (string)to;        AppendText("私下對" + receiverName + "說: " + txtChatContent.Text);//+ Environment.NewLine        SayAndClear(receiverName, txtChatContent.Text, true);        txtChatContent.Focus();      }    }    /// <summary>    /// 連接聊天室    /// </summary>    private void ShowInterChatMenuItem(bool show)    {      InterChatMenuItem.Enabled = show;      OutInterChatMenuItem.Enabled = this.btnChat.Enabled = !show;    }    private void AppendText(string text)    {      txtChatDetails.Text += text;      SendMessage(txtChatDetails.Handle, WM_VSCROLL, SB_BOTTOM, new IntPtr(0));    }    /// <summary>    /// 退出應(yīng)用程序時(shí),釋放使用資源    /// </summary>    private void ExitChatSession()    {      try      {        proxy.Leave();      }      catch { }      finally      {        AbortProxyAndUpdateUI();      }    }    /// <summary>    /// 釋放使用資源    /// </summary>    private void AbortProxyAndUpdateUI()    {      if (proxy != null)      {        proxy.Abort();        proxy.Close();        proxy = null;      }      ShowInterChatMenuItem(true);    }    /// <summary>    /// 接收消息    /// </summary>    public void Receive(string senderName, string message)    {      AppendText(senderName + "說: " + message + Environment.NewLine);    }    /// <summary>    /// 接收私聊消息    /// </summary>    public void ReceiveWhisper(string senderName, string message)    {      AppendText(senderName + " 私下說: " + message + Environment.NewLine);    }    /// <summary>    /// 新用戶登錄    /// </summary>    public void UserEnter(string name)    {      AppendText("用戶 " + name + " --------登錄---------" + DateTime.Now.ToString() + Environment.NewLine);      lbOnlineUsers.Items.Add(name);    }    /// <summary>    /// 用戶離開    /// </summary>    public void UserLeave(string name)    {      AppendText("用戶 " + name + " --------離開---------" + DateTime.Now.ToString() + Environment.NewLine);      lbOnlineUsers.Items.Remove(name);      AdjustWhisperButton();    }    /// <summary>    /// 控制私聊按鈕的可用性,只有選擇了用戶時(shí)按鈕才可用    /// </summary>    private void AdjustWhisperButton()    {      if (lbOnlineUsers.SelectedIndex == lastSelectedIndex)      {        lbOnlineUsers.SelectedIndex = -1;        lastSelectedIndex = -1;        btnWhisper.Enabled = false;      }      else      {        btnWhisper.Enabled = true;        lastSelectedIndex = lbOnlineUsers.SelectedIndex;      }      txtChatContent.Focus();    }    /// <summary>    /// 窗體關(guān)閉時(shí)，釋放使用資源    /// </summary>    private void ChatForm_FormClosed(object sender, FormClosedEventArgs e)    {      AbortProxyAndUpdateUI();      Application.Exit();    }  }}

if (host.Description.Behaviors.Find<System.ServiceModel.Description.ServiceMetadataBehavior>() == null)      {        BindingElement metaElement = new TcpTransportBindingElement();        CustomBinding metaBind = new CustomBinding(metaElement);        host.Description.Behaviors.Add(new System.ServiceModel.Description.ServiceMetadataBehavior());        host.AddServiceEndpoint(typeof(System.ServiceModel.Description.IMetadataExchange), metaBind, "MEX");      }