调用 Socket.Receive 时防止线程休眠

Question

我正在开发一个低延迟的金融应用程序，该应用程序通过套接字接收 tcp 数据。
这就是我建立套接字连接并接收字节的方式：

public class IncomingData
{
  Socket _Socket;
  byte[] buffer = new byte[4096];

  public static void Connect(IPEndPoint endPoint)
  {
    _Socket = new Socket(
                  AddressFamily.InterNetwork,
                  SocketType.Stream, 
                  ProtocolType.Tcp);

    _Socket.Connect(endPoint);
  }

  public static void ReadSocket(int ReadQty)
  {
    _Socket.Receive(buffer, 0, ReadQty, SocketFlags.None); 
  }
}

我听说当您在 Stream 套接字上调用 Receive() 时，调用线程将进入睡眠状态，并且在以下情况下被唤醒：收到数据。我希望线程全速运行（使用 CPU 容量）。

有没有办法使用 Stream 套接字来做到这一点？如果唯一的方法是使用原始套接字，您能提供一个示例吗？

Answer 1

如果我理解正确的话，您希望 Receive 不被阻止？

看一下套接字类的 BeginX/EndX 方法。这些方法异步执行（不会阻塞当前线程）。它们接受回调方法作为参数之一，并且在操作完成时将调用该方法（在本例中，将接收数据）。它本质上与事件相同。

public class IncomingData
{
    Socket _Socket;
    byte[] buffer = new byte[4096];

    public static void Connect(IPEndPoint endPoint)
    {
        _Socket = new Socket(
                      AddressFamily.InterNetwork,
                      SocketType.Stream, 
                      ProtocolType.Tcp);        

        _Socket.Connect(endPoint);

    }

    public static void ReadSocket(int ReadQty)
    {
         // Wait for some data to be received. When data is received,
         // ReceiveCallback will be called.
         _Socket.BeginReceive(buffer, 0, ReadQty, SocketFlags.None, ReceiveCallback, null);
    }

    private static void ReceiveCallback(IAsyncResult asyncResult)
    {
        int bytesTransferred = _Socket.EndReceive(asyncResult);

        // ...
        // process the data
        // ...
    }
}

Answer 2

您可以使用 Socket.Poll 来确定套接字是否有数据，否则继续旋转：

// will spin here until poll returns true
while(!socket.Poll(0, SelectMode.SelectRead));
socket.Receive...

Answer 3

也许可以通过查看 networkComms.net 来回避通过网络发送数据的整个问题，特别是演示最基本功能的简短示例此处，希望不会过于复杂！您可能遇到的大多数问题都已得到解决，这可能会节省您一些时间。