javascript - Javascript - 当服务器发送大响应时,WebSocket 客户端未收到 onmessage 事件
问题描述
我正在创建基于 TcpClient 和 NetworkStream 与 Javascript 客户端通信的 .net websocket 服务器。握手后,客户端要求服务器执行特定操作,服务器生成响应 - 到目前为止,它是短 JSON 字符串被发送回客户端 - 它工作正常。
在我要求发送更大的字符串响应(即,具有 200k 和更多字节的 base64 编码图像)之后,客户端停止接收响应并且没有触发 onmessage 事件。如果我切换并发送简短的 json - 它再次正常工作。
当我发送大数据时:
当我发送简单数据时:
客户端我从所有不相关的东西中剥离了代码(行为保持不变)
try{
ws = new WebSocket("ws://127.0.0.1:8282");
ws.binaryType = "arraybuffer";
}
catch(err){
debugger;
document.getElementById("message").innerHTML = "Not Connected! " + err;
};
ws.onopen = function () {
var jsonRequest = '{"action" : "START_STREAM","timeout" : 20}';
ws.send("START_STREAM");
};
在服务器端,我在生成响应后隔离了代码(带有 base64 编码图像的纯字符串,我对其进行了测试并正确解码):
Byte[] frame = CreateFrameFromString(serverResponse);
networkStream.Write(frame, 0, frame.Count());
networkStream.Flush();
clientSocket.Close();
clientSocket = ServerListener.AcceptTcpClient();
networkStream = clientSocket.GetStream();
初始化服务器线程的代码:
ServerListener.Start();
clientSocket = ServerListener.AcceptTcpClient();
NetworkStream networkStream = clientSocket.GetStream();
while (true)
{
if (!networkStream.DataAvailable)
...regular loop/server stuff/handshake etc.
方法 CreateFrameFromString 如下。使用值 0-10 测试操作码,并且在所有情况下,行为都是相同的 - 在客户端没有捕获到响应。
private static byte[] CreateFrameFromString(string message, Opcode opcode = Opcode.Text)
{
var payload = Encoding.UTF8.GetBytes(message);
byte[] frame;
if (payload.Length < 126)
{
frame = new byte[1 /*op code*/ + 1 /*payload length*/ + payload.Length /*payload bytes*/];
frame[1] = (byte)payload.Length;
Array.Copy(payload, 0, frame, 2, payload.Length);
}
else if (payload.Length >= 126 && payload.Length <= 65535)
{
frame = new byte[1 /*op code*/ + 1 /*payload length option*/ + 2 /*payload length*/ + payload.Length /*payload bytes*/];
frame[1] = 126;
frame[2] = (byte)((payload.Length >> 8) & 255);
frame[3] = (byte)(payload.Length & 255);
Array.Copy(payload, 0, frame, 4, payload.Length);
}
else
{
frame = new byte[1 /*op code*/ + 1 /*payload length option*/ + 8 /*payload length*/ + payload.Length /*payload bytes*/];
frame[1] = 127; // <-- Indicates that payload length is in following 8 bytes.
frame[2] = (byte)((payload.Length >> 56) & 255);
frame[3] = (byte)((payload.Length >> 48) & 255);
frame[4] = (byte)((payload.Length >> 40) & 255);
frame[5] = (byte)((payload.Length >> 32) & 255);
frame[6] = (byte)((payload.Length >> 24) & 255);
frame[7] = (byte)((payload.Length >> 16) & 255);
frame[8] = (byte)((payload.Length >> 8) & 255);
frame[9] = (byte)(payload.Length & 255);
Array.Copy(payload, 0, frame, 10, payload.Length);
}
frame[0] = (byte)((byte)opcode | 0x80 /*FIN bit*/);
return frame;
}
我错过了什么 - 协议/缓冲区大小/等等?在测试时,我注意到我可以使用上述设置发送最多 4250 个字符的响应,无需修改。一旦我达到这个数字,响应就开始消失。
解决方案
经过大量故障排除后,我发现我必须以包的形式发送数据,而不是整体发送。我将响应分成块(50000 个字符)并逐个发送,而在客户端,我在 onmessage 事件中拾取碎片。发送完所有响应块后,我关闭了会话——这在客户端触发了从 base64 流创建图像。
推荐阅读
- angular - ng:找不到命令
- jquery - 从 jQuery 函数设置类/原型变量
- kubernetes - Kubernetes - 创建 configMap 和 secret 的最佳方式
- selenium - 如何将文本发送到 Linkedin 密码字段
- react-native - 如何将抽屉原生基地设置为正确的位置 - React Native
- html - Display DIV's like Bee hive
- c# - 如何在 PowerShell 中使用 envdte 从 ac# 获取函数?
- c# - 如何使用 c# 从 Google 下载全尺寸图片
- ios - ios FirebaseCoreDiagnostics 5.4.1 架构 x86_64 的未定义符号:“_OBJC_CLASS_$_GULAppEnvironmentUtil”
- shell - 如何从文件中重定向整个行模式。grep、awk、sed 等,