1

感谢来自 voidrealms 的 Bryan。过去 2 天（以及数周的研究）我一直在苦苦挣扎，现在我可以非常快地使用旧系统中的 dart tcp 套接字获取大数据。使用 dart 控制台应用程序的过程比 dart Future 项目快得多。

现在将飞镖控制台应用程序混合到渡槽未来应用程序的问题。在下面我把我的问题放在（********）之后。

如果我使用 Socket.connect("192 ..... 在 Future 内部，这个过程会很慢，有时会返回空响​​应。所以，我的问题是如何将渡槽 Future 与 dart 控制台应用程序合并。

aqueduct.io 部分

class NtmsApiController extends Controller {
  @override
  Future<RequestOrResponse> handle(Request request) async {
    try {
      if (request.path.remainingPath != null) {
        _requestValue = request.path.remainingPath;
           // (********) In here I need to add below code, how?
        }
      } else {
        _secureResponse = "$_errorData";
      }
    } catch (e) {
        _secureResponse = "$_errorData";
    }
    return new Response.ok("$_secureResponse")
      ..contentType = ContentType.json;
  }
}

飞镖控制台应用程序

import 'dart:io';
import 'dart:async';

Socket socket;
String _response;
String _requestedData;
Stopwatch _stopWatch;

void main() {

  _stopWatch = Stopwatch()..start();
  _response = "";
  _requestedData = "Q77:_:NBRT:_:6785417534\r\n";

  Socket.connect("192.168.22.120", 3000).then((Socket sock) {
    socket = sock;
    socket.write('$_requestedData\r\n');
    socket.listen(dataHandler,
        onError: errorHandler,
        onDone: doneHandler,
        cancelOnError: false);
  }).catchError((AsyncError e) {
    print("Unable to connect: $e");
  });
  print("_requestedData: $_requestedData");
}

void dataHandler(data){
  _response = new String.fromCharCodes(data).trim();
  _printResponse(_response);
}

void errorHandler(error, StackTrace trace){
  print(error);
}

void doneHandler(){
  socket.destroy();
}

void _printResponse(String _response) {
  // approximately I get 500 rows with 20 column data in 250ms
  print("$_response ... (${_stopWatch.elapsedMilliseconds} ms)");
  _stopWatch..stop();
  if(_stopWatch.isRunning == false) {
    socket.close();
    // (********)return response object to aqueduct Future request_response--- how?
  }
}
4

0 回答 0