C#.Net UdpClient 接收事件

Question

我想知道是否有任何方法可以在我的Udp客户端接收数据时以某种方式触发事件？（System. Net. Socket. Udp客户端）

我尝试覆盖它的 UdpClient.Receive，但我不能根据这个，因为可覆盖的成员必须标记为虚拟或抽象。

我目前的做法是在Threading.Timer上运行一个TimerCallback，以特定的时间间隔来获取我的数据，但我更愿意在传入数据到达时接收它，而不是重复获取它。

关于我如何做到这一点，或者我必须在间隔时间手动接收的任何建议、建议或指针？

Answer 1

UdpClient.Receive 会阻止执行，直到它从endpoint接收数据。但是有一个异步的替代方案，UdpClient.BeginReceive。它不完全是一个事件，但以类似的方式工作，你可以封装它并触发你自己的事件。文档（带有代码示例）可以在这里找到：http://msdn.microsoft.com/en-us/library/system.net.sockets.udpclient.beginreceive（v=vs.110）.aspx

Answer 2

您也可以使用Rx扩展来接收数据。

将ReceiveAsync从Upd客户端包装到可观察. FromAsync并订阅可观察的。

UdpClient client = new UdpClient(..., ...);
var obs = Observable.FromAsync(client.ReceiveAsync);
var sub = obs.Subscribe(...);

Answer 3

覆盖< code>Receive方法对您没有任何帮助——它不是UDP客户端接收数据时调用的方法，而是您想要等待传入数据时调用的方法。

但是，接收方法阻止。这意味着您实际上不必每隔一段时间进行检查 - 您可以简单地检查（几乎）无限循环。只需在不同的线程中执行此操作即可。

void Loop(CancellationToken token)
{
  var remoteEP = default(IPEndPoint);

  while (!token.IsCancellationRequested)
  {
    var data = client.Receive(ref remoteEP);

    yourForm.Invoke(DataReceived, data);
  }
}

当然，因为这是简单的I/O，所以没有必要占用一个线程来做这件事——您可以使用异步I/O:

public Task Loop(CancellationToken token)
{
  using (UdpClient client = new UdpClient(80))
  {
    while (!token.IsCancellationRequested)
    {
      var data = await client.ReceiveAsync();

      // Process the data as needed
    }
  }
}

在 winforms 或 WPF 应用程序中，这将几乎自动工作 - 您只需在事件处理程序中使用此代码btnStart_Click它将在后台等待数据时保持 UI 响应;每当数据返回时，它将在 UI 线程上执行其余代码（根据需要处理数据）——无需手动创建任何线程或处理调度。

当然，处理终止有些棘手，但这在UDP中总是很棘手——基本上，您要么必须使用支持取消的更手动的方式（ReceiveAsync只是不支持取消的开始接收和结束接收的包装器），要么您将使用设置取消令牌然后向自己发送0长度封包的老技巧（导致接收调用结束并返回零长度字节数组）。