using HslCommunication;
|
using System;
|
using System.IO;
|
using System.Net.Sockets;
|
using System.Text;
|
|
namespace PLCHelper
|
{
|
public class RestTcpClient : IDisposable
|
{
|
public string IP { get; private set; }
|
public int Port { get; private set; }
|
|
public int ReceiveTimeout { get; set; } = 5000;
|
|
private TcpClient tcpClient;
|
private Stream Stream;
|
private BinaryReader reader;
|
private BinaryWriter writer;
|
|
public RestTcpClient(string ip, int port)
|
{
|
IP = ip;
|
Port = port;
|
}
|
|
public void ConnectServer()
|
{
|
tcpClient = new TcpClient(IP, Port);
|
tcpClient.ReceiveTimeout = ReceiveTimeout;
|
Stream = tcpClient.GetStream();
|
reader = new BinaryReader(Stream);
|
writer = new BinaryWriter(Stream);
|
}
|
|
public OperateResult<bool> ReadBool(string data)
|
{
|
OperateResult<bool> res = new OperateResult<bool>();
|
if (Request(data, out string response, out string errMsg))
|
{
|
res.Content = bool.Parse(response);
|
res.IsSuccess = true;
|
}
|
else
|
{
|
res.Message = errMsg;
|
res.IsSuccess = false;
|
}
|
return res;
|
}
|
|
public OperateResult Write(string data, bool val)
|
{
|
OperateResult res = new OperateResult();
|
if (Request(data, out string response, out string errMsg))
|
{
|
res.IsSuccess = true;
|
}
|
else
|
{
|
res.Message = errMsg;
|
res.IsSuccess = false;
|
}
|
return res;
|
}
|
|
public void Send(string data)
|
{
|
data = data + "\r";
|
writer.Write(Encoding.UTF8.GetBytes(data));
|
writer.Flush();
|
}
|
|
public bool Request(string data, out string response, out string errMsg)
|
{
|
lock (this)
|
{
|
errMsg = string.Empty;
|
response = string.Empty;
|
try
|
{
|
Send(data);
|
response = Receive();
|
return true;
|
}
|
catch (Exception ex)
|
{
|
errMsg = ex.Message;
|
return false;
|
}
|
}
|
}
|
|
private string Receive()
|
{
|
byte[] array = new byte[1024];
|
int num = tcpClient.Client.Receive(array);
|
if (num == 0)
|
{
|
throw new Exception("Closed");
|
}
|
var bytes = new byte[num];
|
Array.Copy(array, bytes, num);
|
string data = Encoding.UTF8.GetString(bytes);
|
if (data.EndsWith("\r")) data = data.Substring(0, data.Length - 1);
|
return data;
|
}
|
|
public void Dispose()
|
{
|
tcpClient.Close();
|
}
|
}
|
}
|
