7

我一直在尝试使用 C# 从 Twitter 流 API 读取数据，由于有时 API 不会返回任何数据，而我正在寻找近乎实时的响应，所以我一直犹豫是否使用超过 1 字节的缓冲区长度在阅读器上，以防流在接下来的一两天内不再返回任何数据。

我一直在使用以下行：

input.BeginRead(buffer, 0, buffer.Length, InputReadComplete, null); 
//buffer = new byte[1]

现在我打算扩大应用程序的规模，我认为大小为 1 会导致大量 CPU 使用，并希望增加该数量，但我仍然不希望流只是阻塞。如果在接下来的 5 秒内没有读取更多字节或类似的东西，是否可以让流返回？

4

1 回答 1

4

异步选项

如果在 5 秒内没有收到任何字节，您可以在异步回调方法中使用计时器来完成操作。每次接收到字节时重置定时器。在 BeginRead 之前启动它。

同步选项

或者，您可以使用底层套接字的 ReceiveTimeout 属性来确定在完成读取之前等待的最长时间。您可以使用更大的缓冲区并将超时设置为例如 5 秒。

从MSDN 文档中，该属性仅适用于同步读取。您可以在单独的线程上执行同步读取。

更新

这是从类似问题拼凑而成的粗略、未经测试的代码。它可能不会按原样运行（或没有错误），但应该给你一个想法：

private EventWaitHandle asyncWait = new ManualResetEvent(false);
private Timer abortTimer = null;
private bool success = false;

public void ReadFromTwitter()
{
    abortTimer = new Timer(AbortTwitter, null, 50000, System.Threading.Timeout.Infinite);

    asyncWait.Reset();
    input.BeginRead(buffer, 0, buffer.Length, InputReadComplete, null);
    asyncWait.WaitOne();            
}

void AbortTwitter(object state)
{
    success = false; // Redundant but explicit for clarity
    asyncWait.Set();
}

void InputReadComplete()
{
    // Disable the timer:
    abortTimer.Change(System.Threading.Timeout.Infinite, System.Threading.Timeout.Infinite);
    success = true;
    asyncWait.Set();
}
于 2012-12-12T00:09:53.307 回答