345 lines
12 KiB
C#
345 lines
12 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Net.Sockets;
|
||
using System.Net;
|
||
using System.Text;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using static AutomaticApp.Common.Sockets;
|
||
using AutomaticApp.ViewModels;
|
||
|
||
namespace AutomaticApp.Common
|
||
{
|
||
public class Clinet : SocketObject
|
||
{
|
||
public PushSockets pushSockets;
|
||
|
||
bool IsClose = false;
|
||
/// <summary>
|
||
/// 当前管理对象
|
||
/// </summary>
|
||
Sockets sk;
|
||
/// <summary>
|
||
/// 客户端
|
||
/// </summary>
|
||
TcpClient client;
|
||
/// <summary>
|
||
/// 当前连接服务端地址
|
||
/// </summary>
|
||
IPAddress Ipaddress;
|
||
/// <summary>
|
||
/// 当前连接服务端端口号
|
||
/// </summary>
|
||
int Port;
|
||
/// <summary>
|
||
/// 服务端IP+端口
|
||
/// </summary>
|
||
IPEndPoint ip;
|
||
/// <summary>
|
||
/// 发送与接收使用的流
|
||
/// </summary>
|
||
NetworkStream nStream;
|
||
|
||
/// <summary>
|
||
/// 初始化Socket
|
||
/// </summary>
|
||
/// <param name="ipaddress"></param>
|
||
/// <param name="port"></param>
|
||
public override void InitSocket(IPAddress ipaddress, int port)
|
||
{
|
||
Ipaddress = ipaddress;
|
||
Port = port;
|
||
ip = new IPEndPoint(Ipaddress, Port);
|
||
client = new TcpClient();
|
||
}
|
||
/// <summary>
|
||
/// 初始化Socket
|
||
/// </summary>
|
||
/// <param name="ipaddress">ipd地址</param>
|
||
/// <param name="port">端口</param>
|
||
public override void InitSocket(string ipaddress, int port)
|
||
{
|
||
Ipaddress = IPAddress.Parse(ipaddress);
|
||
Port = port;
|
||
ip = new IPEndPoint(Ipaddress, Port);
|
||
client = new TcpClient();
|
||
}
|
||
/// <summary>
|
||
/// 重写Start方法,其实就是连接服务端
|
||
/// </summary>
|
||
public override void Start()
|
||
{
|
||
Connect();
|
||
}
|
||
/// <summary>
|
||
/// 连接
|
||
/// </summary>
|
||
public bool Connect()
|
||
{
|
||
if (client != null && IsOnline() && client.Connected)
|
||
return true;
|
||
|
||
try
|
||
{
|
||
client.Connect(ip);
|
||
tools.Logging("连接客户端成功,IP:" + Ipaddress + "端口号:" + Port);
|
||
//将是否接收到心跳包判断位 置于false
|
||
IsReturnMsg = System.DateTime.Now;
|
||
//检测当前连接状态
|
||
CheckConnect();
|
||
nStream = new NetworkStream(client.Client, true);
|
||
sk = new Sockets(ip, client, nStream);
|
||
sk.nStream.BeginRead(sk.RecBuffer, 0, sk.RecBuffer.Length, new AsyncCallback(EndReader), sk);
|
||
}
|
||
catch (Exception)
|
||
{
|
||
tools.Logging("连接客户端失败,IP:" + Ipaddress + "端口号:" + Port);
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
public DateTime IsReturnMsg = System.DateTime.Now;
|
||
|
||
/// <summary>
|
||
/// 检查链接状态
|
||
/// </summary>
|
||
//private async void CheckConnect()
|
||
//{
|
||
// await Task.Run(() =>
|
||
// {
|
||
// //连接成功等待5秒后 发送心跳包
|
||
// Thread.Sleep(10000);
|
||
// tools.Logging("开始发送心跳包");
|
||
// while ((System.DateTime.Now - IsReturnMsg).TotalSeconds < 150)
|
||
// {
|
||
// //如果没有收到心跳包 就发送一次Get
|
||
// if (!IsCheckConnect)
|
||
// {
|
||
// //发送一次GET
|
||
// SendData(new byte[] { (byte)'G', (byte)'E', (byte)'T' });
|
||
// tools.Logging("发送一次心跳包GET,上一次收到心跳包的时间差为" + (System.DateTime.Now - IsReturnMsg).TotalSeconds + "秒");
|
||
// //等待30秒钟
|
||
// Thread.Sleep(30000);
|
||
// }
|
||
// else //如果处于异常断开情况 则不在发送心跳包
|
||
// {
|
||
// tools.Logging("目前系统由于卫通/下位机原因链接断开，停止发送心跳包GET");
|
||
// break;
|
||
// }
|
||
// }
|
||
// tools.Logging("停止发送心跳包GET");
|
||
// //如果此时还是没有 且不是检查连接状态
|
||
// if (!IsCheckConnect)
|
||
// {
|
||
// //先断开链接
|
||
// Stop();
|
||
// tools.Logging("心跳包超时，主动断开链接，停止发送心跳包GET");
|
||
// //等待30秒钟
|
||
// Thread.Sleep(10000);
|
||
// //初始化
|
||
// InitSocket(Ipaddress.ToString(), Port);
|
||
// //重新链接
|
||
// while (!Connect())
|
||
// {
|
||
// tools.Logging("心跳包超时，重新链接失败！");
|
||
// Thread.Sleep(30000);
|
||
// }
|
||
// tools.Logging("心跳包超时，重新链接成功！");
|
||
// }
|
||
// });
|
||
//}
|
||
bool IsCheckConnect = false;
|
||
private async void CheckConnect()
|
||
{
|
||
if (IsCheckConnect)
|
||
return;
|
||
await Task.Run(() =>
|
||
{
|
||
IsCheckConnect = true;
|
||
//连接成功等待10秒后 发送心跳包
|
||
Thread.Sleep(10000);
|
||
tools.Logging("开始发送心跳包");
|
||
while ((System.DateTime.Now - IsReturnMsg).TotalSeconds < 150)
|
||
{
|
||
//发送一次Get
|
||
SendData(new byte[] { (byte)'G', (byte)'E', (byte)'T' });
|
||
tools.Logging("发送一次心跳包GET,上一次收到心跳包的时间差为" + (System.DateTime.Now - IsReturnMsg).TotalSeconds + "秒");
|
||
//等待30秒钟
|
||
Thread.Sleep(30000);
|
||
}
|
||
tools.Logging("心跳包超时，主动断开链接，停止发送心跳包GET");
|
||
//先断开链接
|
||
Stop();
|
||
//等待10秒钟
|
||
Thread.Sleep(10000);
|
||
//初始化
|
||
InitSocket(Ipaddress.ToString(), Port);
|
||
tools.Logging("心跳包超时，开始初始化并重新链接！");
|
||
IsCheckConnect = false; //允许重新链接并启用异步心跳包
|
||
Connect();
|
||
Thread.Sleep(10000);
|
||
//重新链接
|
||
while (!IsOnline())
|
||
{
|
||
tools.Logging("心跳包超时，重新链接失败！");
|
||
Connect();
|
||
Thread.Sleep(30000);
|
||
}
|
||
tools.Logging("心跳包超时，重新链接成功！");
|
||
});
|
||
}
|
||
/// <summary>
|
||
/// 读取
|
||
/// </summary>
|
||
private void EndReader(IAsyncResult ir)
|
||
{
|
||
Sockets s = ir.AsyncState as Sockets;
|
||
try
|
||
{
|
||
if (s != null)
|
||
{
|
||
if (IsClose && client == null)
|
||
{
|
||
sk.nStream.Close();
|
||
sk.nStream.Dispose();
|
||
return;
|
||
}
|
||
s.Offset = s.nStream.EndRead(ir);
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(s);//推送至UI
|
||
|
||
if (IsOnline())
|
||
{
|
||
//Thread.Sleep(100);
|
||
sk.nStream.BeginRead(sk.RecBuffer, 0, sk.RecBuffer.Length, new AsyncCallback(EndReader), sk);
|
||
}
|
||
else
|
||
{
|
||
if (Ipaddress.ToString().Equals(tools.GetAppSetting("PLC_IP1")))
|
||
{
|
||
MainWindow.mainViewModel.DoSocket1Connect("断开");
|
||
tools.Logging("站点1目前系统由于卫通/下位机原因链接断开，IP:" + Ipaddress + "端口号:" + Port);
|
||
DoConnect(1);
|
||
}
|
||
else if (Ipaddress.ToString().Equals(tools.GetAppSetting("PLC_IP2")))
|
||
{
|
||
MainWindow.mainViewModel.DoSocket2Connect("断开");
|
||
tools.Logging("站点2目前系统由于卫通/下位机原因链接断开，IP:" + Ipaddress + "端口号:" + Port);
|
||
DoConnect(2);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception skex)
|
||
{
|
||
Sockets sks = s;
|
||
sks.ex = skex;
|
||
sks.ClientDispose = true;
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
}
|
||
}
|
||
|
||
private bool IsDoConnect = false;
|
||
/// <summary>
|
||
/// 检查链接状态
|
||
/// </summary>
|
||
private async void DoConnect(int id)
|
||
{
|
||
await Task.Run(() =>
|
||
{
|
||
tools.Logging("站点" + id + "目前系统由于卫通/下位机原因链接断开，IP:" + Ipaddress + "端口号:" + Port + "开始重新连接");
|
||
IsDoConnect = true;
|
||
while (!IsOnline())
|
||
{
|
||
Thread.Sleep(15000);
|
||
if (id == 1)
|
||
MainWindow.mainViewModel.DoSocket1Connect("连接");
|
||
if (id == 2)
|
||
MainWindow.mainViewModel.DoSocket2Connect("连接");
|
||
Thread.Sleep(15000);
|
||
}
|
||
//如果连接成功则切出检查连接模式
|
||
tools.Logging("站点" + id + "目前系统由于卫通/下位机原因链接断开，IP:" + Ipaddress + "端口号:" + Port + "重新链接成功，退出重新链接模式");
|
||
IsDoConnect = false;
|
||
});
|
||
}
|
||
/// <summary>
|
||
/// 停止
|
||
/// </summary>
|
||
public override void Stop()
|
||
{
|
||
Sockets sks = new Sockets();
|
||
try
|
||
{
|
||
if (client != null)
|
||
{
|
||
client.Client.Shutdown(SocketShutdown.Both);
|
||
Thread.Sleep(10);
|
||
client.Close();
|
||
IsClose = true;
|
||
client = null;
|
||
}
|
||
else
|
||
{
|
||
sks.ex = new Exception("客户端没有初始化.!");
|
||
}
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
sks.ex = ex;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 发送消息
|
||
/// </summary>
|
||
public void SendData(byte[] SendData)
|
||
{
|
||
try
|
||
{
|
||
if (client == null || !client.Connected)
|
||
{
|
||
Sockets sks = new Sockets();
|
||
sks.ex = new Exception("客户端无连接..");
|
||
sks.ClientDispose = true;
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
}
|
||
if (client != null && client.Connected) //如果连接则发送
|
||
{
|
||
if (nStream == null)
|
||
{
|
||
nStream = client.GetStream();
|
||
}
|
||
nStream.Write(SendData, 0, SendData.Length);
|
||
}
|
||
}
|
||
catch (Exception skex)
|
||
{
|
||
Sockets sks = new Sockets();
|
||
sks.ex = skex;
|
||
sks.ClientDispose = true;
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
}
|
||
}
|
||
|
||
public bool Is_Connected()
|
||
{
|
||
return client.Connected;
|
||
}
|
||
|
||
public bool IsOnline()
|
||
{
|
||
if (client == null)
|
||
return false;
|
||
return !((client.Client.Poll(1000, SelectMode.SelectRead) && (client.Client.Available == 0)) || !client.Client.Connected);
|
||
}
|
||
}
|
||
}
|