using System;
|
using System.Net;
|
using System.Net.Sockets;
|
using System.Text;
|
using EventTool;
|
|
public class SocketTools
|
{
|
private int clientPort;
|
private NetworkStream clientStream;
|
private TcpListener listener;
|
private int listenPort;
|
private IPAddress localIp;
|
//private LogManager loger = new LogManager(Type.GetType("Vision.Socket"), Environment.CurrentDirectory + @"\Socket.log");
|
private TcpClient remoteClient;
|
private IPAddress remoteIp;
|
private NetworkStream remoteStream;
|
//电脑的监听端口，接收方端口，机械手IP，本地IP
|
public SocketTools(int listenPort, int clientPort, IPAddress remoteIp, IPAddress localIp)
|
{
|
this.remoteIp = remoteIp;
|
this.listenPort = listenPort;
|
this.clientPort = clientPort;
|
this.listener = new TcpListener(localIp, listenPort);
|
this.LocalIp = localIp;
|
}
|
|
public void CloseAll()
|
{
|
this.CloseListener();
|
}
|
|
public void CloseListener()
|
{
|
if (this != null)
|
{
|
if (this.remoteStream != null)
|
{
|
this.remoteStream.Close();
|
this.remoteStream.Dispose();
|
}
|
if (this.remoteClient != null)
|
{
|
this.remoteClient.Close();
|
this.remoteClient = null;
|
}
|
if (this.listener != null)
|
{
|
this.listener.Stop();
|
this.listener = null;
|
}
|
}
|
}
|
|
protected string GetIP()
|
{
|
IPAddress[] hostAddresses = Dns.GetHostAddresses(Dns.GetHostName());
|
for (int i = 0; i < hostAddresses.Length; i++)
|
{
|
if (hostAddresses[i].ToString().Length > 3)
|
{
|
return hostAddresses[i].ToString();
|
}
|
}
|
return "";
|
}
|
|
public void Listening(ListenEventCreater creater)
|
{
|
this.listener.Start();
|
while (true)
|
{
|
try
|
{
|
if (this.listener == null)
|
{
|
this.listener = new TcpListener(this.LocalIp, this.listenPort);
|
this.listener.Start();
|
}
|
if (!this.listener.Pending()) continue;
|
this.remoteClient = this.listener.AcceptTcpClient();
|
this.remoteStream = this.remoteClient.GetStream();
|
if (this.remoteStream.CanRead)
|
{
|
byte[] buffer = new byte[this.remoteClient.ReceiveBufferSize];
|
this.remoteStream.Read(buffer, 0, this.remoteClient.ReceiveBufferSize);
|
string str = Encoding.Default.GetString(buffer);
|
if (str.Contains("CLOSELISTENER"))
|
{
|
return;
|
}
|
EventData iData = new EventData(str.Trim(new char[1]));
|
creater.ChangeValue(iData);
|
}
|
}
|
catch (Exception)
|
{
|
//this.loger.WriteLog(string.Concat(new object[] { "监听问题：", exception.Source, exception.TargetSite, exception.ToString(), "\r\n" }), LogType.Info);
|
}
|
finally
|
{
|
if (this.remoteStream != null)
|
{
|
this.remoteStream.Close();
|
this.remoteStream.Dispose();
|
}
|
if (this.remoteClient != null)
|
{
|
this.remoteClient.Close();
|
}
|
}
|
}
|
}
|
|
public bool SendMessage(string messsge)
|
{
|
return this.SendMessage(this.remoteIp, this.clientPort, messsge);
|
}
|
|
public bool SendMessage(IPAddress ip, int port, string messsge)
|
{
|
bool flag;
|
TcpClient client = new TcpClient();
|
NetworkStream stream = null;
|
try
|
{
|
client.Connect(ip, port);
|
stream = client.GetStream();
|
if (stream.CanWrite)
|
{
|
byte[] bytes = Encoding.ASCII.GetBytes(messsge + "\r\n");
|
stream.Write(bytes, 0, bytes.Length);
|
return true;
|
}
|
flag = false;
|
}
|
catch (Exception)
|
{
|
//this.loger.WriteLog(string.Concat(new object[] { "发送Socket数据问题：", exception.Source, exception.TargetSite, exception.ToString(), "\r\n" }), LogType.Info);
|
flag = false;
|
}
|
finally
|
{
|
if (stream != null)
|
{
|
stream.Close();
|
}
|
if (client != null)
|
{
|
client.Close();
|
}
|
}
|
return flag;
|
}
|
|
//System.Threading.Thread receiveThread;
|
NetworkStream stm = null;
|
|
public bool SendAndReceiveMessage(IPAddress ip, int port, ref string messsge)
|
{
|
bool flag = false;
|
TcpClient tcpClient = new TcpClient();
|
|
try
|
{
|
//tcpClient = TimeOutSocket.TryConnect(new IPEndPoint(ip, port), 3000);// new TcpClient();
|
tcpClient.Connect(ip, port);
|
stm = tcpClient.GetStream();
|
//receiveThread = new System.Threading.Thread(ReceiveMessage);
|
//receiveThread.Start();
|
|
if (stm.CanWrite)
|
{
|
byte[] bytes = Encoding.ASCII.GetBytes(messsge + "\n");
|
byte[] readBytes = new byte[40];
|
|
stm.Write(bytes, 0, bytes.Length);
|
|
System.Threading.Thread.Sleep(100);
|
stm.Read(readBytes, 0, readBytes.Length);
|
|
messsge = Encoding.GetEncoding("gb2312").GetString(readBytes);
|
}
|
}
|
catch (Exception)
|
{
|
//this.loger.WriteLog(string.Concat(new object[] { "发送接收Socket数据问题：", exception.Source, exception.TargetSite, exception.ToString(), "\r\n" }), LogType.Info);
|
flag = false;
|
}
|
finally
|
{
|
if (stm != null)
|
{
|
stm.Close();
|
}
|
if (tcpClient != null)
|
{
|
tcpClient.Close();
|
}
|
}
|
return flag;
|
}
|
|
// 接收消息方法
|
private void ReceiveMessage()
|
{
|
IPEndPoint remoteIpEndPoint = new IPEndPoint(IPAddress.Any, 0);
|
while (true)
|
{
|
try
|
{
|
// 关闭receiveUdpClient时此时会产生异常
|
Encoding gb2312 = Encoding.GetEncoding("gb2312");//Encoding.Default ,936
|
byte[] receiveBytes;
|
byte[] tcpreceiveBytes = new byte[4096];
|
int count = 0;
|
|
|
//if (netSelected == 0)
|
//{
|
// receiveBytes = receiveUpdClient.Receive(ref remoteIpEndPoint);
|
//}
|
//else
|
{
|
|
count = stm.Read(tcpreceiveBytes, 0, 2048);
|
receiveBytes = tcpreceiveBytes;
|
|
}
|
|
string message = gb2312.GetString(receiveBytes);
|
|
// 显示消息内容
|
//ShowMessageforView(texboxMessageView, string.Format("{0}", message));
|
|
}
|
catch (Exception)
|
{
|
break;
|
}
|
}
|
}
|
|
|
public void Stop()
|
{
|
this.SendMessage(this.localIp, this.listenPort, "CLOSELISTENER");
|
}
|
|
public int ClientPort
|
{
|
get
|
{
|
return this.clientPort;
|
}
|
set
|
{
|
this.clientPort = value;
|
}
|
}
|
|
public NetworkStream ClientStream
|
{
|
get
|
{
|
return this.clientStream;
|
}
|
set
|
{
|
this.clientStream = value;
|
}
|
}
|
|
public int ListenPort
|
{
|
get
|
{
|
return this.listenPort;
|
}
|
set
|
{
|
this.listenPort = value;
|
}
|
}
|
|
public TcpListener Listerner
|
{
|
get
|
{
|
return this.listener;
|
}
|
set
|
{
|
this.listener = value;
|
}
|
}
|
|
public IPAddress LocalIp
|
{
|
get
|
{
|
return this.localIp;
|
}
|
set
|
{
|
this.localIp = value;
|
}
|
}
|
|
public TcpClient RemoteClient
|
{
|
get
|
{
|
return this.remoteClient;
|
}
|
set
|
{
|
this.remoteClient = value;
|
}
|
}
|
|
public IPAddress RemoteIp
|
{
|
get
|
{
|
return this.remoteIp;
|
}
|
set
|
{
|
this.remoteIp = value;
|
}
|
}
|
|
public NetworkStream RemoteStream
|
{
|
get
|
{
|
return this.remoteStream;
|
}
|
set
|
{
|
this.remoteStream = value;
|
}
|
}
|
}
|
