在 Unity c# 中打开一个 StreamReader

Question

我正在开发一个游戏，我需要从流（尚未结束）中检索数据。

我有一个名为 StreamingChannel 的类，它创建了流媒体频道

    public StreamingChannel (){

    //stuff to set the stream

    webResponse = (HttpWebResponse) webRequest.GetResponse();
    responseStream = new StreamReader (webResponse.GetResponseStream (), encode);
    }

并从中读取我有这个方法

public string Read(){

    try{
        string jsonText = responseStream.ReadLine();
        return jsonText;
    }catch(ObjectDisposedException){
        return null;
    }
}

我使用 InvokeRepeating 每隔几秒执行一次读取，并且在整个游戏中都这样做。

效果很好，只是我的直播持续了大约几分钟。之后它会抛出一个 ObjectDisposedException。

起初我想恢复连接，但如果不重新实例化整个连接，我就无法做到。在这种情况下，问题是游戏延迟了大约一秒钟。 那么如何告诉 StreamReader 必须保持打开通道？

ps 我不能使用构造函数

public StreamReader(
Stream stream,
Encoding encoding,
bool detectEncodingFromByteOrderMarks,
int bufferSize,
bool leaveOpen)

因为它已在 .NET Framework 4.5 版本中引入，而 Unity 不支持。

Answer 1

流式 API 期望您的代码非常积极地从 Stream 中提取数据。您可能无法等待 Unity 安排您的 ReadLine 方法。我认为更好的模型是使用单独的线程尽可能快地从 Stream 中提取数据并将其存储在缓冲区中。 （我认为这在 Unity 中是可能的。） 然后您可以在标准 Unity 线程中将流数据从缓冲区中拉出，而不必担心拉取率。 ConcurrentQueue 会是一个很好的缓冲区，但 Unity 不支持它，所以我使用了一个锁定的 List。

使用单独的线程还可以让您在失败后重新启动，而不会阻塞主游戏。

using System.Collections.Generic;
using System.Threading;
public class StreamingChannel
{
    private readonly List<string> backgroundLinesList;
    private readonly object listLock = new object();
    private Thread streamReaderThread;

    public StreamingChannel()
    {
        streamReaderThread = new Thread(this.ReadWebStream);
        streamReaderThread.Start();
    }

    public List<string> Read()
    {
        if (!streamReaderThread.IsAlive)
        {
            streamReaderThread = new Thread(this.ReadWebStream);
            streamReaderThread.Start();
        }

        List<string> lines = null;
        lock (listLock)
        {
            if (backgroundLinesList != null)
            {
                lines = backgroundLinesList;
                backgroundLinesList = null;
            }
        }

        return lines;
    }

    private void ReadWebStream()
    {
        try
        {
            //stuff to set the stream
            HttpWebRequest webRequest;
            HttpWebResponse webResponse = (HttpWebResponse)webRequest.GetResponse();
            StreamReader responseStream = new StreamReader(webResponse.GetResponseStream(), encode);
            while (!responseStream.EndOfStream)
            {
                var line = responseStream.ReadLine()
                lock (listLock)
                {
                    if (backgroundLinesList == null)
                    {
                        backgroundLinesList = new List<string>();
                    }
                    backgroundLinesList.Add(line);
                }
            }
            log.Debug("Stream closed");
        }
        catch (Exception e)
        {
            log.Debug("WebStream thread failure: " + e + " Stack: " + e.StackTrace);
        }
    }
}