using System;
|
using System.Net;
|
using System.Net.Sockets;
|
using System.Text;
|
|
namespace CellStepSender
|
{
|
public class TcpClientTool3
|
{
|
private string _ip;
|
private int _port;
|
private bool _isConnected = false; // 是否连接
|
private Socket _clientSocket; // 套接字
|
|
public event EventHandler<string> ExecuteMessageChanged;
|
|
public TcpClientTool3(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;
|
}
|
catch (Exception ex)
|
{
|
_clientSocket.Dispose();
|
_isConnected = false;
|
throw ex;
|
}
|
}
|
|
public void Disconnect()
|
{
|
_clientSocket.Dispose();
|
}
|
|
public void Send(string data)
|
{
|
byte[] arrClientSendMsg = Encoding.UTF8.GetBytes(data);
|
lock (this)
|
{
|
_clientSocket.Send(arrClientSendMsg);
|
}
|
}
|
|
public bool SendStep(
|
string ip, int port,
|
int ovenIndex, int cellIndex, string step, string value, string limitUp,
|
string limitDown, string unit, string result, string updateTime, out string errorMsg)
|
{
|
|
errorMsg = null;
|
try
|
{
|
if (!_isConnected)
|
{
|
errorMsg = "Not Connected";
|
return false;
|
}
|
|
string msg = $"{ovenIndex};{cellIndex};{step},{value},{limitUp},{limitDown},{unit},{result},{updateTime}\n";
|
Send(msg);
|
return true;
|
}
|
catch (Exception ex)
|
{
|
errorMsg = ex.Message;
|
return false;
|
}
|
}
|
}
|
}
|
