dart - 使用 Dart，如何使用 Future 正确返回 HttpResponse

Question

我正在尝试创建一个非常简单的 http 服务器，它只做一件事。收到 HttpRequest 后，它会在本地数据库服务器上运行查询，并根据该查询返回一个字符串。

我正在学习 Dart，但在掌握 Futures 方面遇到了困难。我以为我理解它们，但是这个例子让我相信我真的不知道它们是如何工作的。因此，我不仅要寻找解决此问题的方法，而且我也很乐意接受任何指示。

注意:这段代码是我一直在努力完成的一个非常原始的例子，为了接触 Stackoverflow 社区，我尽可能地缩短/简化它，同时保持问题完好无损。

这是我的 server.dart 代码

import 'dart:io';
import 'package:sqljocky/sqljocky.dart';


final connection = new ConnectionPool(host: 'localhost', port: 3306, user: 'root', password: null, db: 'server1');

main() {

  HttpServer.bind(InternetAddress.ANY_IP_V4, 9090)..then((server) {
    print("serving generic database query on localhost:9090");
    server.listen((request) {
      if (request.method == "GET") {
        request.response.write(getResults());
        request.response.close();
      }
      else {
        request.response.statusCode = HttpStatus.BAD_REQUEST;
      }
    });
  });
}


String getResults() {

  StringBuffer sb = new StringBuffer();
  sb.write("START--");
  connection.query("select name, email, zkey from users")
      ..then((results) {
    results.forEach((row) {
      sb.write(row.toString());
      print(row.toString());
    });
  });

  sb.write("--END");
  print(sb.toString());

  return sb.toString();
}

因此，如果我向该服务器发送请求，它会返回“START----END”。
服务器打印出预期的查询结果，然后打印出“START----END”。
这让我相信我的请求响应正在关闭并在查询结果处理完成之前返回。

因此，无论我 curl localhost:9090/asdf 还是实际构建客户端 http 请求发件人，我都没有得到我期望的响应......这是一个数据库查询结果。

提前致谢

Answer 1

那个"START----END"打印“乱序”是 future 的一种行为，大多数开发人员一开始都会感到困惑。
像connection.query()这样的电话返回 future 不会立即执行，而是被列入队列以供以后执行。当前执行的线程会继续执行，直到完成，然后依次处理队列。
在您的代码中不起作用的是您进行了异步调用 connection.query()并继续，就好像这是一个同步调用。这在 Dart 中是行不通的。当您开始异步执行时，您无法返回同步。 (据我所知，计划中的 async/await 应该可以解决这个问题)。

更多详情请访问 dartlang.org The Event Loop and Dart
编辑测试代码

import 'dart:io';
import 'package:sqljocky/sqljocky.dart';

final connection = new ConnectionPool(host: 'localhost', port: 3306, user: 'root', password: null, db: 'server1');

main() {    
  HttpServer.bind(InternetAddress.ANY_IP_V4, 9090)..then((server) {
    print("serving generic database query on localhost:9090");
    server.listen((request) {
      if (request.method == "GET") {
        getResults()
        .then((result) { 
          print('Result: $result'); 
          request.response.write(result);
          request.response.close();
        });
      }
      else {
        request.response.statusCode = HttpStatus.BAD_REQUEST;
      }
    });
  });
}

Future<String> getResults() { 

  StringBuffer sb = new StringBuffer();
  sb.write("START--");
  return connection.query("select name, email, zkey from users") 
  .then((Result results) => results.toList())
  .then((list) {
    list.forEach((row) {
      sb.write(row.toString());
    });
    sb.write("--END");
  })
  .then((_) => sb.toString());
}

另请参阅关于此问题的 Gregs 回答如何读取 SqlJocky 结果 sqljocky querying database synchronously