using System;
|
using System.Net.Sockets;
|
using System.Net;
|
using HDL_ON.DAL.Net;
|
//using HDL_ON.UI;
|
|
namespace HDL_ON
|
{
|
/// <summary>
|
/// 接收处理UDP数据包
|
/// </summary>
|
/// <typeparam name="T"></typeparam>
|
public static class BusSocket
|
{
|
//监听端口
|
static int port;
|
|
//本地Socket
|
private static Socket busSocket;
|
|
/// <summary>
|
/// 启动Socket接收和发送功能
|
/// </summary>
|
/// <param name="port"></param>
|
public static void Start (int port)
|
{
|
if (IsRunning) {
|
return;
|
}
|
|
BusSocket.port = port;
|
|
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("224.0.168.188")));
|
}
|
catch{
|
busSocket = null;
|
return;
|
}
|
|
//socket = new Socket (AddressFamily.InterNetwork, SocketType.Raw, ProtocolType.IP);
|
//socket.Bind (new IPEndPoint (IPAddress.Parse (ip), 0)); //绑定套接字
|
//socket.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption (IPAddress.Parse ("224.0.168.188")));
|
//if (SetSocketOption () == false) error_occurred = true;
|
|
asyncBeginReceive ();
|
|
MainPage.Log ("BusSocket启动成功！");
|
}
|
|
/// <summary>
|
/// 停止Socket
|
/// </summary>
|
public static void Stop()
|
{
|
if (!IsRunning)
|
{
|
return;
|
}
|
try
|
{
|
busSocket.Close();
|
}
|
catch { }
|
busSocket = null;
|
MainPage.Log("BusSocket关闭成功!");
|
}
|
|
/// <summary>
|
/// 当前的Socket是否运行
|
/// </summary>
|
public static bool IsRunning
|
{
|
get
|
{
|
return null == busSocket ? false : true;
|
}
|
}
|
|
/// <summary>
|
/// 开始异步接收数据
|
/// </summary>
|
private static void asyncBeginReceive()
|
{
|
if (!IsRunning)
|
{
|
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);
|
asyncBeginReceive ();
|
Console.WriteLine($"asyncBeginReceive {e.Message}");
|
}
|
}
|
|
/// <summary>
|
/// 异步接收数据结束
|
/// </summary>
|
/// <param name="iar"></param>
|
private static void asyncEndReceive(IAsyncResult iar)
|
{
|
if (!IsRunning)
|
{
|
return;
|
}
|
|
try
|
{
|
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);
|
|
//mqtt连接数据读取
|
//if (((IPEndPoint)packet.RemoteEndPoint).Port == 6688)
|
//{
|
// var reString = DAL.CommonPage.MyEncodingUTF8.GetString(bytes);
|
// var jt = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(reString);
|
// var gateway_objects = jt.GetValue("objects").ToString();
|
// var jt2 = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(gateway_objects);
|
// Mqtt_A_Protocol.mqttClientIP = jt2.GetValue("gateway_ip").ToString();
|
// Mqtt_A_Protocol.mqttGatewayMAC = jt2.GetValue("board_id").ToString();
|
// Mqtt_A_Protocol.StartMqtt();
|
//}
|
|
packet.Manager();
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"异步接收数据结束 {ex.Message},{((Packet)iar.AsyncState).Bytes}");
|
}
|
}
|
|
/// <summary>
|
/// 异步发送数据
|
/// </summary>
|
/// <param name="tempPacket"></param>
|
public static 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 static void asyncEndSend(IAsyncResult iar)
|
{
|
Packet tempUDPPacketBuffer = (Packet)iar.AsyncState;
|
try
|
{
|
int bytesSent = busSocket.EndSendTo(iar);
|
}
|
catch {
|
|
}
|
}
|
}
|
}
|
