实施代理服务器

拉斐尔

我正在尝试使用Dart实现代理服务器:浏览器上运行的Web应用向本地运行的Dart服务器应用(代理服务器)发出请求,然后代理服务器向外部服务器发出请求。然后,我将CORS标头添加到将发送回客户端(Web应用程序)的响应中。

这是我实现代理服务器的方式:

import 'dart:io';
import 'dart:convert';

main() async {
  var server = await HttpServer.bind(InternetAddress.ANY_IP_V6, 8080);
  print('Server listening on port ${server.port}...');

  var client = 0;
  HttpClient proxy;
  await for (HttpRequest request in server) {
    print('Request received from client ${++client}.');

    // Adds CORS headers.
    request.response.headers.add('Access-Control-Allow-Origin', '*');

    proxy = new HttpClient()
      ..getUrl(Uri.parse('http://example.com/'))
          // Makes a request to the external server.
          .then((HttpClientRequest proxyRequest) => proxyRequest.close())

          // Sends the response to the web client.
          .then((HttpClientResponse proxyResponse) =>
              proxyResponse.transform(UTF8.decoder).listen((contents) =>
                request.response
                  ..write(contents)
                  ..close()
          ));

    print('Response sent to client $client.');
  }
}

在大多数情况下,这可以正常工作,但有时客户端仅会收到部分响应。我认为有时在完成执行request.response.close()之前就正在request.response.write(contents)执行,因此在完成内容写入之前就发送了响应。

有什么方法可以解决此问题,并且仅在写入内容后才发送响应?谢谢。

贡特·佐赫鲍尔(GünterZöchbauer)

收到第一个数据块(..close()后,关闭响应您应该从此处删除close()并侦听proxyResponse流的close事件,并从此处关闭响应。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章