如何使用颤振将文件发送到 node.js 服务器？

Question

我正在使用socket_io_client 包与nodejs 套接字服务器进行通信。 这是我的颤振套接字配置：

socket = IO.io(SocketUrl.url, <String, dynamic>{
      'transports': ["websocket"],
      "autoConnect": false
    });
    socket.connect();
    socket.on('connect', (_) {
      print('socket connected to server');
    });
    socket.on('newMessage', (message) {
      print(message);
    });
    socket.on('event', (data) => print(data));
    socket.on('disconnect', (_) => print('disconnect'));
  }

这是文件发送的逻辑：

const data = {
            userId: currentUser.id,
            file: file.name
          };
          const stream = ss.createStream();
          ss(socket).emit("send-file", stream, data);
          ss.createBlobReadStream(file).pipe(stream);

这是从节点客户端完成的。我需要编写上述代码的飞镖版本。我看到 quiver 包具有创建流缓冲区的异步函数，但我不知道如何为这个特定的应用程序实现它。

已编辑：

 void onSendFile(file, data) async {
    final isFile = File(file);
    var buffer = isFile.openRead();
    //socket.emit("send-file",[buffer,data]);
    socket.emitWithBinary("send-file", [buffer, data]);
  }

Answer 1

阅读socket_io_client 的repo 上的API 参考和问题，您应该能够使用socket.emitWithBinary 发送二进制文件。

假设您已经有办法获得File，您很可能能够做到这一点

final myFile = File('file.txt');
final bytes = await myFile.readAsBytes();

socket.emitWithBinary('send-file', bytes);

更新

从 JS 版本的 socket-io 客户端，emit 函数可以接受多个参数，最终是converted to an array，所以我假设你可以通过将数组传递给emitWithBinary 或emit

注意

看到您的 JS 版本不包含任何 binary 标志，您可能想尝试使用 emit。

socket.emit(
  'send-file',
  [
    123,
    {
      'userId': currentUser.id,
      'file': file.name,
    },
  ],
);

Answer 2

你可以使用包https://pub.dev/packages/web_socket_channel
查看官方示例https://flutter.dev/docs/cookbook/networking/web-sockets
将文件转换为字节并接收到流中

final bytes = await myFile.readAsBytes();

main() async {
  var channel = IOWebSocketChannel.connect("ws://localhost:1234");
  channel.stream.listen((message) {
    channel.sink.add(bytes);
    channel.sink.close(status.goingAway);
  });
}