框架

DotNettyFrom/Form1.cs

 
         private void BtnSendData_Click(object sender, EventArgs e)
         {
-            nc.SendData("");
+            nc?.SendData("");
         }
     }
 }

DotNettyFrom/common/UIInfoModel..cs

     [Serializable]
     public class UIInfoModel
     {
-        public int action = -1;
+        public int action = int.MinValue;
         public DateTime time = DateTime.Now;
         public string info = "";
 

DotNettyFrom/netty/NettyClient.cs

         {
             IPAddress hostIp = IPAddress.Parse(host);
             RunClientAsync(hostIp, port);
+            DataModel.ReceCollection.Add(new UIInfoModel("开启连接"));
         }
 
         private async void RunClientAsync(IPAddress HostIP, int Port)
             catch (Exception e)
             {
                 //连接出错,服务器没开启....
-                Console.WriteLine(e);
+                //Console.WriteLine(e);
+                DataModel.ReceCollection.Add(new UIInfoModel("远程服务器连接失败").setAction(-1));
                 await _group.ShutdownGracefullyAsync(TimeSpan.FromMilliseconds(100), TimeSpan.FromSeconds(1));
             }
-            
         }
 
 
                 byte[] messageBytes = Encoding.UTF8.GetBytes(DateTime.Now.ToLongDateString());
                 msg.WriteBytes(messageBytes);
                 Context.Channel.WriteAndFlushAsync(msg);
+                DataModel.ReceCollection.Add(new UIInfoModel("发送", hex).setIsSend(true));
             }
             else
             {
-                DataModel.ReceCollection.Add(new UIInfoModel("连接已断开", ""));
+                DataModel.ReceCollection.Add(new UIInfoModel("连接已经断开"));
             }
         }
 
             _group = null;
             Context = null;
             _clientHandler = null;
+            DataModel.ReceCollection.Add(new UIInfoModel("停止连接"));
         }
 
 
             public override void ChannelActive(IChannelHandlerContext context)
             {
                 Context = context;
-
-
                 IByteBuffer msg = Unpooled.Buffer(128);
                 byte[] messageBytes = Encoding.UTF8.GetBytes(DateTime.Now.ToLongDateString());
                 msg.WriteBytes(messageBytes);
                 context.WriteAndFlushAsync(msg);
-
-                DataModel.ReceCollection.Add(new UIInfoModel("", DateTime.Now.ToLongDateString() + "channeiActive"));
+                DataModel.ReceCollection.Add(new UIInfoModel("连接成功").setAction(1));
             }
 
 
             {
                 base.ExceptionCaught(context, exception);
                 Console.WriteLine(exception.Message);
-                DataModel.ReceCollection.Add(new UIInfoModel("", "ExceptionCaught:" + exception.Message));
+                DataModel.ReceCollection.Add(new UIInfoModel("", "ExceptionCaught:" + exception.Message).setAction(3));
             }
 
             public override void ChannelInactive(IChannelHandlerContext context)
             {
                 base.ChannelInactive(context);
-                DataModel.ReceCollection.Add(new UIInfoModel("", "ChannelInactive"));
+                DataModel.ReceCollection.Add(new UIInfoModel("", "ChannelInactive").setAction(2));
             }
         }
     }