using System;using System.Collections.Generic;using System.Linq;using System.ServiceModel;using System.ServiceModel.Description;using System.Text;using System.Threading.Tasks;namespace SendMessageHostConsoleApplication{    [ServiceContract(SessionMode=SessionMode.Required,CallbackContract=typeof(ICallback))]    public interface IService    {        /// <summary>        /// 启动会话        /// </summary>        [OperationContract(IsOneWay=true,IsInitiating=true,IsTerminating=false)]        void Begin();        /// <summary>        /// 客户端调用服务器端发送消息        /// </summary>        /// <param name="nick"></param>        /// <param name="msg"></param>        /// <param name="sendTime"></param>        [OperationContract(IsOneWay = true)]        void SendMessage(string nick,string msg,DateTime sendTime);        /// <summary>        /// 终止会话        /// </summary>        [OperationContract(IsOneWay=true,IsInitiating=false,IsTerminating=true)]        void End();    }    public interface ICallback    {        /// <summary>        /// 服务器端调用客户端发送消息        /// </summary>        /// <param name="nick"></param>        /// <param name="msg"></param>        /// <param name="sendTime"></param>        [OperationContract(IsOneWay=true)]        void SendToClients(string nick,string msg,DateTime sendTime);    }    [ServiceBehavior(IncludeExceptionDetailInFaults=true,InstanceContextMode=InstanceContextMode.PerSession)]    public class MyService : IService    {        public static Dictionary<string, ICallback> ClientCallBacks = new Dictionary<string, ICallback>();        public void Begin()        {            string sessionId = OperationContext.Current.SessionId;            ICallback cb = OperationContext.Current.GetCallbackChannel<ICallback>();            MyService.ClientCallBacks[sessionId] = cb;        }        public void SendMessage(string nick, string msg, DateTime sendTime)        {            foreach (ICallback  c in MyService.ClientCallBacks.Values)            {                if (c != null)                {                    c.SendToClients(nick, msg, sendTime);                }            }        }        public void End()        {            string sessionId = OperationContext.Current.SessionId;            if (MyService.ClientCallBacks.ContainsKey(sessionId))            {                MyService.ClientCallBacks.Remove(sessionId);            }        }    }    public class Program    {        public static void Main(string[] args)        {            using (ServiceHost host = new ServiceHost(typeof(MyService)))            {                NetTcpBinding bingding = new NetTcpBinding();                bingding.Security.Mode = SecurityMode.None;//不需要安全模式                host.AddServiceEndpoint(typeof(IService), bingding, "net.tcp://127.0.0.1:8868/channel");                ServiceMetadataBehavior behavior = new ServiceMetadataBehavior();                behavior.HttpGetEnabled = true;                behavior.HttpGetUrl = new Uri("http://127.0.0.1:8888/WSDL"); //httpGetUrl客户端引用的地址                host.Description.Behaviors.Add(behavior);                host.Opened += delegate                {                    Console.WriteLine("服务已启动");                    Console.ReadKey();                };                host.Open();            }        }    }}

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.ServiceModel;using System.Text;using System.Threading.Tasks;using System.Windows.Forms;namespace SendMessageClientWindowsFormsApplication{        public partial class Form1 : Form    {        private WS.ServiceClient client = null;        public Form1()        {            InitializeComponent();            MyCallback callback = new MyCallback();            callback.MessageReceived += callback_MessageReceived;            var instanceContext = new InstanceContext(callback);            client = new WS.ServiceClient(instanceContext);            client.Begin();            this.FormClosed += Form1_FormClosed;        }        void Form1_FormClosed(object sender, FormClosedEventArgs e)        {            client.End();        }        private void btnSend_Click(object sender, EventArgs e)        {                 client.SendMessage(this.txtNick.Text, this.txtSendMsg.Text, DateTime.Now);        }        void callback_MessageReceived(object sender, CallbackRecEventArgs e)        {            ListViewItem item = new ListViewItem();            Font font = new System.Drawing.Font(new FontFamily("宋体"), 12,FontStyle.Bold);            item.Font = font;            item.ForeColor = Color.Blue;            if (e.Nick == this.txtNick.Text)            {                item.ForeColor = Color.Green;            }            item.Text = e.Nick + "        " + e.SendTime+"\r\n";            listView1.Items.Add(item);            listView1.Items.Add(e.Message);            this.txtSendMsg.Text = "";        }    }    public class MyCallback : WS.IServiceCallback    {        public void SendToClients(string nick, string msg, DateTime sendTime)        {            if (this.MessageReceived != null)            {                CallbackRecEventArgs arg = new CallbackRecEventArgs(nick, msg, sendTime);                this.MessageReceived(this, arg);            }        }        public event EventHandler<CallbackRecEventArgs> MessageReceived;    }    public class CallbackRecEventArgs : EventArgs    {        private string _Nick, _Msg;        private DateTime _time;        public CallbackRecEventArgs(string nk, string m, DateTime t)        {            _Nick = nk;            _Msg = m;            _time = t;        }        public string Nick        {            get { return _Nick; }        }        public string Message        {            get { return _Msg; }        }        public DateTime SendTime        {            get { return _time; }        }    }}