|
|
@@ -1,86 +1,10 @@
|
|
|
-using YSAI.Log;
|
|
|
-using YSAI.Unility;
|
|
|
+using System.Text;
|
|
|
+using YSAI.Core.communication.net.tcp.client;
|
|
|
+using YSAI.Core.communication.net.tcp.service;
|
|
|
+using YSAI.Core.data;
|
|
|
+
|
|
|
|
|
|
-for (int i = 0; i < 100; i++)
|
|
|
-{
|
|
|
- int a, b = 0;
|
|
|
- try
|
|
|
- {
|
|
|
- a = 10;
|
|
|
- //LogHelper.Verbose((new Random().NextDouble() * i).ToString(), "我的家AdcOne.LOG");
|
|
|
- //LogHelper.Info((new Random().NextDouble() * i).ToString(), "OpcClientOperate.LOG");
|
|
|
- //LogHelper.Debug((new Random().NextDouble() * i).ToString(), "OpcUaClientOperate.LOG");
|
|
|
- //LogHelper.Error((new Random().NextDouble() * i).ToString(), "Http.Operate.LOG");
|
|
|
- //LogHelper.Fatal((new Random().NextDouble() * i).ToString(), "ModbusClientOperate.LOG");
|
|
|
- //LogHelper.Warning((new Random().NextDouble() * i).ToString(), "ABCDabcd.LOG");
|
|
|
- double c = a / b;
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- aaaa aa = new aaaa();
|
|
|
- string aaa = aa.ToJson().JsonFormatting();
|
|
|
- LogHelper.Verbose(aaa, "我的家AdcOne.LOG", ex);
|
|
|
- LogHelper.Info((new Random().NextDouble() * i).ToString(), "OpcClientOperate.LOG", ex);
|
|
|
- LogHelper.Debug((new Random().NextDouble() * i).ToString(), "OpcUaClientOperate.LOG", ex);
|
|
|
- LogHelper.Error((new Random().NextDouble() * i).ToString(), "Http.Operate.LOG", ex);
|
|
|
- LogHelper.Fatal((new Random().NextDouble() * i).ToString(), "ModbusClientOperate.LOG", ex);
|
|
|
- LogHelper.Warning((new Random().NextDouble() * i).ToString(), "ABCDabcd.LOG", ex);
|
|
|
- }
|
|
|
-}
|
|
|
|
|
|
-class aaaa
|
|
|
-{
|
|
|
- /// <summary>
|
|
|
- /// 服务端IP
|
|
|
- /// </summary>
|
|
|
- public string? Ip { get; set; } = "127.0.0.1";
|
|
|
- /// <summary>
|
|
|
- /// 服务器端口
|
|
|
- /// </summary>
|
|
|
- public int Port { get; set; } = 6688;
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 是否需要断开重新连接
|
|
|
- /// </summary>
|
|
|
- public bool InterruptReconnection { get; set; } = true;
|
|
|
- /// <summary>
|
|
|
- /// 重连间隔(毫秒)
|
|
|
- /// </summary>
|
|
|
- public int ReconnectionInterval { get; set; } = 2000;
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 超时时间
|
|
|
- /// </summary>
|
|
|
- public int Timeout { get; set; } = 1000;
|
|
|
-
|
|
|
- public List<bbb> abc { get; set; } = new List<bbb> { new bbb(), new bbb(), new bbb(), new bbb(), new bbb(), new bbb() };
|
|
|
-
|
|
|
- public class bbb
|
|
|
- {
|
|
|
- /// <summary>
|
|
|
- /// 服务端IP
|
|
|
- /// </summary>
|
|
|
- public string? Ip { get; set; } = "127.0.0.1";
|
|
|
- /// <summary>
|
|
|
- /// 服务器端口
|
|
|
- /// </summary>
|
|
|
- public int Port { get; set; } = 6688;
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 是否需要断开重新连接
|
|
|
- /// </summary>
|
|
|
- public bool InterruptReconnection { get; set; } = true;
|
|
|
- /// <summary>
|
|
|
- /// 重连间隔(毫秒)
|
|
|
- /// </summary>
|
|
|
- public int ReconnectionInterval { get; set; } = 2000;
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 超时时间
|
|
|
- /// </summary>
|
|
|
- public int Timeout { get; set; } = 1000;
|
|
|
- }
|
|
|
-}
|
|
|
//Console.WriteLine(Encoding.Default.GetString((byte[])ByteTool.HexStringToByteArray("58 44 34 20 53 20 20 20 20 20 20 35 2E 30 32 33 20 67 20 33 20 31 20 30 20 30 0D 0A")));;
|
|
|
|
|
|
//SerialOperate serialOperate = SerialOperate.Instance(new SerialData.Basics
|
|
|
@@ -171,53 +95,53 @@ class aaaa
|
|
|
//}
|
|
|
|
|
|
|
|
|
-//TcpServiceOperate tcpServiceOperate = TcpServiceOperate.Instance(new TcpServiceData.Basics
|
|
|
-//{
|
|
|
-// Ip = "127.0.0.1",
|
|
|
-// Port = 8888,
|
|
|
-// MaxNumber = 1000
|
|
|
-//});
|
|
|
+TcpServiceOperate tcpServiceOperate = TcpServiceOperate.Instance(new TcpServiceData.Basics
|
|
|
+{
|
|
|
+ Ip = "127.0.0.1",
|
|
|
+ Port = 12345,
|
|
|
+ MaxNumber = 1000
|
|
|
+});
|
|
|
|
|
|
-//tcpServiceOperate.OnEvent += WsServiceOperate_OnEvent;
|
|
|
-//OperateResult operateResult = tcpServiceOperate.On();
|
|
|
-//Console.WriteLine(operateResult.Message);
|
|
|
+tcpServiceOperate.OnEvent += WsServiceOperate_OnEvent;
|
|
|
+OperateResult operateResult = tcpServiceOperate.On();
|
|
|
+Console.WriteLine(operateResult.Message);
|
|
|
|
|
|
|
|
|
-//TcpClientOperate wsClientOperate = TcpClientOperate.Instance(new TcpClientData.Basics
|
|
|
-//{
|
|
|
-// Ip = "127.0.0.1",
|
|
|
-// Port = 8888,
|
|
|
-// InterruptReconnection = true
|
|
|
-//});
|
|
|
-//wsClientOperate.OnEvent += WsServiceOperate_OnEvent;
|
|
|
-//operateResult = wsClientOperate.On();
|
|
|
-//Console.WriteLine(operateResult.Message);
|
|
|
+TcpClientOperate wsClientOperate = TcpClientOperate.Instance(new TcpClientData.Basics
|
|
|
+{
|
|
|
+ Ip = "127.0.0.1",
|
|
|
+ Port = 1234,
|
|
|
+ InterruptReconnection = true
|
|
|
+});
|
|
|
+wsClientOperate.OnEvent += WsServiceOperate_OnEvent;
|
|
|
+operateResult = wsClientOperate.On();
|
|
|
+Console.WriteLine(operateResult.Message);
|
|
|
|
|
|
|
|
|
-//while (true)
|
|
|
-//{
|
|
|
-// for (int i = 0; i < 1; i++)
|
|
|
-// {
|
|
|
-// string str = Console.ReadLine();
|
|
|
+while (true)
|
|
|
+{
|
|
|
+ for (int i = 0; i < 1; i++)
|
|
|
+ {
|
|
|
+ string str = Console.ReadLine();
|
|
|
|
|
|
-// operateResult = tcpServiceOperate.Send(Encoding.Default.GetBytes(str));
|
|
|
-// Console.WriteLine(operateResult.Message);
|
|
|
+ operateResult = tcpServiceOperate.Send(Encoding.Default.GetBytes(str));
|
|
|
+ Console.WriteLine(operateResult.Message);
|
|
|
|
|
|
-// operateResult = wsClientOperate.Send(Encoding.Default.GetBytes(str));
|
|
|
-// Console.WriteLine(operateResult.Message);
|
|
|
-// }
|
|
|
+ operateResult = wsClientOperate.Send(Encoding.Default.GetBytes(str));
|
|
|
+ Console.WriteLine(operateResult.Message);
|
|
|
+ }
|
|
|
|
|
|
-// Console.ReadLine();
|
|
|
-// operateResult = tcpServiceOperate.Off();
|
|
|
-// Console.WriteLine(operateResult.Message);
|
|
|
-// operateResult = wsClientOperate.Off();
|
|
|
-// Console.WriteLine(operateResult.Message);
|
|
|
-//}
|
|
|
+ Console.ReadLine();
|
|
|
+ operateResult = tcpServiceOperate.Off();
|
|
|
+ Console.WriteLine(operateResult.Message);
|
|
|
+ operateResult = wsClientOperate.Off();
|
|
|
+ Console.WriteLine(operateResult.Message);
|
|
|
+}
|
|
|
|
|
|
-//void WsServiceOperate_OnEvent(object? sender, EventResult e)
|
|
|
-//{
|
|
|
-// Console.WriteLine("事件数据:" + e.Message);
|
|
|
-//}
|
|
|
+void WsServiceOperate_OnEvent(object? sender, EventResult e)
|
|
|
+{
|
|
|
+ Console.WriteLine("事件数据:" + e.Message);
|
|
|
+}
|
|
|
|
|
|
//WsServiceOperate wsServiceOperate = WsServiceOperate.Instance(new WsServiceData.Basics
|
|
|
//{
|