5

我在使用 Windows 8 UI 应用程序时遇到问题。我正在使用客户端-服务器通信,客户端需要一直检查新消息。所以我使用这样的代码,其中_socket是一个StreamSoket:

    private async static void MessageReceiver()
    {
        var dataReader = new DataReader(_socket.InputStream);
        dataReader.InputStreamOptions = InputStreamOptions.Partial;

        var stringHeader = await dataReader.LoadAsync(4);
        if (stringHeader != 0)
        {
            var bytes = new byte[4];
            dataReader.ReadBytes(bytes);
            var length = BitConverter.ToInt32(bytes, 0);

            var count = await dataReader.LoadAsync((uint) length);

            var result = dataReader.ReadString(count);

            ParseRequest(result);
        }

        dataReader.DetachStream();


        MessageReceiver();
    }

但是在第二个 LoadAsync 中,当我尝试读取字符串时,我有 ObjectDisposedException。你能帮我吗?我不知道为什么会抛出这样的异常。我也尝试过使用 DataReader.InputStream.ReadAsync(),但我也遇到了这样的问题。

4

2 回答 2

2

我知道这是一篇旧帖子,但由于我遇到了同样的问题并想通了,我想我会为遇到此问题的其他人发布解决方案。虽然我不会声称确切地知道这个问题的原因是什么,但由于我主要是一个 C++ 人,所以解决方案相当简单。

我修复它的方法是将 DataReader 声明为类成员,从而扩展它的范围

_socket= new StreamSocket();
_socket.Control.KeepAlive = true;
_socket.Control.NoDelay = true;
_socketReader = new DataReader(_socket.InputStream);
_socketReader.InputStreamOptions = InputStreamOptions.Partial;

我可能对 await 关键字的错误理解是调用基本上放在一个新线程上,并且函数的其余部分将在前一个线程上继续。由于 DataReader 是在本地声明的,一旦函数完成,它将超出范围,让等待线程处理已处理的对象。

如果有人想澄清这一点,将不胜感激。

于 2015-01-30T00:02:03.703 回答
1

Based of Alex Sorokoletov's last comment, my guess would be that the one of your important objects (probably the stream) would be disposed in the call to datareader.DetachStream();

于 2014-10-10T04:29:51.313 回答