You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
105 lines
3.7 KiB
105 lines
3.7 KiB
using SunlightCentralizedControlManagement_SCCM_.UserClass;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Net.Http;
|
|
using System.Net.Sockets;
|
|
using System.Reflection.Emit;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using System.Diagnostics;
|
|
using TouchSocket.Core;
|
|
using TouchSocket.Sockets;
|
|
using SunlightCentralizedControlManagement_SCCM_.ViewModel;
|
|
using System.Runtime.InteropServices;
|
|
using ScottPlot.Colormaps;
|
|
using static System.Windows.Forms.AxHost;
|
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement.TaskbarClock;
|
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement;
|
|
using Newtonsoft.Json;
|
|
using static SunlightCentralizedControlManagement_SCCM_.UserClass.SqliteHelper;
|
|
using SunlightCentralizedControlManagement_SCCM_.View;
|
|
using TcpClient = TouchSocket.Sockets.TcpClient;
|
|
using Newtonsoft.Json.Linq;
|
|
using System.Xml.Linq;
|
|
|
|
namespace SunlightCentralizedControlManagement_SCCM_.UserClass
|
|
{/// <summary>
|
|
/// 异步TCP客户端
|
|
/// </summary>
|
|
public class AsyncTcpClient
|
|
{
|
|
public static async Task TcpClient(TcpClient tcpClient, string ip,string port)
|
|
{
|
|
//TcpClient tcpClient = new TcpClient();
|
|
tcpClient.Connecting = (client, e) => { return EasyTask.CompletedTask; };//即将连接到服务器，此时已经创建socket，但是还未建立tcp
|
|
tcpClient.Connected = (client, e) =>
|
|
{
|
|
DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "' AND port='" + client.Port + "'").First();
|
|
drEmployee.BeginEdit();
|
|
drEmployee["State"] = "801";
|
|
drEmployee.EndEdit();
|
|
drEmployee.AcceptChanges();
|
|
drEmployee.ClearErrors();
|
|
|
|
return EasyTask.CompletedTask;
|
|
};//成功连接到服务器
|
|
tcpClient.Closing = (client, e) => { return EasyTask.CompletedTask; };//即将从服务器断开连接。此处仅主动断开才有效。
|
|
tcpClient.Closed = (client, e) => { return EasyTask.CompletedTask; };//从服务器断开连接，当连接不成功时不会触发。
|
|
tcpClient.Received = (client, e) =>
|
|
{
|
|
//从服务器收到信息。但是一般byteBlock和requestInfo会根据适配器呈现不同的值。
|
|
var mes = e.ByteBlock.Span.ToString(Encoding.UTF8);
|
|
|
|
|
|
|
|
|
|
// tcpClient.Logger.Info($"客户端接收到信息：{mes}");
|
|
return EasyTask.CompletedTask;
|
|
};
|
|
|
|
//载入配置
|
|
await tcpClient.SetupAsync(new TouchSocketConfig()
|
|
.SetRemoteIPHost(ip+":"+port)
|
|
.ConfigurePlugins(a =>
|
|
{
|
|
a.UseCheckClear()
|
|
.SetCheckClearType(CheckClearType.All)
|
|
.SetTick(TimeSpan.FromSeconds(30))
|
|
.SetOnClose((c, t) =>
|
|
{
|
|
c.TryShutdown();
|
|
});
|
|
a.UseTcpReconnection();//触发型重连
|
|
})
|
|
.ConfigureContainer(a =>
|
|
{
|
|
// a.AddConsoleLogger();//添加一个日志注入
|
|
}));
|
|
|
|
// Result result = await
|
|
_ = tcpClient.TryConnectAsync();
|
|
// return result.IsSuccess;
|
|
/* try
|
|
{
|
|
await tcpClient.ConnectAsync();//调用连接，当连接不成功时，会抛出异常。
|
|
return true;
|
|
}
|
|
catch
|
|
{
|
|
return false;
|
|
}*/
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|