WCF心跳判斷服務端及客戶端是否掉線並實現重連線
阿新 • • 發佈：2019-01-11
本篇文章將通過一個例項實現對WCF中針對服務端以及客戶端是否掉線進行判斷；若掉線時伺服器或客戶端又線上時將實現自動重連；將通過WCF的雙工知識以及相應的心跳包來實現此功能；
首先了解一下本例項的一個分層架構圖；相信瞭解WCF對這個分層法肯定都很瞭解；其中Client為客戶端，Interface為契約層，Service則是實現契約的服務層；
接下來我們將對各層進行一個簡單的講解；方便大家理解例項的實現方式；
首先我們瞭解契約層Interface；因為我們利用WCF中的雙工知識，所以此處我們定義的兩個介面，其中ICallback為回撥介面；IPushMessage上面定義的回撥；我們發現回撥介面上並沒有定義ServiceContract; 其實是WCF當一個介面被定義成回撥介面時已經默認了；
using System.ServiceModel; namespace Interface { [ServiceContract(SessionMode=SessionMode.Required,CallbackContract=typeof(ICallback))] public interface IPushMessage { [OperationContract(IsOneWay = true)] void Login(string UID); [OperationContract(IsOneWay = true)] void Update(string UID); [OperationContract(IsOneWay = true)] void Leave(string UID); } }
using System.ServiceModel; namespace Interface { public interface ICallback { [OperationContract(IsOneWay = true)] void ShowMessage(string msg); } }
接著我們瞭解一下實現契約的服務層Service;此處包括實現介面IPushMessage的服務內容，還定義一個類WcfCleint；在PushMessageServer服務內裡我們定義的一個靜態成員Dictionary<string,WcfCleint>用於記錄我們客戶端上下線的操作；定義的一個lockObje用來鎖定每個操作,在最後我們還定義的一個定時器用來判斷客戶端使用者是否離線了；其中方法Update()我們就實現的雙工中的回撥；
using System.ServiceModel; using Interface; namespace Service { public class PushMessageServer:IPushMessage { static Dictionary<string, WcfCleint> dit_callback = new Dictionary<string, WcfCleint>(); private static Object lockObje = new Object(); public void Login(string UID) { Console.WriteLine("使用者:" + UID + "上線"); lock (lockObje) { dit_callback.Add(UID, new WcfCleint(OperationContext.Current.GetCallbackChannel<ICallback>(), DateTime.Now)); } } public void Update(string UID) { ICallback callback = OperationContext.Current.GetCallbackChannel<ICallback>(); Console.WriteLine("使用者:" + UID + "心跳更新！"); lock (lockObje) { if (dit_callback.ContainsKey(UID)) { dit_callback.Remove(UID); } dit_callback.Add(UID, new WcfCleint(OperationContext.Current.GetCallbackChannel<ICallback>(), DateTime.Now)); callback.ShowMessage(UID); } } public void Leave(string UID) { Console.WriteLine("使用者:" + UID + "退出！"); lock (lockObje) { dit_callback.Remove(UID); } } static System.Timers.Timer timer1; public static void StartListenClients() { timer1 = new System.Timers.Timer(); timer1.Interval = 500; timer1.Elapsed += new System.Timers.ElapsedEventHandler(time_EventArgs); timer1.Start(); } static void time_EventArgs(object sender, System.Timers.ElapsedEventArgs e) { lock (lockObje) { foreach (string key in new List<string>(dit_callback.Keys)) { if (dit_callback[key].NowdateTime.AddSeconds(5) < DateTime.Now) { dit_callback.Remove(key); Console.WriteLine("離線使用者" + key); } } } } } }
接著我們簡單看一下WcfCleint的程式碼：
using Interface; using System.ServiceModel; namespace Service { public class WcfCleint { public DateTime NowdateTime { get; set; } public ICallback callbackHandler { get; set; } public WcfCleint(ICallback callback, DateTime nowTime) { this.callbackHandler = callback; this.NowdateTime = nowTime; } } }
服務端的配置檔案資訊，此處我們採用net.tcp方式：
<?xml version="1.0" encoding="utf-8" ?> <configuration> <system.serviceModel> <behaviors> <serviceBehaviors> <behavior name="exposeExceptionDetail"> <serviceDebug includeExceptionDetailInFaults="true"/> </behavior> </serviceBehaviors> </behaviors> <services> <service name="Service.PushMessageServer" behaviorConfiguration="exposeExceptionDetail"> <endpoint address="net.tcp://127.0.0.1:3721/PushMessageServer" binding="netTcpBinding" contract="Interface.IPushMessage"/> </service> </services> </system.serviceModel> </configuration>
服務端的執行入口程式碼，通過一個執行緒不斷的執行：
using System.Threading; using System.ServiceModel.Description; namespace Service { class Program { static void Main(string[] args) { using (ServiceHost host = new ServiceHost(typeof(PushMessageServer))) { host.Open(); Console.WriteLine("WCF心跳包實現開始監聽"); PushMessageServer.StartListenClients(); int i = 0; while (true) { System.Threading.Thread.Sleep(2000); i++; } Console.Read(); host.Abort(); host.Close(); } } } }
接著瞭解客戶端層的情況；首先是一個實現的回撥介面的內容類；
using Interface; namespace Client { public class CallServer:ICallback { public void ShowMessage(string msg) { Console.WriteLine("伺服器正在工作中；" + msg); } } }
客戶端的配置資訊如下：
<?xml version="1.0" encoding="utf-8" ?> <configuration> <system.serviceModel> <client> <endpoint name="pushmessageserver" address="net.tcp://127.0.0.1:3721/PushMessageServer" binding="netTcpBinding" contract="Interface.IPushMessage"/> </client> </system.serviceModel> </configuration>
客戶端的執行入口程式碼如下，它會判斷伺服器是否掉線，若掉線會試著重連：
using System.ServiceModel; using Interface; using System.ServiceModel.Channels; using System.Threading; namespace Client { class Program { static void Main(string[] args) { InstanceContext callback = new InstanceContext(new CallServer()); using (DuplexChannelFactory<IPushMessage> channelFactory = new DuplexChannelFactory<IPushMessage>(callback, "pushmessageserver")) { IPushMessage proxy = channelFactory.CreateChannel(); using (proxy as IDisposable) { string UID = "踏浪帥"; proxy.Login(UID); while (true) { Thread.Sleep(3000); try { proxy.Update(UID); } catch { try { Console.WriteLine("正在重連"); proxy = channelFactory.CreateChannel(); proxy.Login(UID); } catch { Console.WriteLine("重連異常"); } } } } } Console.Read(); } } }
程式碼的內容就如上，接著我們簡單看一下執行的效果：
1：首先執行服務端，讓其處於監聽
2：接著執行客戶端，客戶端會顯示伺服器正在工作中以及當前的賬號
3：當客戶端上線後，服務端就發現客戶端使用者，並顯示出來，不停的進行判斷
4：當我們把服務端停掉以後，此時服務是不工作的，我們可以看到客戶端就會不停的嘗試著重連服務端；
5：當我們重新把服務端開啟以後，服務端會自運發現正在執行的客戶端資訊；
6：上面我們重新開啟服務端，我們可以在客戶端發現它重連線服務端成功並顯示如下：
7：接著我們將把客戶端關閉；我們會在服務端發現它提示客戶端的使用者離線了；
8：此時服務端還是不停的監聽中，我們再把客戶端開啟，服務端將會接著顯示使用者；
