C# DotNetty客户端,包含心跳发送,断线重连机制

1.新建MessageBean消息类型类,也可以不用,看自己需要

public enum MsgType { STATUS_CONNECT_ERROR, STATUS_CONNECT_SUCCESS, STATUS_CONNECT_CLOSED, STATUC_CONNECT_RECONNECT }public class MessageBean
{/*** 消息类型*/private MsgType type;/*** 消息数据*/private Object msg;public MessageBean(MsgType type,Object msg){this.type = type;this.msg = msg;}public Object getMsg(){return msg;}public void setMsg(Object msg){this.msg = msg;}public void setType(MsgType type){this.type = type;}public MsgType getType(){return type;}public override string ToString(){return "MsgBean{" +"type=" + type +", msg=" + msg +'}';}
}

2.新建DotNettyClientHandler类,用于接收服务端消息

public class DotNettyClientHandler : FlowControlHandler
{/// <param name="ctx"></param>/// <param name="msg"></param>private DotNettyListener listener;private static String strMsg; public DotNettyClientHandler(DotNettyListener listener){this.listener = listener;}public override void ChannelActive(IChannelHandlerContext context){Console.WriteLine("==================ChannelActive======================");if (null != listener){listener.onServiceStatusConnectChanged(new MessageBean(MsgType.STATUS_CONNECT_SUCCESS, null));}}public override void ChannelInactive(IChannelHandlerContext context){base.ChannelInactive(context);//掉线了Console.WriteLine("===============ChannelInactive==============");if (null != listener){listener.onServiceStatusConnectChanged(new MessageBean(MsgType.STATUS_CONNECT_CLOSED, null));}DotNettyClient.getInstance(listener).start();}public override void ChannelRead(IChannelHandlerContext context, object msg){Console.WriteLine("===============ChannelRead==============");IByteBuffer byteBuffer = msg as IByteBuffer;strMsg += byteBuffer.ToString(Encoding.UTF8);if (byteBuffer != null){Console.WriteLine("byteBuffer:" + strMsg);if (strMsg.StartsWith("{") && strMsg.EndsWith("}")){listener.onMessageResponse(strMsg);strMsg = null;}}else {Console.WriteLine("---------null---------- ");}//context.WriteAsync(msg);}public override void ChannelReadComplete(IChannelHandlerContext context){Console.WriteLine("===============ChannelReadComplete==============");context.Flush();}public override void UserEventTriggered(IChannelHandlerContext context, object evt){Console.WriteLine("----------------UserEventTriggered----------------");base.UserEventTriggered(context, evt);if (evt is IdleStateEvent){var e = evt as IdleStateEvent;switch (e.State){//长期没收到服务器推送数据/**case IdleState.ReaderIdle:{//可以重新连接if (!context.Channel.Active)context.ConnectAsync(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9997));}break;//长期未向服务器发送数据case IdleState.WriterIdle:{//发送心跳包byte[] messageBytes = Encoding.UTF8.GetBytes("heartbeat");context.WriteAndFlushAsync(messageBytes);}break;**///Allcase IdleState.AllIdle:{//发送心跳包}break;}}}public override void ExceptionCaught(IChannelHandlerContext context, Exception exception){Console.WriteLine("===============ExceptionCaught==============");Console.WriteLine(exception);context.CloseAsync();if (null != listener){listener.onServiceStatusConnectChanged(new MessageBean(MsgType.STATUS_CONNECT_ERROR, exception.Message));}}
}

3.新建DotNettyClient类,管理DotNetty连接,消息发送

public interface DotNettyListener
{/*** 当接收到系统消息*/void onMessageResponse(Object msg);/*** 当连接状态发生变化时调用*/void onServiceStatusConnectChanged(MessageBean msg);
}
public class DotNettyClient
{#region Instancepublic IChannel clientChannel;public String ip = "127.0.0.1";//ippublic int port = 9997;//端口private DotNettyListener listener;//写的接口用来接收服务端返回的值private static DotNettyClient instance;public static DotNettyClient getInstance(DotNettyListener listener) {if (instance == null) {instance = new DotNettyClient();}instance.setListener(listener);return instance;}private DotNettyClient(){ }#endregionprivate ManualResetEvent ClosingArrivedEvent = new ManualResetEvent(false);public void start(){try{Task.Run(() => runClientAsync(ip,port));}catch (Exception exception){Console.WriteLine(exception.StackTrace);}}public async Task runClientAsync(String ip,int host){var group = new MultithreadEventLoopGroup();X509Certificate2 cert = null;string targetHost = null;try{var bootstrap = new Bootstrap();bootstrap.Group(group).Channel<TcpSocketChannel>().Option(ChannelOption.TcpNodelay, true)//.Option(ChannelOption.ConnectTimeout, new TimeSpan(0, 0, 0, 0, args.ConnectTimeout)).Handler(new ActionChannelInitializer<ISocketChannel>(channel =>{IChannelPipeline pipeline = channel.Pipeline;pipeline.AddLast(new StringEncoder(Encoding.UTF8));//pipeline.AddLast(new StringDecoder(Encoding.UTF8));pipeline.AddLast(new IdleStateHandler(0, 0, 100));pipeline.AddLast(new DotNettyClientHandler(listener));//定义Handler类及名称                }));clientChannel = await bootstrap.ConnectAsync(ip,port);ClosingArrivedEvent.Reset();ClosingArrivedEvent.WaitOne();await clientChannel.CloseAsync();}catch (Exception exp){//MainWindow.SetText("Client connection failed");Console.WriteLine(exp.ToString());Console.WriteLine(exp.StackTrace);}finally{//await group.ShutdownGracefullyAsync(TimeSpan.FromMilliseconds(100), TimeSpan.FromSeconds(1));reConnectServer();}}//断线重连private void reConnectServer(){Console.WriteLine("=================reConnectServer===================");if (null != listener) {listener.onServiceStatusConnectChanged(new MessageBean(MsgType.STATUC_CONNECT_RECONNECT, null));}try{Thread.Sleep(5000);start();}catch (Exception e){}}public bool SendMessage(string message){if (clientChannel != null && clientChannel.Open){clientChannel.WriteAndFlushAsync(message);Console.WriteLine("Sent message to server: " + message);return true;}return false;}public void disconnect() {Console.WriteLine("============disconnect==============");//await channel.CloseAsync();clientChannel.CloseAsync();}public void setListener(DotNettyListener listener){this.listener = listener;}
}

4.使用DotNetty

public partial class Form1 : Form, DotNettyListener
{public Form1(){InitializeComponent();}public void onMessageResponse(object msg){Console.WriteLine(msg);}public void onServiceStatusConnectChanged(MessageBean msg){Console.WriteLine("type = "+msg.getType()+",msg = "+msg.getMsg());}private void simpleButton1_Click(object sender, EventArgs e){DotNettyClient client = DotNettyClient.getInstance(this);client.start();Thread.Sleep(5000);client.SendMessage("12345");}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/882063.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

c# gobal using

在 C# 10 及以上版本中&#xff0c;引入了 全局 using&#xff08;Global using&#xff09;特性&#xff0c;这允许开发者在项目级别声明 using 命名空间&#xff0c;从而简化代码的书写和维护。全局 using 的主要作用是提高代码的可读性和减少重复声明。 全局 using 的基本概…

visio导出pdf公式变形问题杂谈

其实不会变形。 我自己的情况是直接用edge PDF阅读器打开pdf看到的是公式有变形&#xff08;常见是字体、形状变了&#xff09;&#xff0c;但换一个pdf阅读器如adobe的就是正常的了 不过大家一般是用edge pdf阅读器直接打开查看&#xff0c;所以通过visio打印的方式导出pdf可…

若依框架中spring security的完整认证流程,及其如何使用自定义用户表进行登录认证,学会轻松实现二开,嘎嘎赚块乾

1&#xff09;熟悉之前的SysUser登录流程 过滤器链验证配置 这里security过滤器链增加了前置过滤器链jwtFilter 该过滤器为我们自定义的&#xff0c;每次请求都会经过jwt验证 ok我们按ctrl alt B跳转过去来看下 首先会获取登录用户LoginUser 内部通过header键&#xff0c;获…

第十二章 RabbitMQ之失败消息处理策略

目录 一、引言 二、RepublishMessageRecoverer 实现 2.1. 实现步骤 2.2. 实现代码 2.2.1. 异常交换机队列回收期配置类 2.2.2. 常规交换机队列配置类 2.2.3. 消费者代码 2.2.4. 消费者yml配置 2.2.5. 生产者代码 2.2.6. 生产者yml配置 2.2.7. 运行效果 一、引言 …

Codeforces Round 883 (Div. 3) G. Rudolf and CodeVid-23(Dijkstra最短路)

题目链接 Codeforces Round 883 (Div. 3) G. Rudolf and CodeVid-23 思路 因为 n n n最大值为 10 10 10&#xff0c;且只有 01 01 01两种状态&#xff0c;当作二进制数转化为十进制数后最多只有 1024 1024 1024种。 因为 m m m的最大值为 1 e 3 1e3 1e3&#xff0c;因此我们…

重新定义自动驾驶的动态视觉?谷歌提出几何优先的动态场景方法MonST3R

导读&#xff1a; 本文引入了Motion DUSt3R (MonST3R)&#xff0c;这是一种几何优先的动态场景方法&#xff0c;它以点图的形式直接估计几何形状。相比以前的工作&#xff0c;MonST3R具有如下关键优势&#xff1a; 增强的稳健性&#xff0c;特别是在具有挑战性的场景中&#xf…

unity动态批处理

unity动态批处理 动态批处理要求和兼容性渲染管线兼容性 使用动态批处理网格的动态批处理限制动态生成几何体的动态批处理 动态批处理 动态批处理是一种绘制调用批处理方法&#xff0c;用于批处理移动的 GameObjects 以减少绘制调用。动态批处理在处理网格和 Unity 在运行时动…

【系统架构设计师】案例专题三:数据库系统考点梳理

更多内容请见: 备考系统架构设计师-核心总结目录 摘要:本文主要梳理系统架构设计师 - 数据库系统 案例考点 ,主要包括ORM技术、关系型数据库、内存数据库、NoSQL、规范化、分布式数据库、数据仓库集成等。 文章目录 一、ORM技术二、数据库分类比较三、并发控制四、封锁协议…

【二刷hot-100】day2

目录 1.无重复字符的最长子串 2.找到字符串中所有字母异位词 3.和为 K 的子数组 4.滑动窗口最大值 1.无重复字符的最长子串 class Solution {public int lengthOfLongestSubstring(String s) {Map<Character,Integer> dict new HashMap<>();int ret0;int i-1;for…

Oracle实际需要用到但常常被忽略的函数

1、Oracle中nvl()与nvl2()函数 函数nvl(expression1,expression2)根据参数1是否为null返回参数1或参数2的值&#xff1b; 函数nvl2(expression1,expression2,expression3)根据参数1是否为null返回参数2或参数3的值 【函数格式】&#xff1a;nvl(expression1,expression2) 若…

从一致性哈希算法带来的分布式系统设计思考

引言 在分布式系统中&#xff0c;数据存储和访问的均匀性、高可用性及可扩展性至关重要。一致性哈希算法&#xff08;Consistent Hashing&#xff09;以其优秀的数据分布特性&#xff0c;广泛应用于缓存、负载均衡和数据库分片等领域&#xff0c;有效提升了系统的稳定性和灵活…

快速了解AUTOSAR CP DEM模块作用与实现工作原理

在AUTOSAR&#xff08;Automotive Open System Architecture&#xff09;Classic Platform&#xff08;CP&#xff09;中&#xff0c;DEM&#xff08;Diagnostic Event Manager&#xff09;模块的主要作用是记录和管理ECU&#xff08;Electronic Control Unit&#xff09;内的诊…

uniapp onPageScroll

子组件有onPageScroll, 首页也要引入onPageScroll, eg: 主页面 sell/detail/index 《子组件》 <script setup> 引入onPageScroll </script> 组件&#xff1a; 引入onPageScroll 别人的比较

如果使用 Iptables 配置端口转发 ?

现实生活中&#xff0c;港口转发就像在一个大型公寓大楼里告诉送货司机该去哪里。通常情况下&#xff0c;该建筑群的正门是不对外开放的。但如果里面有人想要快递&#xff0c;他们可以告诉保安让司机进来&#xff0c;并指引他们到特定的公寓。 类似地&#xff0c;在计算机网络…

jeecg3版本的vue,离线启动

jeecg的vue2版本已经停止维护&#xff0c;所以只能用vue3的版本。3版本中使用的是pnpm&#xff08;npm的增强版本&#xff09;下载依赖。使用pnpm安装的node_modules&#xff0c;不能直接复制到离线主机中&#xff08;因为在 pnpm安装过程中&#xff0c;会给依赖的配置文件写死…

2025届保研-优营率0%上岸C9

保研面试心得 以上是标题 说在前面 本人保研边缘人&#xff0c;基本不陶瓷老师&#xff08;因为没啥成果&#xff0c;但是没啥用&#xff0c;不如有offer再套&#xff0c;结果0offer&#xff09;&#xff0c;大三还在努力卷保研资格。绩点不高专业一般英语一般项目很水&#…

【C++刷题】力扣-#118-杨辉三角

题目描述 给定一个非负整数 numRows&#xff0c;生成杨辉三角的前 numRows 行。在杨辉三角中&#xff0c;每个数是它正上方两个数的和。 示例 示例 1: 输入: numRows 5 输出: [[1],[1,1],[1,2,1],[1,3,3,1],[1,4,6,4,1]]示例 2: 输入: numRows 1 输出: [[1]]题解 这个问题…

Elasticsearch 入门

ES 概述 ES 是一个开源的高扩展的分布式全文搜索引擎。 倒排索引 环境准备 Elasticsearch 官方地址&#xff1a;https://www.elastic.co/cn/ 下载地址&#xff1a; 注意&#xff1a;9300 端口为 Elasticsearch 集群间组件的通信端口&#xff0c;9200 端口为浏览器访问的 h…

Leetcode 3321. Find X-Sum of All K-Long Subarrays II

Leetcode 3321. Find X-Sum of All K-Long Subarrays II 1. 解题思路2. 代码实现 题目链接&#xff1a;3321. Find X-Sum of All K-Long Subarrays II 1. 解题思路 这一题同样虽然是一道hard的题目&#xff0c;但也是比较常规的&#xff0c;就是通过一个滑动窗口不断地维护当…

【赵渝强老师】K8s中Deployment控制器与StatefulSet控制器的区别

一、K8s的Deployment与StatefulSets 在K8s中&#xff0c;Deployment将Pod部署成无状态的应用程序&#xff0c;它只关心Pod的数量、Pod更新方式、使用的镜像和资源限制等。由于是无状态的管理方式&#xff0c;因此Deployment中没有角色和顺序的概念&#xff0c;换句话说&#xf…