//using System;
|
//using System.Net.Sockets;
|
//using System.Net;
|
|
//namespace HDL_ON.DriverLayer
|
//{
|
// public class UdpSocket
|
// {
|
// static UdpSocket _busSocket;
|
// public static UdpSocket _BusSocket
|
// {
|
// get
|
// {
|
// if(_busSocket == null)
|
// {
|
// _busSocket = new UdpSocket();
|
// }
|
// return _busSocket;
|
// }
|
// }
|
|
// //本地Socket
|
// private Socket busSocket;
|
// public int Port = 0;
|
// /// <summary>
|
// /// 启动Socket接收和发送功能
|
// /// </summary>
|
// public void Start (int port = 0)
|
// {
|
// if (IsRunning)
|
// {
|
// if (port == Port)
|
// {
|
// return;
|
// }
|
// else
|
// {
|
// busSocket.Close();
|
// }
|
// }
|
// if (port != 0)
|
// Port = port;
|
// if (Port == 0)
|
// return;
|
|
// busSocket = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
|
// busSocket.EnableBroadcast = true;
|
// try {
|
// busSocket.Bind(new IPEndPoint(IPAddress.Any, Port));
|
|
// busSocket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(IPAddress.Parse("239.0.168.188")));
|
// relinkCount = 0;
|
// }
|
// catch (Exception ex){
|
// MainPage.Log ($"udp port bind error : {ex.Message}");
|
|
// busSocket = null;
|
// return;
|
// }
|
|
// asyncBeginReceive();
|
|
// MainPage.Log ($"udp port : {port}");
|
// }
|
|
// /// <summary>
|
// /// 停止Socket
|
// /// </summary>
|
// public void Stop()
|
// {
|
// if(busSocket == null)
|
// {
|
// return;
|
// }
|
// if (!IsRunning)
|
// {
|
// return;
|
// }
|
// try
|
// {
|
// busSocket.Close();
|
// relinkCount = 0;
|
// }
|
// catch { }
|
// busSocket = null;
|
// MainPage.Log("Socket关闭");
|
// }
|
|
// /// <summary>
|
// /// 当前的Socket是否运行
|
// /// </summary>
|
// public bool IsRunning
|
// {
|
// get
|
// {
|
// return null == busSocket ? false : true;
|
// }
|
// }
|
|
// /// <summary>
|
// /// 开始异步接收数据
|
// /// </summary>
|
// private void asyncBeginReceive()
|
// {
|
// if (!IsRunning)
|
// {
|
// return;
|
// }
|
// if(busSocket == null)
|
// {
|
// return;
|
// }
|
|
// try {
|
// Packet packet = new Packet ();
|
// busSocket.BeginReceiveFrom (packet.Bytes, 0, packet.Bytes.Length, SocketFlags.None, ref packet.RemoteEndPoint, new AsyncCallback (asyncEndReceive), packet);
|
// }
|
// catch (Exception e) {
|
// System.Threading.Thread.Sleep (1);
|
// Console.WriteLine("asyncBeginReceive " + relinkCount );
|
// if (relinkCount == 0)
|
// {
|
// relinkCount = 1;
|
// asyncBeginReceive();
|
// }
|
// Console.WriteLine($"asyncBeginReceive {e.Message}");
|
// }
|
// }
|
// /// <summary>
|
// /// 重连次数
|
// /// </summary>
|
// private int relinkCount = 0;
|
|
|
|
// /// <summary>
|
// /// 异步接收数据结束
|
// /// </summary>
|
// /// <param name="iar"></param>
|
// private void asyncEndReceive(IAsyncResult iar)
|
// {
|
// if (!IsRunning)
|
// {
|
// return;
|
// }
|
// try
|
// {
|
// if (busSocket == null)
|
// {
|
// return;
|
// }
|
// asyncBeginReceive();
|
// Packet packet = (Packet)iar.AsyncState;
|
// int len = busSocket.EndReceiveFrom(iar, ref packet.RemoteEndPoint);
|
|
// byte[] bytes = packet.Bytes;
|
// packet.Bytes = new byte[len];
|
// Array.Copy(bytes, 0, packet.Bytes, 0, packet.Bytes.Length);
|
|
// //MainPage.Log($"接收{packet.RemoteEndPoint}数据");
|
// //mqtt连接数据读取 A协议网络设备信息读取回复 处理
|
// if (((IPEndPoint)packet.RemoteEndPoint).Port == 8585)
|
// {
|
// Control.Ins.ConvertReceiveData(bytes, ((IPEndPoint)packet.RemoteEndPoint).Address.ToString());
|
// }
|
// else if (((IPEndPoint)packet.RemoteEndPoint).Port == 6000)//处理bus 6000端口的数据
|
// {
|
// packet.Manager();
|
// }
|
|
// }
|
// catch (Exception ex)
|
// {
|
// MainPage.Log($"异步接收数据结束 {ex.Message},{((Packet)iar.AsyncState).Bytes}");
|
// }
|
// }
|
|
// /// <summary>
|
// /// 异步发送数据
|
// /// </summary>
|
// /// <param name="tempPacket"></param>
|
// public void AsyncBeginSend(Packet tempPacket)
|
// {
|
// try
|
// {
|
// if (!IsRunning)
|
// {
|
// tempPacket.HaveSendCount++;
|
// return;
|
// }
|
// tempPacket.FlagDateTime = System.DateTime.Now;
|
// tempPacket.HaveSendCount++;
|
// busSocket.BeginSendTo(tempPacket.Bytes, 0, tempPacket.Bytes.Length, SocketFlags.None, tempPacket.RemoteEndPoint, new AsyncCallback(asyncEndSend), tempPacket);
|
// }
|
// catch (Exception ex)
|
// {
|
// MainPage.Log($"AsyncBeginSend error {ex.Message}");
|
// }
|
// }
|
|
// /// <summary>
|
// /// 异步发送数据结束
|
// /// </summary>
|
// /// <param name="iar"></param>
|
// private void asyncEndSend(IAsyncResult iar)
|
// {
|
// Packet tempUDPPacketBuffer = (Packet)iar.AsyncState;
|
// try
|
// {
|
// int bytesSent = busSocket.EndSendTo(iar);
|
// }
|
// catch {
|
|
// }
|
// }
|
// }
|
//}
|
|
using System;
|
using System.Net.Sockets;
|
using System.Net;
|
|
namespace HDL_ON.DriverLayer
|
{
|
public class UdpSocket
|
{
|
static UdpSocket _busSocket;
|
public static UdpSocket _BusSocket
|
{
|
get
|
{
|
if (_busSocket == null)
|
{
|
_busSocket = new UdpSocket();
|
}
|
return _busSocket;
|
}
|
}
|
|
//本地Socket
|
private Socket busSocket;
|
public int Port = 0;
|
/// <summary>
|
/// 启动Socket接收和发送功能
|
/// </summary>
|
public void Start(int port = 0)
|
{
|
if (IsRunning)
|
{
|
if (port == Port)
|
{
|
return;
|
}
|
else
|
{
|
busSocket.Close();
|
}
|
}
|
if (port != 0)
|
Port = port;
|
if (Port == 0)
|
return;
|
|
busSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
|
busSocket.EnableBroadcast = true;
|
try
|
{
|
busSocket.Bind(new IPEndPoint(IPAddress.Any, Port));
|
|
busSocket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(IPAddress.Parse("239.0.168.188")));
|
relinkCount = 0;
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"udp port bind error : {ex.Message}");
|
|
busSocket = null;
|
return;
|
}
|
|
asyncBeginReceive();
|
|
MainPage.Log($"udp port : {port}");
|
}
|
|
/// <summary>
|
/// 停止Socket
|
/// </summary>
|
public void Stop()
|
{
|
if (busSocket == null)
|
{
|
return;
|
}
|
if (!IsRunning)
|
{
|
return;
|
}
|
try
|
{
|
busSocket.Close();
|
relinkCount = 0;
|
}
|
catch { }
|
busSocket = null;
|
MainPage.Log("Socket关闭");
|
}
|
|
/// <summary>
|
/// 当前的Socket是否运行
|
/// </summary>
|
public bool IsRunning
|
{
|
get
|
{
|
return null == busSocket ? false : true;
|
}
|
}
|
|
byte []receiveBytes = new byte[2000];
|
|
/// <summary>
|
/// 开始异步接收数据
|
/// </summary>
|
private void asyncBeginReceive()
|
{
|
if (!IsRunning)
|
{
|
return;
|
}
|
if (busSocket == null)
|
{
|
return;
|
}
|
|
try
|
{
|
int len = busSocket.Receive(receiveBytes, SocketFlags.None);
|
|
Packet packet = new Packet(len);
|
|
System.Array.Copy(receiveBytes, packet.Bytes, len);
|
packet.Manager();
|
}
|
catch (Exception e)
|
{
|
System.Threading.Thread.Sleep(1);
|
Console.WriteLine("asyncBeginReceive " + relinkCount);
|
if (relinkCount == 0)
|
{
|
relinkCount = 1;
|
asyncBeginReceive();
|
}
|
Console.WriteLine($"asyncBeginReceive {e.Message}");
|
}
|
}
|
/// <summary>
|
/// 重连次数
|
/// </summary>
|
private int relinkCount = 0;
|
|
|
|
/// <summary>
|
/// 异步接收数据结束
|
/// </summary>
|
/// <param name="iar"></param>
|
private void asyncEndReceive(IAsyncResult iar)
|
{
|
if (!IsRunning)
|
{
|
return;
|
}
|
try
|
{
|
if (busSocket == null)
|
{
|
return;
|
}
|
asyncBeginReceive();
|
Packet packet = (Packet)iar.AsyncState;
|
int len = busSocket.EndReceiveFrom(iar, ref packet.RemoteEndPoint);
|
|
byte[] bytes = packet.Bytes;
|
packet.Bytes = new byte[len];
|
Array.Copy(bytes, 0, packet.Bytes, 0, packet.Bytes.Length);
|
|
//MainPage.Log($"接收{packet.RemoteEndPoint}数据");
|
//mqtt连接数据读取 A协议网络设备信息读取回复 处理
|
if (((IPEndPoint)packet.RemoteEndPoint).Port == 8585)
|
{
|
Control.Ins.ConvertReceiveData(bytes, ((IPEndPoint)packet.RemoteEndPoint).Address.ToString());
|
}
|
else if (((IPEndPoint)packet.RemoteEndPoint).Port == 6000)//处理bus 6000端口的数据
|
{
|
packet.Manager();
|
}
|
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"异步接收数据结束 {ex.Message},{((Packet)iar.AsyncState).Bytes}");
|
}
|
}
|
|
/// <summary>
|
/// 异步发送数据
|
/// </summary>
|
/// <param name="tempPacket"></param>
|
public void AsyncBeginSend(Packet tempPacket)
|
{
|
try
|
{
|
if (!IsRunning)
|
{
|
tempPacket.HaveSendCount++;
|
return;
|
}
|
tempPacket.FlagDateTime = System.DateTime.Now;
|
tempPacket.HaveSendCount++;
|
busSocket.BeginSendTo(tempPacket.Bytes, 0, tempPacket.Bytes.Length, SocketFlags.None, tempPacket.RemoteEndPoint, new AsyncCallback(asyncEndSend), tempPacket);
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"AsyncBeginSend error {ex.Message}");
|
}
|
}
|
|
/// <summary>
|
/// 异步发送数据结束
|
/// </summary>
|
/// <param name="iar"></param>
|
private void asyncEndSend(IAsyncResult iar)
|
{
|
Packet tempUDPPacketBuffer = (Packet)iar.AsyncState;
|
try
|
{
|
int bytesSent = busSocket.EndSendTo(iar);
|
}
|
catch
|
{
|
|
}
|
}
|
}
|
}
|
