UWP c# 从 StreamSocket 读取 XML

Posted 2023-02-24

【中文标题】UWP c# 从 StreamSocket 读取 XML

【英文标题】：UWP c# read XML from StreamSocket

【发布时间】：2017-10-10 16:45:56

【问题描述】：

我正在尝试通过 TCP 网络套接字 (StreamSocket) 与 XMPP (Jabber) 服务器通信，并且我正在使用以下代码来读取服务器发送给我的内容：

StreamSocket tcpSocket;
StreamReader reader;
int BUFFER_SIZE = 4096;

// Connecting to a remote XMPP server ....

reader = new StreamReader(tcpSocket.InputStream.AsStreamForRead());
string result;
while (true)

    result = "";
    while (true)
    
        char[] buffer = new char[BUFFER_SIZE];
        await reader.ReadAsync(buffer, 0, BUFFER_SIZE);
        string data = new string(buffer);

        // Detecting if all elements in the buffer array got replaced => there is more to read
        if (data.IndexOf("\0") >= 0 || reader.EndOfStream)
        
            result + data.Substring(0, data.IndexOf("\0"));
            break;
        
        result += data;
       
    Debug.WriteLine(result);

我的代码适用于长度

有没有办法获取字符串的实际长度并依次读取？

【参考方案1】：

您已将 4096 设置为 BUFFER_SIZE，并将其设置为 StreamReader.ReadAsync 和 char 数组中的计数参数。当字符串包含超过 4096 个字符时，它将失败。

你应该可以得到 Stream 中的实际长度，我们可以使用Stream.Length 来获取 Stream 的字节长度。 Array 的最后一个字符是“\0”。当您创建 char 数组时，您应该能够将 Stream.Length 加 1 设置为 char 数组。

例如：

StreamSocket socket;
StreamSocket tcpSocket;
StreamReader reader;

reader = new StreamReader(tcpSocket.InputStream.AsStreamForRead());
var  BUFFER_SIZE=(int)(tcpSocket.InputStream.AsStreamForRead()).Length;
string result;
while (true)

    result = "";
    while (true)
    
        char[] buffer = new char[BUFFER_SIZE+1];
        await reader.ReadAsync(buffer, 0, BUFFER_SIZE);
        string data = new string(buffer);
        if (data.IndexOf("\0") >= 0 || reader.EndOfStream)
        
            result = data.Substring(0, data.IndexOf("\0"));
            break;
        
        result += data;
    
    Debug.WriteLine(result);

如果要读取从当前位置到流尾的所有字符，可以使用StreamReader.ReadToEnd或StreamReader.ReadToEndAsync方法。

【讨论】：

感谢您的帮助，但如果我使用 BUFFER_SIZE=(int)(tcpSocket.InputStream.AsStreamForRead()).Length;，我会收到 System.NotSupportedException：此流不支持 Length 属性，因为它不可搜索。如果我使用 await reader.readToEndAsync() 它不会返回任何东西 - 它只会等待

能不能通过tcpSocket.InputStream.AsStreamForRead()方法获取流？

是的，它返回一个流对象，但是Length对象对于它返回的这种流是不可用的。

【参考方案2】：

我终于想通了阅读长消息： 我必须使用 DataReader 和 DataWriter 而不是 StreamReader 和 StreamWriter。

/// <summary>
/// How many characters should get read at once max.
/// </summary>
private static readonly int BUFFER_SIZE = 4096;

private StreamSocket socket;
private DataReader dataReader;
private DataWriter dataWriter;

public string readNextString() 
    string result = "";
    readingCTS = new CancellationTokenSource();

    try 
        uint readCount = 0;

        // Read the first batch:
        Task < uint > t = dataReader.LoadAsync(BUFFER_SIZE).AsTask();
        t.Wait(readingCTS.Token);
        readCount = t.Result;

        if (dataReader == null) 
            return result;
        

        while (dataReader.UnconsumedBufferLength > 0) 
            result +=dataReader.ReadString(dataReader.UnconsumedBufferLength);
        

        // If there is still data left to read, continue until a timeout occurs or a close got requested:
        while (!readingCTS.IsCancellationRequested && readCount >= BUFFER_SIZE) 
            t = dataReader.LoadAsync(BUFFER_SIZE).AsTask();
            t.Wait(100, readingCTS.Token);
            readCount = t.Result;
            while (dataReader.UnconsumedBufferLength > 0) 
                result += dataReader.ReadString(dataReader.UnconsumedBufferLength);
            
        
    
    catch(AggregateException) 
    catch(NullReferenceException) 

    return result;