Dart 放弃了处理HTTP服务器响应

学习Golang要努力，但是不要急！今天的这篇文章《Dart 放弃了处理HTTP服务器响应》将会介绍到等等知识点，如果你想深入学习Golang，可以关注我！我会持续更新相关文章的，希望对大家都能有所帮助！

我正在开发一个简单的 dart http 服务器，它必须返回流的值作为 http 响应。我想以块的形式发送流的数据，有人知道如何在 dart 中做到这一点吗？我之前在 go 中创建过一次应用程序，代码如下：

...
func(w http.responsewriter, r *http.request){
    flusher, ok := w.(http.flusher)

    w.header().set("connection", "keep-alive")
    w.header().set("access-control-allow-origin", "*")
    w.header().set("x-content-type-options", "nosniff")
    w.header().set("transfer-encoding", "chunked")
    w.header().set("content-type", "audio/mpeg")

    for (...) {
        w.write(b)
        flusher.flush()
    }
    
    ...
}
...

这是我到目前为止在 dart 中所拥有的，但是刷新功能并没有像我预期的那样工作：

final server = await HttpServer.bind(InternetAddress.anyIPv4, 8080);
    await for (var request in server) {
      final stream = await _audio.stream();
      final response = request.response;

      StreamSubscription? subscription;

      response.done.then((value) => subscription?.cancel());

      request.response
        ..headers.contentType = ContentType("audio", "mpeg")
        ..headers.add("Connection", "Keep-Alive")
        ..headers.add("Access-Control-Allow-Origin", "*")
        ..headers.add("X-Content-Type-Options", "nosniff")
        ..headers.add("Transfer-Encoding", "chunked");

      subscription = stream?.listen((event) {
        response.write(event);
        response.flush(); // Here
      });
    }

flush方法在调用时会抛出错误，即“bad state: streamsink is bond to a stream”。

正确答案

在 shel​​f 中，您当然可以在没有缓冲区的情况下进行流式传输，使用如下处理程序：

Future<Response> audioHandler(Request request) async {
  final stream = [await] getTheStream();

  return Response.ok(
    stream,
    headers: {
      'Cache-Control': 'no-store',
      'Content-Type': 'audio/whatever',
      // any other response headers
    },
    context: {
      'shelf.io.buffer_output': false,
    },
  );
}

本篇关于《Dart 放弃了处理HTTP服务器响应》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！