我正在尝试实现 Facebook X_FACEBOOK_PLATFORM SASL 机制，以便我可以通过 XMPP 将 Facebook Chat 集成到我的应用程序中。
这是代码：
var ak = "my app id";
var sk = "access token";
var aps = "my app secret";
using (var client = new TcpClient())
{
client.Connect("chat.facebook.com", 5222);
using (var writer = new StreamWriter(client.GetStream())) using (var reader = new StreamReader(client.GetStream()))
{
// Write for the first time
writer.Write("<stream:stream xmlns=\"jabber:client\" xmlns:stream=\"http://etherx.jabber.org/streams\" version=\"1.0\" to=\"chat.facebook.com\"><auth xmlns=\"urn:ietf:params:xml:ns:xmpp-sasl\" mechanism=\"X-FACEBOOK-PLATFORM\" /></stream:stream>");
writer.Flush();
Thread.Sleep(500);
// I am pretty sure following works or at least it's not what causes the error
var challenge = Encoding.UTF8.GetString(Convert.FromBase64String(XElement.Parse(reader.ReadToEnd()).Elements().Last().Value)).Split('&').Select(s => s.Split('=')).ToDictionary(s => s[0], s => s[1]);
var response = new SortedDictionary<string, string>() { { "api_key", ak }, { "call_id", DateTime.Now.Ticks.ToString() }, { "method", challenge["method"] }, { "nonce", challenge["nonce"] }, { "session_key", sk }, { "v", "1.0" } };
var responseString1 = string.Format("{0}{1}", string.Join(string.Empty, response.Select(p => string.Format("{0}={1}", p.Key, p.Value)).ToArray()), aps);
byte[] hashedResponse1 = null;
using (var prov = new MD5CryptoServiceProvider()) hashedResponse1 = prov.ComputeHash(Encoding.UTF8.GetBytes(responseString1));
var builder = new StringBuilder();
foreach (var item in hashedResponse1) builder.Append(item.ToString("x2"));
var responseString2 = Convert.ToBase64String(Encoding.UTF8.GetBytes(string.Format("{0}&sig={1}", string.Join("&", response.Select(p => string.Format("{0}={1}", p.Key, p.Value)).ToArray()), builder.ToString().ToLower()))); ;
// Write for the second time
writer.Write(string.Format("<response xmlns=\"urn:ietf:params:xml:ns:xmpp-sasl\">{0}</response>", responseString2));
writer.Flush();
Thread.Sleep(500);
MessageBox.Show(reader.ReadToEnd());
}
}
我尽可能地缩短和缩小了代码，因为我认为我的 SASL 实现（无论它是否有效，我还没有机会测试它）不是导致错误的原因。
我收到以下异常：无法从传输连接中读取数据：已建立的连接被主机中的软件中止。10053 System.Net.Sockets.SocketError.ConnectionAborted
每次我client第二次尝试从 's 流中读取时都会发生这种情况。如您所见，我在这里暂停了一个线程，因此 Facebook 服务器有足够的时间来回答我，但是我之前使用了异步方法并且遇到了完全相同的事情，所以我决定先尝试同步。无论如何，实际的 SASL 机制实现确实不应该导致这种情况，因为如果我不尝试立即进行身份验证，但是我发送请求以查看服务器使用什么机制并在另一轮读写中选择该机制，它会失败，但是当我立即发送机制选择 XML 时，它会在我发送的任何一秒内工作并失败。
所以结论如下：我打开套接字连接，写入它，从中读取（第一次读取同时适用于同步和异步），第二次写入它并尝试第二次从中读取它总是在这里失败。显然，问题出在套接字连接本身。我尝试使用 newStreamReader进行第二次阅读，但无济于事。这是相当不愉快的，因为我真的很想NetworkStream用“已接收”事件或类似的东西来实现外观，Send(string data, Action<string> responseProcessor)以便在使用该流时获得一些安慰，并且我已经有了实现，但是在第二次阅读时它也失败了。
感谢您的建议。
编辑：这是 NetworkStream 上的外观代码。使用这种异步方法时也会发生同样的事情，但几个小时前它起作用了，但是对于第二个响应返回与第一个响应相同的字符串。我无法弄清楚我在此期间改变了什么以及如何改变。
public void Send(XElement fragment)
{
if (Sent != null) Sent(this, new XmppEventArgs(fragment));
byte[] buffer = new byte[1024];
AsyncCallback callback = null;
callback = (a) =>
{
var available = NetworkStream.EndRead(a);
if (available > 0)
{
StringBuilder.Append(Encoding.UTF8.GetString(buffer, 0, available));
NetworkStream.BeginRead(buffer, 0, buffer.Length, callback, buffer);
}
else
{
var args = new XmppEventArgs(XElement.Parse(StringBuilder.ToString()));
if (Received != null) Received(this, args);
StringBuilder = new StringBuilder();
// NetworkStream.BeginRead(buffer, 0, buffer.Length, callback, buffer);
}
};
NetworkStream.BeginRead(buffer, 0, buffer.Length, callback, buffer);
NetworkStreamWriter.Write(fragment);
NetworkStreamWriter.Flush();
}