場景一：
用戶需要在界面上看到消息的發送與回復，UDP得發送1->接收回復1->發送2->接收回復2
場景二：
無關用戶體驗，但是需要大量的數據發送，可能導致接收方處理不過來而端口堵塞消息丟棄
方案：
使用EventWaitHandle的WaitOne來暫停發送，當收到消息回復或者有消息超時時Set繼續發送，代碼（包含偽代碼，不可編譯）如下:
ConcurrentDictionary<int, DateTime> _batchMsgID = new ConcurrentDictionary<int, DateTime>();//等待中的消息<消息唯一標識,開始等待時間>
EventWaitHandle _waitHandler = new AutoResetEvent(false);//執行下發等待信號
SendFunc()
{
for()
{
_batchMsgID.TryAdd();//加入等待
UdpSendOne();//發送一條數據
if(_batchMsgID.Count>=10) _waitHandler.WaitOne(); //場景一,不用判斷直接wait;場景二,等待數超過10條暫停發送
}
}
ReceiveFunc()
{
while()
{
UdpReceiveOne();//收到一條數據
if (_batchMsgID.ContainsKey(msgID))
{
DateTime time;
_batchMsgID.TryRemove(msgID, out time);
if (_batchMsgID.Count <= 10) _waitHandler.Set(); //場景一,不用判斷直接set;
}
}
}
timer_tick()
{//消息超時處理
try
{
List<int> keys = new List<int>();
foreach(var msg in _batchMsgID)
{
if ((DateTime.Now - msg.Value).TotalSeconds >= 3) keys.Add(msg.Key);
}
DateTime time;
keys.ForEach(x => _batchMsgID.TryRemove(x, out time));
if (_batchMsgID.Count <= 10) _waitHandler.Set(); //場景一,不用判斷直接set;
}
catch (Exception ex) { LogHelper.logger.Error(ex); }
}