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

2024-06-18 15:48
文章标签 实现 连接 判断 是否 服务端 客户端 wcf 心跳 掉线

本文主要是介绍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。

相关文章

SpringBoot集成redisson实现延时队列教程

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配
阅读更多...
Python的Darts库实现时间序列预测

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts？二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与
阅读更多...
Python使用FastAPI实现大文件分片上传与断点续传功能

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现（FastAPI）2.1 运行环境2.2 目录结构建议2.3 serv
阅读更多...
C#实现千万数据秒级导入的代码

C#实现千万数据秒级导入的代码

《C#实现千万数据秒级导入的代码》在实际开发中excel导入很常见,现代社会中很容易遇到大数据处理业务,所以本文我就给大家分享一下千万数据秒级导入怎么实现,文中有详细的代码示例供大家参考,需要的朋友可... 目录前言一、数据存储二、处理逻辑优化前代码处理逻辑优化后的代码总结前言在实际开发中excel导入很
阅读更多...
SpringBoot+RustFS 实现文件切片极速上传的实例代码

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot？二、环境准备与部署2.1 安装 RustF
阅读更多...
Nginx部署HTTP/3的实现步骤

Nginx部署HTTP/3的实现步骤

《Nginx部署HTTP/3的实现步骤》本文介绍了在Nginx中部署HTTP/3的详细步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前提条件第一步：安装必要的依赖库第二步：获取并构建 BoringSSL第三步：获取 Nginx
阅读更多...
java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

《java.sql.SQLTransientConnectionException连接超时异常原因及解决方案》：本文主要介绍java.sql.SQLTransientConnectionExcep... 目录一、引言二、异常信息分析三、可能的原因3.1 连接池配置不合理3.2 数据库负载过高3.3 连接泄漏
阅读更多...
MyBatis Plus实现时间字段自动填充的完整方案

MyBatis Plus实现时间字段自动填充的完整方案

《MyBatisPlus实现时间字段自动填充的完整方案》在日常开发中,我们经常需要记录数据的创建时间和更新时间,传统的做法是在每次插入或更新操作时手动设置这些时间字段,这种方式不仅繁琐,还容易遗漏,... 目录前言解决目标技术栈实现步骤1. 实体类注解配置2. 创建元数据处理器3. 服务层代码优化填充机制详
阅读更多...
Python实现Excel批量样式修改器(附完整代码)

Python实现Excel批量样式修改器(附完整代码)

《Python实现Excel批量样式修改器(附完整代码)》这篇文章主要为大家详细介绍了如何使用Python实现一个Excel批量样式修改器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录前言功能特性核心功能界面特性系统要求安装说明使用指南基本操作流程高级功能技术实现核心技术栈关键函
阅读更多...
Java实现字节字符转bcd编码

Java实现字节字符转bcd编码

《Java实现字节字符转bcd编码》BCD是一种将十进制数字编码为二进制的表示方式,常用于数字显示和存储,本文将介绍如何在Java中实现字节字符转BCD码的过程,需要的小伙伴可以了解下... 目录前言BCD码是什么Java实现字节转bcd编码方法补充总结前言BCD码（Binary-Coded Decima
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2