DotNetty客户端断线重连

DotNetty客户端断线重连1、代码如下：usingSystem;usingSystem.Collections.Generic;usingDotNetty.Buffers;usingDotNetty.Transport.Bootstrapping;usingDotNetty.Transport.Channels;usingDotNetty.Transport.Channels.Sockets;usingSystem.Linq;usingSystem.Net;usingSystem.Text;usingSystem.Threading.Tasks;usingSystem.IO;usingSystem.Threading;usingTest.Model;usingDotNetty.Handlers.Timeout;usingDotNetty.Handlers.Logging;///zuochao_2013/article/details/72872315namespaceTest{publicclassExliveNettyClient{MultithreadEventLoopGroupgroup;Bootstrapbootstrap;ExliveClientHandlerhandler;publicExliveNettyClient(){group=newMultithreadEventLoopGroup();bootstrap=newBootstrap();handler=newExliveClientHandler(this);bootstrap.Group(group).Channel<TcpSocketChannel>().Option(ChannelOption.TcpNodelay,true).Option(ChannelOption.ConnectTimeout,TimeSpan.FromSeconds(3)).Handler(newActionChannelInitializer<ISocketChannel>(c=>{varpipeline=c.Pipeline;//pipeline.AddLast("timeout",newIdleStateHandler(TimeSpan.FromSeconds(5),TimeSpan.FromSeconds(5),TimeSpan.FromSeconds(5)));pipeline.AddLast(handler);}));bootstrap.RemoteAddress(newIPEndPoint(IPAddress.Parse(AppConfig.ServerIP),AppConfig.ServerPort));RunClientAsync().Wait();}publicasyncTaskConnectToServer(){try{IChannelclientChannel=null;try{clientChannel=awaitbootstrap.ConnectAsync();}catch(Exceptionex){System.Threading.Thread.Sleep(5000);awaitConnectToServer();}}}finally{Console.ReadLine();awaitgroup.ShutdownGracefullyAsync(TimeSpan.FromMilliseconds(100),TimeSpan.FromSeconds(1));}}privateasyncTaskRunClientAsync(){awaitConnectToServer();}}classExliveClientHandler:ChannelHandlerAdapter,IExliveNetInterface{privateinttotal=0;///<summary>///通道///</summary>privateIChannelHandlerContextcontext;///<summary>///消息处理///</summary>privateMessageProcessmp;///<summary>///客户端///</summary>privateExliveNettyClientclient;///<summary>////w592376568/article/details/79898062///报错：isnota@Sharablehandler///要么就是IsSharable设为true，要么就是每次都new⼀个新的handler的实例///</summary>publicoverrideboolIsSharable=>true;publicExliveClientHandler(ExliveNettyClientclient){this.client=client;mp=newMessageProcess(this);}publicoverridevoidHandlerAdded(IChannelHandlerContextcontext){this.context=context;base.HandlerAdded(context);}publicoverridevoidChannelRegistered(IChannelHandlerContextcontext){base.ChannelRegistered(context);}publicoverridevoidChannelUnregistered(IChannelHandlerContextcontext){}publicoverridevoidChannelActive(IChannelHandlerContextcontext){total=0;mp.SendData(ExliveCmd.LOGIN);base.ChannelActive(context);}publicoverridevoidChannelInactive(IChannelHandlerContextcontext){Reconnect(context);base.ChannelInactive(context);}publicoverridevoidChannelRead(IChannelHandlerContextcontext,objectmessage){if(messageisIByteBufferbuffer){stringdata=buffer.ToString(System.Text.Encoding.GetEncoding("gb2312"));mp.AfterReceiveData(data);stringrecieveText="recieve:"+context.Channel.RemoteAddress.ToString()+"->"+context.Channel.LocalAddress.ToString()+"\r\n"+(string.IsNullOrEmpty(data)?"":data.Trim(newchar[]{'\r','\n'}));//Console.WriteLine(recieveText);Log.WriteLog(recieveText);}}publicoverridevoidChannelReadComplete(IChannelHandlerContextcontext)=>context.Flush();publicoverridevoidHandlerRemoved(IChannelHandlerContextcontext){Reconnect(context);Console.WriteLine($"服务端{context}下线.");base.HandlerRemoved(context);}publicoverridevoidExceptionCaught(IChannelHandlerContextcontext,Exceptionexception){Reconnect(context);base.ExceptionCaught(context,exception);}publicoverridevoidUserEventTriggered(IChannelHandlerContextcontext,objectevt){if(evtisIdleStateEvent){vareventState=evtasIdleStateEvent;if(eventState!=null){switch(eventState.State){caseIdleState.ReaderIdle:break;caseIdleState.WriterIdle://长时间未写⼊数据//则发送⼼跳数据//context.WriteAndFlushAsync();mp.SendData(ExliveCmd.HEART);break;caseIdleState.AllIdle:break;}}}}publicvoidSendPackage(stringdata){byte[]messageBytes=System.Text.Encoding.GetEncoding("gb2312").GetBytes(data);IByteBufferinitialMessage=Unpooled.Buffer(messageBytes.Length);initialMessage.WriteBytes(messageBytes);if(context!=null)context.WriteAndFlushAsync(initialMessage);}publicvoidSendPackage(objectobj){varsendMessage=Json.ToCamelCaseJson(obj);SendPackage(sendMessage);}publicvoidReconnect(IChannelHandlerContextcontext){Interlocked.Increment(reftotal);if(total==1){newAction(async()=>{awaitthis.client.ConnectToServer();}).BeginInvoke(null,null);}}}}2、事件顺序Added->Registered->Active,如果连接成功会执⾏到Active，未成功会在ConnectToServer中