gpt4 book ai didi

c# - UWP,如何从 StreamSocket 读取所有数据

转载 作者:太空狗 更新时间:2023-10-29 22:00:24 26 4
gpt4 key购买 nike

我正在尝试在 C# 中为 UWP 实现 XMPP 客户端,为了实现这一点,我使用 StreamSocket 进行 TCP 连接。

问题是对于握手和SASL auth,我需要服务器从客户端进行一系列“写入和读取”,并且我无法立即读取服务器发送的所有数据;我想删除延迟部分。

这是我的代码:

// Start handshake
await XmppWrite("<?xml version='1.0'?><stream:stream to='" + serverHostName.Domain + "' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams' version='1.0'>");
var responseStream = await XmppRead();

SaslPlain saslPlain = new SaslPlain(Username, Password);
responseStream = null;
String xml = null;
while (!saslPlain.IsCompleted && (xml = saslPlain.GetNextXml(responseStream)) != null)
{
await XmppWrite(xml);
responseStream = await XmppRead();
}
if (!saslPlain.IsSuccess) return;

// Request bind
await XmppWrite("<?xml version='1.0'?><stream:stream to='" + serverHostName.Domain + "' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams' version='1.0'>");
responseStream = await XmppRead();

// Bind
await XmppWrite("<iq id='" + GenerateId() + "' type='set'><bind xmlns='urn:ietf:params:xml:ns:xmpp-bind'/></iq>");
responseStream = await XmppRead();
if (responseStream.Jid == null) return;

Jid = responseStream.Jid;

// Open session
await XmppWrite("<iq id='" + GenerateId() + "' type='set'><session xmlns='urn:ietf:params:xml:ns:xmpp-session'/></iq>");
responseStream = await XmppRead();

XmppRead() 方法是这样的:

private async Task<XmppStream> XmppRead()
{
await Task.Delay(100); // Things don't works without this...
var x = await dataReader.LoadAsync(BUFFER_SIZE);
if (dataReader.UnconsumedBufferLength > 0)
{
Debug.WriteLine(x + ", " + dataReader.UnconsumedBufferLength);
var stream = new XmppStream(dataReader.ReadString(dataReader.UnconsumedBufferLength));
if (stream.IsError)
{
if (Error != null)
{
Error(this, new XmppClientEventArgs(stream));
}
throw new Exception(stream.Error);
}
return stream;
}
return new XmppStream();
}

所以,我认为问题在于我尝试在服务器完成发送所有数据之前读取,所以我只能读取部分消息。如何检查是否有其他数据没有阻塞?

谢谢。

最佳答案

(我正在搜索别的东西,看到了这个问题)

当您将 DataReader.InputOptions 设置为 Partial 时会发生什么?现在 LoadAsync (AFAICT) 不会返回它所有的 BUFFER_SIZE 字节。通过将输入流选项设置为部分,您将获得可用的任何内容。

DataReader 文档是 here和 InputStreamOptions 值为 here

关于c# - UWP,如何从 StreamSocket 读取所有数据,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34249739/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com