使用DotNetty代替原来的网络框架

GWSocketClient/Form1.Designer.cs

             this.toolStripStatusLabel2 = new System.Windows.Forms.ToolStripStatusLabel();
             this.tsslCCIDLEN = new System.Windows.Forms.ToolStripStatusLabel();
             this.toolStripStatusLabelHbShow = new System.Windows.Forms.ToolStripStatusLabel();
+            this.toolStripStatusLabelSendTime = new System.Windows.Forms.ToolStripStatusLabel();
             this.groupBox2 = new System.Windows.Forms.GroupBox();
             this.listBoxShow = new System.Windows.Forms.ListBox();
             this.cmslistboxRightMenu = new System.Windows.Forms.ContextMenuStrip(this.components);
             this.rightMenuCopyCmd = new System.Windows.Forms.ToolStripMenuItem();
             this.rightMenuClearInfo = new System.Windows.Forms.ToolStripMenuItem();
             this.timerHeartBeat = new System.Windows.Forms.Timer(this.components);
-            this.toolStripStatusLabelSendTime = new System.Windows.Forms.ToolStripStatusLabel();
             this.groupBox1.SuspendLayout();
             this.menuStrip1.SuspendLayout();
             this.statusStrip1.SuspendLayout();
             this.toolStripStatusLabelHbShow.Size = new System.Drawing.Size(82, 17);
             this.toolStripStatusLabelHbShow.Text = "心跳时间: 5秒";
             // 
+            // toolStripStatusLabelSendTime
+            // 
+            this.toolStripStatusLabelSendTime.Name = "toolStripStatusLabelSendTime";
+            this.toolStripStatusLabelSendTime.Size = new System.Drawing.Size(85, 17);
+            this.toolStripStatusLabelSendTime.Text = "发送-回复时间";
+            // 
             // groupBox2
             // 
             this.groupBox2.Anchor = ((System.Windows.Forms.AnchorStyles)((((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Bottom) 
             | System.Windows.Forms.AnchorStyles.Left) 
             | System.Windows.Forms.AnchorStyles.Right)));
             this.groupBox2.Controls.Add(this.listBoxShow);
-            this.groupBox2.Location = new System.Drawing.Point(14, 380);
+            this.groupBox2.Location = new System.Drawing.Point(14, 195);
             this.groupBox2.Margin = new System.Windows.Forms.Padding(3, 4, 3, 4);
             this.groupBox2.Name = "groupBox2";
             this.groupBox2.Padding = new System.Windows.Forms.Padding(3, 4, 3, 4);
-            this.groupBox2.Size = new System.Drawing.Size(1123, 490);
+            this.groupBox2.Size = new System.Drawing.Size(1123, 675);
             this.groupBox2.TabIndex = 13;
             this.groupBox2.TabStop = false;
             this.groupBox2.Text = "显示信息栏";
             this.listBoxShow.Location = new System.Drawing.Point(9, 28);
             this.listBoxShow.Margin = new System.Windows.Forms.Padding(3, 4, 3, 4);
             this.listBoxShow.Name = "listBoxShow";
-            this.listBoxShow.Size = new System.Drawing.Size(1106, 454);
+            this.listBoxShow.Size = new System.Drawing.Size(1106, 634);
             this.listBoxShow.TabIndex = 0;
             this.listBoxShow.DrawItem += new System.Windows.Forms.DrawItemEventHandler(this.listBoxShow_DrawItem);
             this.listBoxShow.DoubleClick += new System.EventHandler(this.listBoxShow_DoubleClick);
             this.timerHeartBeat.Interval = 5000;
             this.timerHeartBeat.Tick += new System.EventHandler(this.timerHeartBeat_Tick);
             // 
-            // toolStripStatusLabelSendTime
-            // 
-            this.toolStripStatusLabelSendTime.Name = "toolStripStatusLabelSendTime";
-            this.toolStripStatusLabelSendTime.Size = new System.Drawing.Size(85, 17);
-            this.toolStripStatusLabelSendTime.Text = "发送-回复时间";
-            // 
             // Form1
             // 
             this.AutoScaleDimensions = new System.Drawing.SizeF(7F, 17F);

GWSocketClient/GWSocketClient.csproj

     <ApplicationIcon>GWSocket.ico</ApplicationIcon>
   </PropertyGroup>
   <ItemGroup>
+    <Reference Include="DotNetty.Buffers, Version=0.4.6.0, Culture=neutral, PublicKeyToken=bc13ca065fa06c29, processorArchitecture=MSIL">
+      <HintPath>..\packages\DotNetty.Buffers.0.4.6\lib\net45\DotNetty.Buffers.dll</HintPath>
+    </Reference>
+    <Reference Include="DotNetty.Codecs, Version=0.4.6.0, Culture=neutral, PublicKeyToken=bc13ca065fa06c29, processorArchitecture=MSIL">
+      <HintPath>..\packages\DotNetty.Codecs.0.4.6\lib\net45\DotNetty.Codecs.dll</HintPath>
+    </Reference>
+    <Reference Include="DotNetty.Common, Version=0.4.6.0, Culture=neutral, PublicKeyToken=bc13ca065fa06c29, processorArchitecture=MSIL">
+      <HintPath>..\packages\DotNetty.Common.0.4.6\lib\net45\DotNetty.Common.dll</HintPath>
+    </Reference>
+    <Reference Include="DotNetty.Handlers, Version=0.4.6.0, Culture=neutral, PublicKeyToken=bc13ca065fa06c29, processorArchitecture=MSIL">
+      <HintPath>..\packages\DotNetty.Handlers.0.4.6\lib\net45\DotNetty.Handlers.dll</HintPath>
+    </Reference>
+    <Reference Include="DotNetty.Transport, Version=0.4.6.0, Culture=neutral, PublicKeyToken=bc13ca065fa06c29, processorArchitecture=MSIL">
+      <HintPath>..\packages\DotNetty.Transport.0.4.6\lib\net45\DotNetty.Transport.dll</HintPath>
+    </Reference>
+    <Reference Include="Microsoft.Extensions.DependencyInjection.Abstractions, Version=1.1.0.0, Culture=neutral, PublicKeyToken=adb9793829ddae60, processorArchitecture=MSIL">
+      <HintPath>..\packages\Microsoft.Extensions.DependencyInjection.Abstractions.1.1.0\lib\netstandard1.0\Microsoft.Extensions.DependencyInjection.Abstractions.dll</HintPath>
+    </Reference>
+    <Reference Include="Microsoft.Extensions.Logging, Version=1.1.1.0, Culture=neutral, PublicKeyToken=adb9793829ddae60, processorArchitecture=MSIL">
+      <HintPath>..\packages\Microsoft.Extensions.Logging.1.1.1\lib\netstandard1.1\Microsoft.Extensions.Logging.dll</HintPath>
+    </Reference>
+    <Reference Include="Microsoft.Extensions.Logging.Abstractions, Version=1.1.1.0, Culture=neutral, PublicKeyToken=adb9793829ddae60, processorArchitecture=MSIL">
+      <HintPath>..\packages\Microsoft.Extensions.Logging.Abstractions.1.1.1\lib\netstandard1.1\Microsoft.Extensions.Logging.Abstractions.dll</HintPath>
+    </Reference>
     <Reference Include="Newtonsoft.Json">
       <HintPath>dlls\Newtonsoft.Json.dll</HintPath>
     </Reference>
     <Reference Include="System" />
+    <Reference Include="System.ComponentModel.Composition" />
     <Reference Include="System.Core" />
+    <Reference Include="System.IO.Compression" />
+    <Reference Include="System.Numerics" />
+    <Reference Include="System.Runtime.InteropServices.RuntimeInformation, Version=4.0.1.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
+      <HintPath>..\packages\System.Runtime.InteropServices.RuntimeInformation.4.3.0\lib\net45\System.Runtime.InteropServices.RuntimeInformation.dll</HintPath>
+    </Reference>
     <Reference Include="System.Runtime.Serialization" />
     <Reference Include="System.Xml.Linq" />
     <Reference Include="System.Data.DataSetExtensions" />
     <Compile Include="AnaProtocol.Designer.cs">
       <DependentUpon>AnaProtocol.cs</DependentUpon>
     </Compile>
+    <Compile Include="config\ConfigBean.cs" />
     <Compile Include="db\AccessDbLoader.cs" />
+    <Compile Include="dotnetty\DotNettyClient.cs" />
+    <Compile Include="dotnetty\DotNettyClientHandler.cs" />
     <Compile Include="excel\ExcelLoader.cs" />
     <Compile Include="Form1.cs">
       <SubType>Form</SubType>
     <Compile Include="Program.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="property\PropertiesLoader.cs" />
+    <Compile Include="util\AryUtil.cs" />
     <Compile Include="util\CheckUtil.cs" />
     <Compile Include="util\HexUtil.cs" />
+    <Compile Include="util\TimeUtil.cs" />
     <Compile Include="util\Utils.cs" />
     <Compile Include="WebViewForm.cs">
       <SubType>Form</SubType>
     <EmbeddedResource Include="WebViewForm.resx">
       <DependentUpon>WebViewForm.cs</DependentUpon>
     </EmbeddedResource>
+    <None Include="packages.config" />
     <None Include="Properties\Settings.settings">
       <Generator>SettingsSingleFileGenerator</Generator>
       <LastGenOutput>Settings.Designer.cs</LastGenOutput>

GWSocketClient/config/ConfigBean.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace GWSocketClient.config
+{
+    public class ConfigBean
+    {
+        public static string Host;
+        public static int Port;
+        public static bool ConnAndLogin = true;
+    }
+}

GWSocketClient/dotnetty/DotNettyClient.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+using DotNetty.Codecs;
+using DotNetty.Handlers.Timeout;
+using DotNetty.Transport.Bootstrapping;
+using DotNetty.Transport.Channels;
+using DotNetty.Transport.Channels.Sockets;
+
+namespace GWSocketClient.dotnetty
+{
+    public class DotNettyClient
+    {
+        private IPAddress Host;
+        private int Port;
+
+        public void StartDotNetty()
+        {
+            RunClientAsync().Wait();
+        }
+
+        async Task RunClientAsync()
+        {
+            var group = new MultithreadEventLoopGroup();
+            try
+            {
+                var bootstrap = new Bootstrap();
+                bootstrap
+                    .Group(group)
+                    .Channel<TcpSocketChannel>()
+                    .Option(ChannelOption.TcpNodelay, true)
+                    .Handler(new ActionChannelInitializer<ISocketChannel>(channel =>
+                    {
+                        IChannelPipeline pipeline = channel.Pipeline;
+                        pipeline.AddLast("framing-dec", new LengthFieldBasedFrameDecoder(ushort.MaxValue, 10, 2, 1, 0));
+                        pipeline.AddLast("idle", new IdleStateHandler(10, 20, 15));
+                        pipeline.AddLast("echo", new DotNettyClientHandler());
+                    }));
+
+                IChannel clientChannel = await bootstrap.ConnectAsync(new IPEndPoint(Host, Port));
+
+                Console.ReadLine();
+
+                await clientChannel.CloseAsync();
+            }
+            finally
+            {
+                await group.ShutdownGracefullyAsync(TimeSpan.FromMilliseconds(100), TimeSpan.FromSeconds(1));
+            }
+        }
+    }
+}

GWSocketClient/dotnetty/DotNettyClientHandler.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using DotNetty.Buffers;
+using DotNetty.Handlers.Timeout;
+using DotNetty.Transport.Channels;
+using GWSocketClient.util;
+
+namespace GWSocketClient.dotnetty
+{
+    public class DotNettyClientHandler : ChannelHandlerAdapter
+    {
+        public override void ChannelActive(IChannelHandlerContext context)
+        {
+            Console.WriteLine("ChannelActive  " + DateTime.Now);
+        }
+
+        public override void ChannelRead(IChannelHandlerContext context, object message)
+        {
+            if (message is IByteBuffer byteBuffer)
+            {
+                Console.WriteLine("Received from server: " + byteBuffer.ToString(Encoding.UTF8));
+            }
+            context.WriteAsync(message);
+        }
+
+        public override void ChannelReadComplete(IChannelHandlerContext context) => context.Flush();
+
+
+        public override void UserEventTriggered(IChannelHandlerContext context, object evt)
+        {
+            base.UserEventTriggered(context, evt);
+            if (evt is IdleStateEvent state)
+            {
+                if (state == IdleStateEvent.ReaderIdleStateEvent)
+                {
+                    Console.WriteLine("Read超时");
+                }
+                else if (state == IdleStateEvent.WriterIdleStateEvent)
+                {
+                    Console.WriteLine("Write超时");
+                }
+                if (state == IdleStateEvent.AllIdleStateEvent)
+                {
+                    Console.WriteLine("All超时");
+                }
+            }
+        }
+
+        public override void ChannelInactive(IChannelHandlerContext context)
+        {
+            base.ChannelInactive(context);
+            Console.WriteLine("ChannelInactive");
+        }
+
+        public override void ExceptionCaught(IChannelHandlerContext context, Exception exception)
+        {
+            Console.WriteLine("Exception: " + exception);
+            context.CloseAsync();
+        }
+    }
+}

GWSocketClient/packages.config

+<?xml version="1.0" encoding="utf-8"?>
+<packages>
+  <package id="DotNetty.Buffers" version="0.4.6" targetFramework="net452" />
+  <package id="DotNetty.Codecs" version="0.4.6" targetFramework="net452" />
+  <package id="DotNetty.Common" version="0.4.6" targetFramework="net452" />
+  <package id="DotNetty.Handlers" version="0.4.6" targetFramework="net452" />
+  <package id="DotNetty.Transport" version="0.4.6" targetFramework="net452" />
+  <package id="Microsoft.Extensions.DependencyInjection.Abstractions" version="1.1.0" targetFramework="net452" />
+  <package id="Microsoft.Extensions.Logging" version="1.1.1" targetFramework="net452" />
+  <package id="Microsoft.Extensions.Logging.Abstractions" version="1.1.1" targetFramework="net452" />
+  <package id="Microsoft.NETCore.Platforms" version="1.1.0" targetFramework="net452" />
+  <package id="NETStandard.Library" version="1.6.1" targetFramework="net452" />
+  <package id="System.Collections" version="4.3.0" targetFramework="net452" />
+  <package id="System.Collections.Concurrent" version="4.3.0" targetFramework="net452" />
+  <package id="System.ComponentModel" version="4.3.0" targetFramework="net452" />
+  <package id="System.Diagnostics.Debug" version="4.3.0" targetFramework="net452" />
+  <package id="System.Diagnostics.Tools" version="4.3.0" targetFramework="net452" />
+  <package id="System.Diagnostics.Tracing" version="4.3.0" targetFramework="net452" />
+  <package id="System.Globalization" version="4.3.0" targetFramework="net452" />
+  <package id="System.IO" version="4.3.0" targetFramework="net452" />
+  <package id="System.IO.Compression" version="4.3.0" targetFramework="net452" />
+  <package id="System.Linq" version="4.3.0" targetFramework="net452" />
+  <package id="System.Linq.Expressions" version="4.3.0" targetFramework="net452" />
+  <package id="System.Net.Http" version="4.3.0" targetFramework="net452" />
+  <package id="System.Net.Primitives" version="4.3.0" targetFramework="net452" />
+  <package id="System.ObjectModel" version="4.3.0" targetFramework="net452" />
+  <package id="System.Reflection" version="4.3.0" targetFramework="net452" />
+  <package id="System.Reflection.Extensions" version="4.3.0" targetFramework="net452" />
+  <package id="System.Reflection.Primitives" version="4.3.0" targetFramework="net452" />
+  <package id="System.Resources.ResourceManager" version="4.3.0" targetFramework="net452" />
+  <package id="System.Runtime" version="4.3.0" targetFramework="net452" />
+  <package id="System.Runtime.Extensions" version="4.3.0" targetFramework="net452" />
+  <package id="System.Runtime.InteropServices" version="4.3.0" targetFramework="net452" />
+  <package id="System.Runtime.InteropServices.RuntimeInformation" version="4.3.0" targetFramework="net452" />
+  <package id="System.Runtime.Numerics" version="4.3.0" targetFramework="net452" />
+  <package id="System.Text.Encoding" version="4.3.0" targetFramework="net452" />
+  <package id="System.Text.Encoding.Extensions" version="4.3.0" targetFramework="net452" />
+  <package id="System.Text.RegularExpressions" version="4.3.0" targetFramework="net452" />
+  <package id="System.Threading" version="4.3.0" targetFramework="net452" />
+  <package id="System.Threading.Tasks" version="4.3.0" targetFramework="net452" />
+  <package id="System.Threading.Timer" version="4.3.0" targetFramework="net452" />
+  <package id="System.Xml.ReaderWriter" version="4.3.0" targetFramework="net452" />
+  <package id="System.Xml.XDocument" version="4.3.0" targetFramework="net452" />
+</packages>

GWSocketClient/util/AryUtil.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace GWSocketClient.util
+{
+    public class AryUtil
+    {
+        public static string Bytes2Hex(byte[] bs)
+        {
+            return BitConverter.ToString(bs, 0, bs.Length).Replace("-", "").ToUpper();
+        }
+
+
+        public static byte[] Hex2Bytes(string hex)
+        {
+            hex = hex.Replace(" ", "");
+            if (hex.Length % 2 != 0)
+                hex += " ";
+            byte[] returnBytes = new byte[hex.Length / 2];
+            for (int i = 0; i < returnBytes.Length; i++)
+                returnBytes[i] = Convert.ToByte(hex.Substring(i * 2, 2).Trim(), 16);
+            return returnBytes;
+        }
+    }
+}

GWSocketClient/util/TimeUtil.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace GWSocketClient.util
+{
+    public class TimeUtil
+    {
+        public static string getTime()
+        {
+            return "";
+        }
+    }
+}

GWSocketClient/util/Utils.cs

 {
     public class Utils
     {
+
+
+        public static string Bytes2Hex(byte[] bs)
+        {
+            return BitConverter.ToString(bs, 0, bs.Length).Replace("-", "").ToUpper();
+        }
+
+
+        public static byte[] Hex2Bytes(string hex)
+        {
+            hex = hex.Replace(" ", "");
+            if (hex.Length % 2 != 0)
+                hex += " ";
+            byte[] returnBytes = new byte[hex.Length / 2];
+            for (int i = 0; i < returnBytes.Length; i++)
+                returnBytes[i] = Convert.ToByte(hex.Substring(i * 2, 2).Trim(), 16);
+            return returnBytes;
+        } 
+
         public static int hexToTen(string hex)
         {
             return int.Parse(hex, NumberStyles.HexNumber);

README.md

 
 
 
-## 要解决问题
+## 使用DotNetty代替Socket
+
+`基于Visual Studio 2017`开发,没有`Nuget`程序,请下载安装.`VS2017自带`
+
+`工具->Nuget包管理器->程序包管理器控制台`输入以下指令
+
+```
+Install-Package DotNetty.Common -Version 0.4.6
+Install-Package DotNetty.Transport -Version 0.4.6
+Install-Package DotNetty.Codecs -Version 0.4.6
+Install-Package DotNetty.Handlers -Version 0.4.6
+```
+
+
+
+
 
-1. 服务器没开
-2. 超时
-3. 连接成功了,但服务器主动断开