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

相关文章

python生成随机唯一id的几种实现方法

《python生成随机唯一id的几种实现方法》在Python中生成随机唯一ID有多种方法,根据不同的需求场景可以选择最适合的方案,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习... 目录方法 1:使用 UUID 模块(推荐)方法 2:使用 Secrets 模块(安全敏感场景)方法

Spring StateMachine实现状态机使用示例详解

《SpringStateMachine实现状态机使用示例详解》本文介绍SpringStateMachine实现状态机的步骤,包括依赖导入、枚举定义、状态转移规则配置、上下文管理及服务调用示例,重点解... 目录什么是状态机使用示例什么是状态机状态机是计算机科学中的​​核心建模工具​​,用于描述对象在其生命

Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

《SpringBoot结合WxJava实现文章上传微信公众号草稿箱与群发》本文将详细介绍如何使用SpringBoot框架结合WxJava开发工具包,实现文章上传到微信公众号草稿箱以及群发功能,... 目录一、项目环境准备1.1 开发环境1.2 微信公众号准备二、Spring Boot 项目搭建2.1 创建

IntelliJ IDEA2025创建SpringBoot项目的实现步骤

《IntelliJIDEA2025创建SpringBoot项目的实现步骤》本文主要介绍了IntelliJIDEA2025创建SpringBoot项目的实现步骤,文中通过示例代码介绍的非常详细,对大家... 目录一、创建 Spring Boot 项目1. 新建项目2. 基础配置3. 选择依赖4. 生成项目5.

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用:如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.

Linux下删除乱码文件和目录的实现方式

《Linux下删除乱码文件和目录的实现方式》:本文主要介绍Linux下删除乱码文件和目录的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录linux下删除乱码文件和目录方法1方法2总结Linux下删除乱码文件和目录方法1使用ls -i命令找到文件或目录

SpringBoot+EasyExcel实现自定义复杂样式导入导出

《SpringBoot+EasyExcel实现自定义复杂样式导入导出》这篇文章主要为大家详细介绍了SpringBoot如何结果EasyExcel实现自定义复杂样式导入导出功能,文中的示例代码讲解详细,... 目录安装处理自定义导出复杂场景1、列不固定,动态列2、动态下拉3、自定义锁定行/列,添加密码4、合并

mybatis执行insert返回id实现详解

《mybatis执行insert返回id实现详解》MyBatis插入操作默认返回受影响行数,需通过useGeneratedKeys+keyProperty或selectKey获取主键ID,确保主键为自... 目录 两种方式获取自增 ID:1. ​​useGeneratedKeys+keyProperty(推

Spring Boot集成Druid实现数据源管理与监控的详细步骤

《SpringBoot集成Druid实现数据源管理与监控的详细步骤》本文介绍如何在SpringBoot项目中集成Druid数据库连接池,包括环境搭建、Maven依赖配置、SpringBoot配置文件... 目录1. 引言1.1 环境准备1.2 Druid介绍2. 配置Druid连接池3. 查看Druid监控

Linux在线解压jar包的实现方式

《Linux在线解压jar包的实现方式》:本文主要介绍Linux在线解压jar包的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录linux在线解压jar包解压 jar包的步骤总结Linux在线解压jar包在 Centos 中解压 jar 包可以使用 u