using SetingDemo.LogHelp;
using SetingDemo.SingleRowDeclare;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows;
namespace SetingDemo.SocketHelp
{
public class UdpState
{
public UdpClient udpClient;
public IPEndPoint ipEndPoint;
public const int BufferSize = 1024;
public byte[] buffer = new byte[BufferSize];
public int counter = 0;
}
public class AsyncUdpSever
{ // 定義節點
private IPEndPoint ipEndPoint = null;
private IPEndPoint remoteEP = null;
// 定義UDP發送和接收
private UdpClient udpReceive = null;
private UdpClient udpSend = null;
// 定義端口
private const int listenPort = 60091;
private const int remotePort = 60091;
UdpState udpReceiveState = null;
UdpState udpSendState = null;
// 異步狀態同步
private ManualResetEvent sendDone = new ManualResetEvent(false);
private ManualResetEvent receiveDone = new ManualResetEvent(false);
public AsyncUdpSever()
{
}
public void ReceiveMsg()
{
while (true)
{
lock (this)
{
// 調用接收回調函數
IAsyncResult iar = udpReceive.BeginReceive(new AsyncCallback(ReceiveCallback), udpReceiveState);
receiveDone.WaitOne();
Thread.Sleep(100);
}
}
}
// 接收回調函數
private void ReceiveCallback(IAsyncResult iar)
{
UdpState udpReceiveState = iar.AsyncState as UdpState;
if (iar.IsCompleted)
{
Byte[] receiveBytes = udpReceiveState.udpClient.EndReceive(iar, ref udpReceiveState.ipEndPoint);
string receiveString = Encoding.ASCII.GetString(receiveBytes);
Task.Run(() =>
{
Application.Current.Dispatcher.Invoke(() =>
{
CKInstanceBase<ReviceMsgClass>.Instance.AddMsg(string.Concat("Udp接收:", receiveString));
});
});
Console.WriteLine("UDP-Received: {0}", receiveString);
//Thread.Sleep(100);
receiveDone.Set();
}
}
// 發送函數
private void SendMsg()
{
udpSend.Connect(udpSendState.ipEndPoint);
udpSendState.udpClient = udpSend;
udpSendState.counter++;
string message = string.Format("第{0}個UDP請求處理完成！", udpSendState.counter);
Byte[] sendBytes = Encoding.Unicode.GetBytes(message);
udpSend.BeginSend(sendBytes, sendBytes.Length, new AsyncCallback(SendCallback), udpSendState);
sendDone.WaitOne();
}
// 發送回調函數
private void SendCallback(IAsyncResult iar)
{
UdpState udpState = iar.AsyncState as UdpState;
Console.WriteLine("第{0}個請求處理完畢！", udpState.counter);
Console.WriteLine("number of bytes sent: {0}", udpState.udpClient.EndSend(iar));
sendDone.Set();
}
public void StatUdpRecv()
{
// 本機節點
ipEndPoint = new IPEndPoint(IPAddress.Any, listenPort);
// 遠程節點
remoteEP = new IPEndPoint(Dns.GetHostAddresses(Dns.GetHostName())[0], remotePort);
// 實例化
udpReceive = new UdpClient(ipEndPoint);
udpSend = new UdpClient();
// 分別實例化udpSendState、udpReceiveState
udpReceiveState = new UdpState();
udpReceiveState.udpClient = udpReceive;
udpReceiveState.ipEndPoint = ipEndPoint;
udpSendState = new UdpState();
udpSendState.udpClient = udpSend;
udpSendState.ipEndPoint = remoteEP;
Thread t = new Thread(new ThreadStart(ReceiveMsg));
t.IsBackground = true;
t.Start();
Console.Read();
}
}
}