538 lines
19 KiB
C#
538 lines
19 KiB
C#
using System;
|
||
using System.Net;
|
||
using System.Net.Sockets;
|
||
using System.Text;
|
||
using System.Threading;
|
||
using Aitex.Core.RT.Event;
|
||
using Aitex.Core.RT.Log;
|
||
using MECF.Framework.Common.Equipment;
|
||
|
||
namespace MECF.Framework.RT.EquipmentLibrary.HardwareUnits.LoadPorts
|
||
{
|
||
public class AsyncSocket : ICommunication, IDisposable
|
||
{
|
||
public delegate void ErrorHandler(ErrorEventArgs args);
|
||
public event ErrorHandler OnErrorHappened;
|
||
|
||
public delegate void MessageHandler(string message);
|
||
public event MessageHandler OnDataChanged;
|
||
|
||
private static Object _locker = new Object();
|
||
|
||
public class ClientStateObject
|
||
{
|
||
// Client socket.
|
||
public Socket workSocket = null;
|
||
// Size of receive buffer.
|
||
public const int BufferSize = 256;
|
||
// Receive buffer.
|
||
public byte[] buffer = new byte[BufferSize];
|
||
// Received data string.
|
||
public StringBuilder sb = new StringBuilder();
|
||
}
|
||
|
||
public string NewLine { get; set; }
|
||
|
||
private Socket _socket;
|
||
|
||
private string _ip;
|
||
private int _port;
|
||
|
||
private int _bufferSize = 256;
|
||
|
||
public bool IsConnected { get { return (_socket != null && _socket.Connected); } }
|
||
//public bool IsConnected { get { return (_socket != null && IsSocketConnected(_socket)); } }
|
||
private bool IsSocketConnected(Socket client)
|
||
{
|
||
try
|
||
{
|
||
byte[] tmp = new byte[] { 0x0, 0x0, 0x0 };
|
||
//int a= newclient.Receive(tmp);
|
||
int a = client.Send(tmp);
|
||
if (a == 1)
|
||
return true;
|
||
else
|
||
return false;
|
||
}
|
||
catch (SocketException e)
|
||
{
|
||
LOG.Write(e);
|
||
return false;
|
||
}
|
||
|
||
}
|
||
public AsyncSocket(string address, string newline = "\r")
|
||
{
|
||
// Connect(address);
|
||
_socket = null;
|
||
NewLine = newline;
|
||
}
|
||
public AsyncSocket(string address, int bufferSize, string newline = "\r")
|
||
{
|
||
_socket = null;
|
||
NewLine = newline;
|
||
|
||
_bufferSize = bufferSize;
|
||
}
|
||
|
||
~AsyncSocket()
|
||
{
|
||
Dispose();
|
||
}
|
||
|
||
public void Connect(string address)
|
||
{
|
||
try
|
||
{
|
||
_ip = address.Split(':')[0];
|
||
_port = int.Parse(address.Split(':')[1]);
|
||
IPAddress ipAddress = IPAddress.Parse(_ip);
|
||
IPEndPoint remoteEP = new IPEndPoint(ipAddress, _port);
|
||
|
||
//Dispose current socket and create a TCP/IP socket.
|
||
Dispose();
|
||
|
||
if (_socket == null)
|
||
_socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||
|
||
// Connect to the remote endpoint.
|
||
_socket.BeginConnect(remoteEP, new AsyncCallback(ConnectCallback), _socket);
|
||
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
LOG.Write(e);
|
||
throw new Exception(e.ToString());
|
||
}
|
||
|
||
}
|
||
private void ConnectCallback(IAsyncResult ar)
|
||
{
|
||
try
|
||
{
|
||
// Retrieve the socket from the state object.
|
||
Socket client = (Socket)ar.AsyncState;
|
||
// Complete the connection.
|
||
client.EndConnect(ar);
|
||
|
||
EV.PostMessage(ModuleName.Robot.ToString(), EventEnum.TCPConnSucess, _ip, _port.ToString());
|
||
|
||
// Receive the response from the remote device.
|
||
Receive(_socket);
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
LOG.Write(e);
|
||
string reason = string.Format("Communication {0}:{1:D} {2}.", _ip, _port, e.Message);
|
||
LOG.Error(reason);
|
||
// EV.PostMessage(UnitName.Transfer.ToString(), EventEnum.RobotCommandFailed, reason);
|
||
OnErrorHappened(new ErrorEventArgs(reason));
|
||
}
|
||
}
|
||
private void Receive(Socket client)
|
||
{
|
||
try
|
||
{
|
||
// Create the state object.
|
||
ClientStateObject state = new ClientStateObject();
|
||
state.workSocket = client;
|
||
|
||
// Begin receiving the data from the remote device.
|
||
client.BeginReceive(state.buffer, 0, ClientStateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
LOG.Write(e);
|
||
string reason = string.Format("TCP连接发生错误：{0}", e.Message);
|
||
LOG.Error(string.Format("Communication {0}:{1:D} {2}.", _ip, _port, reason));
|
||
OnErrorHappened(new ErrorEventArgs(reason));
|
||
}
|
||
}
|
||
private void ReceiveCallback(IAsyncResult ar)
|
||
{
|
||
try
|
||
{
|
||
if (!IsConnected) { return; }
|
||
|
||
// Retrieve the state object and the client socket
|
||
// from the asynchronous state object.
|
||
ClientStateObject state = (ClientStateObject)ar.AsyncState;
|
||
Socket client = state.workSocket;
|
||
|
||
// Read data from the remote device.
|
||
int bytesRead = client.EndReceive(ar);
|
||
if (bytesRead > 0)
|
||
{
|
||
// There might be more data, so store the data received so far.
|
||
|
||
state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead));
|
||
|
||
if (state.sb.Length > NewLine.Length)
|
||
{
|
||
if (state.sb.ToString().Substring(state.sb.Length - NewLine.Length).Equals(NewLine))
|
||
{
|
||
string msg = state.sb.ToString();
|
||
LOG.Info(string.Format("Communication {0}:{1:D} receive {2}.", _ip, _port, msg.TrimEnd('\n').TrimEnd('\r')));
|
||
OnDataChanged(state.sb.ToString());
|
||
state.sb.Clear();
|
||
}
|
||
}
|
||
// Get the rest of the data.
|
||
client.BeginReceive(state.buffer, 0, ClientStateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
LOG.Write(ex);
|
||
string reason = string.Format("TCP Socket recevice data failed：{0}", ex.Message);
|
||
LOG.Error(string.Format("Communication {0}:{1:D} {2}.", _ip, _port, reason));
|
||
OnErrorHappened(new ErrorEventArgs(reason));
|
||
}
|
||
}
|
||
|
||
public bool Write(string data)
|
||
{
|
||
try
|
||
{
|
||
lock (_locker)
|
||
{
|
||
// Convert the string data to byte data using ASCII encoding.
|
||
byte[] byteData = Encoding.ASCII.GetBytes(data);
|
||
_socket.BeginSend(byteData, 0, byteData.Length, 0, new AsyncCallback(SendCallback), _socket);
|
||
|
||
LOG.Info(string.Format("Communication {0}:{1:D} Send {2}.", _ip, _port, data));
|
||
}
|
||
|
||
return true;
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
LOG.Write(ex);
|
||
LOG.Info(string.Format("Communication {0}:{1:D} Send {2}. failed", _ip, _port, data));
|
||
|
||
string reason = string.Format("Send command failed:{0}", ex.Message);
|
||
OnErrorHappened(new ErrorEventArgs(reason));
|
||
}
|
||
|
||
return false;
|
||
}
|
||
|
||
private void SendCallback(IAsyncResult ar)
|
||
{
|
||
try
|
||
{
|
||
// Retrieve the socket from the state object.
|
||
Socket client = (Socket)ar.AsyncState;
|
||
// Complete sending the data to the remote device.
|
||
int bytesSent = client.EndSend(ar);
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
LOG.Write(ex);
|
||
string reason = string.Format("Send command failed:{0}", ex.Message);
|
||
|
||
OnErrorHappened(new ErrorEventArgs(reason));
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 释放资源（Dispose）
|
||
/// </summary>
|
||
public void Dispose()
|
||
{
|
||
try
|
||
{
|
||
if (_socket != null)
|
||
{
|
||
if (IsConnected)
|
||
{
|
||
_socket.Shutdown(SocketShutdown.Both);
|
||
}
|
||
|
||
_socket.Close();
|
||
_socket.Dispose();
|
||
_socket = null;
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
LOG.Write(ex);
|
||
string reason = string.Format("release socket failed:{0}", ex.Message);
|
||
OnErrorHappened(new ErrorEventArgs(reason));
|
||
}
|
||
}
|
||
}
|
||
//public class AsyncSocket : ICommunication, IDisposable
|
||
//{
|
||
// public delegate void ErrorHandler(ErrorEventArgs args);
|
||
// public event ErrorHandler OnErrorHappened;
|
||
|
||
// public delegate void MessageHandler(string message);
|
||
// public event MessageHandler OnDataChanged;
|
||
|
||
// private static Object _locker = new Object();
|
||
|
||
// public class ClientStateObject
|
||
// {
|
||
// // Client socket.
|
||
// public Socket workSocket = null;
|
||
// // Size of receive buffer.
|
||
// public static int BufferSize = 256;
|
||
// // Receive buffer.
|
||
// public byte[] buffer = new byte[BufferSize];
|
||
// // Received data string.
|
||
// public StringBuilder sb = new StringBuilder();
|
||
|
||
// public ClientStateObject(int bufferSize = 256)
|
||
// {
|
||
// BufferSize = bufferSize;
|
||
// buffer = new byte[bufferSize];
|
||
// }
|
||
// }
|
||
|
||
// public string NewLine { get; set; }
|
||
// public bool NeedLog { get; set; } = true;
|
||
|
||
// private Socket _socket;
|
||
|
||
// private string _ip;
|
||
// private int _port;
|
||
// private string _address;
|
||
// private int _bufferSize = 256;
|
||
|
||
// public bool IsConnected { get { return (_socket != null && _socket.Connected); } } //&& !_socket.Poll(100, SelectMode.SelectRead)); } }
|
||
// public bool IsHstConnected { get { return (_socket != null && IsSocketConnected(_socket)); } }
|
||
// private bool IsSocketConnected(Socket client)
|
||
// {
|
||
// try
|
||
// {
|
||
// byte[] tmp = new byte[] { 0x0};
|
||
// //int a= newclient.Receive(tmp);
|
||
// int a = client.Send(tmp);
|
||
// if (a == 1)
|
||
// return true;
|
||
// else
|
||
// return false;
|
||
// }
|
||
// catch (SocketException e)
|
||
// {
|
||
// LOG.Write(e.Message);
|
||
// return false;
|
||
// }
|
||
|
||
// }
|
||
// public AsyncSocket(string address, string newline ="\r")
|
||
// {
|
||
// // Connect(address);
|
||
// _socket = null;
|
||
// NewLine = newline;
|
||
// _address = address;
|
||
// }
|
||
|
||
// public AsyncSocket(string address, int bufferSize, string newline ="\r")
|
||
// {
|
||
// _socket = null;
|
||
// NewLine = newline;
|
||
// _address = address;
|
||
// _bufferSize = bufferSize;
|
||
// }
|
||
|
||
// ~AsyncSocket()
|
||
// {
|
||
// Dispose();
|
||
// }
|
||
|
||
// public void Connect(string address)
|
||
// {
|
||
// try
|
||
// {
|
||
// _ip =address.Split(':')[0];
|
||
// _port =int.Parse(address.Split(':')[1]);
|
||
// IPAddress ipAddress = IPAddress.Parse(_ip);
|
||
// IPEndPoint remoteEP = new IPEndPoint(ipAddress, _port);
|
||
|
||
// lock (_locker)
|
||
// {
|
||
// //Dispose current socket and create a TCP/IP socket.
|
||
// Dispose();
|
||
|
||
// if(_socket == null)
|
||
// _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||
|
||
// // Connect to the remote endpoint.
|
||
// _socket.BeginConnect(remoteEP, new AsyncCallback(ConnectCallback), _socket);
|
||
// }
|
||
// }
|
||
// catch (Exception e)
|
||
// {
|
||
// LOG.Write(e);
|
||
// throw new Exception(e.ToString());
|
||
// }
|
||
|
||
// }
|
||
// private void ConnectCallback(IAsyncResult ar)
|
||
// {
|
||
// try
|
||
// {
|
||
// // Retrieve the socket from the state object.
|
||
// Socket client = (Socket)ar.AsyncState;
|
||
// // Complete the connection.
|
||
// client.EndConnect(ar);
|
||
|
||
// EV.PostMessage(ModuleName.Robot.ToString(), EventEnum.TCPConnSucess, _ip, _port.ToString());
|
||
|
||
// // Receive the response from the remote device.
|
||
// Receive(_socket);
|
||
// }
|
||
// catch(Exception e)
|
||
// {
|
||
// LOG.Write(e);
|
||
// string reason = string.Format("Communication {0}:{1:D} {2}.", _ip, _port, e.Message);
|
||
// LOG.Error(reason);
|
||
// // EV.PostMessage(UnitName.Transfer.ToString(), EventEnum.RobotCommandFailed, reason);
|
||
// //OnErrorHappened(new ErrorEventArgs(reason));
|
||
|
||
// Thread.Sleep(1000);
|
||
// Connect(_address);
|
||
// }
|
||
// }
|
||
// private void Receive(Socket client)
|
||
// {
|
||
// try
|
||
// {
|
||
// // Create the state object.
|
||
// ClientStateObject state = new ClientStateObject(_bufferSize);
|
||
// state.workSocket = client;
|
||
|
||
// // Begin receiving the data from the remote device.
|
||
// client.BeginReceive(state.buffer, 0, ClientStateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
|
||
// }
|
||
// catch (Exception e)
|
||
// {
|
||
// LOG.Write(e);
|
||
// string reason = string.Format("TCP connection error:{0}", e.Message);
|
||
// LOG.Error(string.Format("Communication {0}:{1:D} {2}.", _ip, _port, reason));
|
||
// OnErrorHappened(new ErrorEventArgs(reason));
|
||
// }
|
||
// }
|
||
// private void ReceiveCallback(IAsyncResult ar)
|
||
// {
|
||
// try
|
||
// {
|
||
// if (!IsConnected) { return; }
|
||
|
||
// // Retrieve the state object and the client socket
|
||
// // from the asynchronous state object.
|
||
// ClientStateObject state = (ClientStateObject)ar.AsyncState;
|
||
// Socket client = state.workSocket;
|
||
|
||
// // Read data from the remote device.
|
||
// int bytesRead = client.EndReceive(ar);
|
||
// if (bytesRead > 0)
|
||
// {
|
||
// // There might be more data, so store the data received so far.
|
||
|
||
// state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead));
|
||
|
||
// if (state.sb.Length > NewLine.Length)
|
||
// {
|
||
// if (state.sb.ToString().Substring(state.sb.Length - NewLine.Length).Equals(NewLine))
|
||
// {
|
||
// string msg =state.sb.ToString();
|
||
// if(NeedLog)
|
||
// LOG.Info(string.Format("Communication {0}:{1:D} receive {2}.", _ip, _port, msg.TrimEnd('\n').TrimEnd('\r')));
|
||
// OnDataChanged(state.sb.ToString());
|
||
// state.sb.Clear();
|
||
// }
|
||
// }
|
||
// // Get the rest of the data.
|
||
// client.BeginReceive(state.buffer, 0, ClientStateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
|
||
// }
|
||
// }
|
||
// catch (Exception ex)
|
||
// {
|
||
// LOG.Write(ex);
|
||
// string reason = string.Format("TCP Socket recevice data failed：{0}", ex.Message);
|
||
// LOG.Error(string.Format("Communication {0}:{1:D} {2}.", _ip, _port, reason));
|
||
// OnErrorHappened(new ErrorEventArgs(reason));
|
||
// }
|
||
// }
|
||
|
||
// public bool Write(string data)
|
||
// {
|
||
// try
|
||
// {
|
||
// lock (_locker)
|
||
// {
|
||
// // Convert the string data to byte data using ASCII encoding.
|
||
// byte[] byteData = Encoding.ASCII.GetBytes(data);
|
||
// _socket.BeginSend(byteData, 0, byteData.Length, 0, new AsyncCallback(SendCallback), _socket);
|
||
|
||
// LOG.Info(string.Format("Communication {0}:{1:D} Send {2}.", _ip, _port, data));
|
||
// }
|
||
|
||
// return true;
|
||
|
||
// }
|
||
// catch (Exception ex)
|
||
// {
|
||
// LOG.Write(ex);
|
||
// LOG.Info(string.Format("Communication {0}:{1:D} Send {2}. failed", _ip, _port, data));
|
||
|
||
// string reason = string.Format("Send command failed:{0}", ex.Message);
|
||
// OnErrorHappened(new ErrorEventArgs(reason));
|
||
// }
|
||
|
||
// return false;
|
||
// }
|
||
|
||
// private void SendCallback(IAsyncResult ar)
|
||
// {
|
||
// try
|
||
// {
|
||
// // Retrieve the socket from the state object.
|
||
// Socket client = (Socket)ar.AsyncState;
|
||
// // Complete sending the data to the remote device.
|
||
// int bytesSent = client.EndSend(ar);
|
||
|
||
// }
|
||
// catch (Exception ex)
|
||
// {
|
||
// LOG.Write(ex);
|
||
// string reason = string.Format("Send command failed:{0}", ex.Message);
|
||
|
||
// OnErrorHappened(new ErrorEventArgs(reason));
|
||
// }
|
||
// }
|
||
|
||
// /// <summary>
|
||
// /// 释放资源（Dispose）
|
||
// /// </summary>
|
||
// public void Dispose()
|
||
// {
|
||
// try
|
||
// {
|
||
// if (_socket != null)
|
||
// {
|
||
// if (IsConnected)
|
||
// {
|
||
// _socket.Shutdown(SocketShutdown.Both);
|
||
// }
|
||
|
||
// _socket.Close();
|
||
// _socket.Dispose();
|
||
// _socket = null;
|
||
// }
|
||
// }
|
||
// catch (Exception ex)
|
||
// {
|
||
// LOG.Write(ex);
|
||
// string reason = string.Format("释放socket资源失败:{0}", ex.Message);
|
||
// OnErrorHappened(new ErrorEventArgs(reason));
|
||
// }
|
||
// }
|
||
//}
|
||
}
|