使用 Dart WebSocket 服务器支持 WebSocket 关闭原因
Support WebSocket close reason with a Dart WebSocket server
我正在使用 Dart 的 WebSocket classes(dart:io 和 dart:html 版本)连接到 Dart WebSocket 服务器。当我让客户端使用自定义关闭代码和原因关闭 Web 套接字连接时,自定义代码设置正确但自定义关闭原因不正确。
这是一个简化的测试用例:
server.dart
library server;
import 'dart:io';
main() async {
HttpServer server = await HttpServer.bind('localhost', 8081);
server
.transform(new WebSocketTransformer())
.listen((WebSocket webSocket) {
print('WebSocket opened.');
webSocket.listen((_) {}, onDone: () {
print('WebSocket closed.');
});
});
print('Listening..');
}
test.dart
library test;
import 'dart:io';
main() async {
WebSocket webSocket1 = await WebSocket.connect('ws://localhost:8081');
webSocket1.listen((_) {}, onDone: () {
print('Local Dart ws connection: closed with\n\t' +
'code: ${webSocket1.closeCode}\n\t' +
'reason: ${webSocket1.closeReason}');
});
webSocket1.close(4001, 'Custom close reason.');
WebSocket webSocket2 = await WebSocket.connect('ws://echo.websocket.org');
webSocket2.listen((_) {}, onDone: () {
print('echo.websocket.org connection: closed with\n\t' +
'code: ${webSocket2.closeCode}\n\t' +
'reason: ${webSocket2.closeReason}');
});
webSocket2.close(4001, 'Custom close reason.');
}
标准输出
Local Dart ws connection: closed with
code: 4001
reason:
echo.websocket.org connection: closed with
code: 4001
reason: Custom close reason.
第一个网络套接字(连接到本地 Dart 服务器的那个)连接并关闭,但缺少关闭原因(空字符串)。第二个网络套接字(连接到 echo.websocket.org 的那个)连接并关闭,关闭代码和原因都设置正确。
这不可能是客户端连接方式的问题,因为这两种情况都是相同的。那么我设置 Dart WebSocket 的方式有问题吗?还是 WebSocketTransformer/WebSocket class 中的错误?
已通过添加 dart-lang/sdk 解决此问题:https://github.com/dart-lang/sdk/issues/23964
我正在使用 Dart 的 WebSocket classes(dart:io 和 dart:html 版本)连接到 Dart WebSocket 服务器。当我让客户端使用自定义关闭代码和原因关闭 Web 套接字连接时,自定义代码设置正确但自定义关闭原因不正确。
这是一个简化的测试用例:
server.dart
library server;
import 'dart:io';
main() async {
HttpServer server = await HttpServer.bind('localhost', 8081);
server
.transform(new WebSocketTransformer())
.listen((WebSocket webSocket) {
print('WebSocket opened.');
webSocket.listen((_) {}, onDone: () {
print('WebSocket closed.');
});
});
print('Listening..');
}
test.dart
library test;
import 'dart:io';
main() async {
WebSocket webSocket1 = await WebSocket.connect('ws://localhost:8081');
webSocket1.listen((_) {}, onDone: () {
print('Local Dart ws connection: closed with\n\t' +
'code: ${webSocket1.closeCode}\n\t' +
'reason: ${webSocket1.closeReason}');
});
webSocket1.close(4001, 'Custom close reason.');
WebSocket webSocket2 = await WebSocket.connect('ws://echo.websocket.org');
webSocket2.listen((_) {}, onDone: () {
print('echo.websocket.org connection: closed with\n\t' +
'code: ${webSocket2.closeCode}\n\t' +
'reason: ${webSocket2.closeReason}');
});
webSocket2.close(4001, 'Custom close reason.');
}
标准输出
Local Dart ws connection: closed with
code: 4001
reason:
echo.websocket.org connection: closed with
code: 4001
reason: Custom close reason.
第一个网络套接字(连接到本地 Dart 服务器的那个)连接并关闭,但缺少关闭原因(空字符串)。第二个网络套接字(连接到 echo.websocket.org 的那个)连接并关闭,关闭代码和原因都设置正确。
这不可能是客户端连接方式的问题,因为这两种情况都是相同的。那么我设置 Dart WebSocket 的方式有问题吗?还是 WebSocketTransformer/WebSocket class 中的错误?
已通过添加 dart-lang/sdk 解决此问题:https://github.com/dart-lang/sdk/issues/23964