修改细节

src/YSAI.DAQ/YSAI.Netty/client/NettyClientOperate.cs

@@ -342,9 +342,8 @@ namespace YSAI.Netty.client
                 {
                     msg = "{" + string.Format("\"T\":\"{0}\",\"C\":\"{1}\"", Topic, Content) + "}\r\n";
                 }
-                Channel.WriteAndFlushAsync(msg);
-                //延时
-                //TimeTool.DelayUs(0.2);
+                //等待执行完成
+                Channel.WriteAndFlushAsync(msg).Wait();
                 return Break("Produce", true);
             }
             catch (Exception ex)

src/YSAI.DAQ/YSAI.Netty/service/NettyServiceOperate.cs

@@ -154,7 +154,7 @@ namespace YSAI.Netty.service
                 string broadcast = string.Format("{0}\n", msg);
                 string response = string.Format("{0}\n", msg);
                 group.WriteAndFlushAsync(broadcast, new EveryOneBut(contex.Channel.Id));
-                //contex.WriteAndFlushAsync(response);
+                contex.WriteAndFlushAsync(response);
                 if (string.Equals("bye", msg, StringComparison.OrdinalIgnoreCase))
                 {
                     contex.CloseAsync();

src/YSAI.DAQ/YSAI.Test.All/Program.cs

@@ -4,13 +4,13 @@ using YSAI.Netty.client;
 using YSAI.Netty.service;
 using YSAI.Unility;
 
-//NettyServiceOperate nettyServiceOperate = NettyServiceOperate.Instance(new NettyServiceData.Basics 
-//{
-//    Port = 8007,
-//    SN = "1"
-//});
+NettyServiceOperate nettyServiceOperate = NettyServiceOperate.Instance(new NettyServiceData.Basics
+{
+    Port = 8007,
+    SN = "1"
+});
 
-//Console.WriteLine(nettyServiceOperate.On().ToJson());
+Console.WriteLine(nettyServiceOperate.On().ToJson());
 
 
 //转发协议