WCF心跳判断服务端及客户端是否掉线并实现重连接

2024-06-18 15:48

本文主要是介绍WCF心跳判断服务端及客户端是否掉线并实现重连接,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

本篇文章将通过一个实例实现对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:此时服务端还是不停的监听中,我们再把客户端打开,服务端将会接着显示用户;

这篇关于WCF心跳判断服务端及客户端是否掉线并实现重连接的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1072426

相关文章

W外链微信推广短连接怎么做?

制作微信推广链接的难点分析 一、内容创作难度 制作微信推广链接时,首先需要创作有吸引力的内容。这不仅要求内容本身有趣、有价值,还要能够激起人们的分享欲望。对于许多企业和个人来说,尤其是那些缺乏创意和写作能力的人来说,这是制作微信推广链接的一大难点。 二、精准定位难度 微信用户群体庞大,不同用户的需求和兴趣各异。因此,制作推广链接时需要精准定位目标受众,以便更有效地吸引他们点击并分享链接

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯,先赞后看哦~🎈🎈 🏆 作者简介:景天科技苑 🏆《头衔》:大厂架构师,华为云开发者社区专家博主,阿里云开发者社区专家博主,CSDN全栈领域优质创作者,掘金优秀博主,51CTO博客专家等。 🏆《博客》:Python全栈,前后端开发,小程序开发,人工智能,js逆向,App逆向,网络系统安全,数据分析,Django,fastapi

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现,因为rasa本身是带有remindschedule模块的。不过经过一番折腾后,忽然发现,chatbot上实现的定时,语音助手不一定会有响应。因为,我目前语音助手的代码设置了长时间无应答会结束对话,这样一来,chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢? 我最后选择的方法是用threading.Time

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸(两张壁纸可不一致)

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸: 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  (注意不能是bmp格式) 替换默认锁屏壁纸: 将图片资源放入vendo

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount

poj 3259 uva 558 Wormholes(bellman最短路负权回路判断)

poj 3259: 题意:John的农场里n块地,m条路连接两块地,w个虫洞,虫洞是一条单向路,不但会把你传送到目的地,而且时间会倒退Ts。 任务是求你会不会在从某块地出发后又回来,看到了离开之前的自己。 判断树中是否存在负权回路就ok了。 bellman代码: #include<stdio.h>const int MaxN = 501;//农场数const int

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略 1. 特权模式限制2. 宿主机资源隔离3. 用户和组管理4. 权限提升控制5. SELinux配置 💖The Begin💖点点关注,收藏不迷路💖 Kubernetes的PodSecurityPolicy(PSP)是一个关键的安全特性,它在Pod创建之前实施安全策略,确保P

工厂ERP管理系统实现源码(JAVA)

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本,并实时掌握各环节的运营状况。 在采购管理方面,系统能够处理采购订单、供应商管理和采购入库等流程,确保采购过程的透明和高效。仓库管理方面,实现库存的精准管理,包括入库、出库、盘点等操作,确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、