using System;
|
using System.Net;
|
using System.Net.Sockets;
|
using System.Text;
|
using System.Threading;
|
|
namespace HMI.Simple.Util
|
{
|
public class DataSender
|
{
|
private string _ip;
|
private int _port;
|
private bool _isConnected = false; // 是否连接
|
private Socket _clientSocket; // 套接字
|
private Thread _receiveThread = null; // 接收线程
|
private volatile bool needRecieve = true;
|
|
public event EventHandler<string> ExecuteMessageChanged;
|
|
public DataSender(string ip, int port)
|
{
|
this._ip = ip;
|
this._port = port;
|
}
|
|
public void Connect()
|
{
|
try
|
{
|
_clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
IPAddress ipaddress = IPAddress.Parse(this._ip);
|
IPEndPoint endpoint = new IPEndPoint(ipaddress, _port);
|
_clientSocket.Connect(endpoint);
|
_isConnected = true;
|
_receiveThread = new Thread(Received);
|
_receiveThread.IsBackground = true;
|
_receiveThread.Start();
|
}
|
catch (Exception ex)
|
{
|
needRecieve = false;
|
_receiveThread?.Abort();
|
_receiveThread = null;
|
_clientSocket.Close();
|
_isConnected = false;
|
throw ex;
|
}
|
}
|
|
public void Disconnect()
|
{
|
needRecieve = false;
|
_clientSocket.Close();
|
_receiveThread?.Abort();
|
_receiveThread = null;
|
_isConnected = false;
|
}
|
|
private void Send(string data)
|
{
|
byte[] arrClientSendMsg = Encoding.UTF8.GetBytes(data);
|
_clientSocket.Send(arrClientSendMsg);
|
}
|
|
private void Received()
|
{
|
//while (needRecieve)
|
//{
|
// byte[] arrRecMsg = new byte[1024 * 1024];
|
// int length = _clientSocket.Receive(arrRecMsg);
|
// string strRecMsg = Encoding.UTF8.GetString(arrRecMsg, 0, length);
|
// ExecuteMessageChanged?.Invoke(this, strRecMsg);
|
// Thread.Sleep(100);
|
//}
|
}
|
|
|
public bool SendStep(int ovenIndex, int cellIndex,
|
string name, string send, string value, string unit, string upper, string lower, string result, string time,
|
out string errorMsg)
|
{
|
|
errorMsg = null;
|
try
|
{
|
if (!_isConnected)
|
{
|
errorMsg = "Not Connected";
|
return false;
|
}
|
|
string msg = $"{ovenIndex};{cellIndex};{name},{send},{value},{unit},{upper},{lower},{result},{time}\n";
|
Send(msg);
|
return true;
|
}
|
catch (Exception ex)
|
{
|
errorMsg = ex.Message;
|
return false;
|
}
|
}
|
}
|
}
|
