如何从 Dart 中的 Future 返回套接字数据？

Question

可能我将数据发送到服务器并使用以下代码在 ============ 行之间获取数据，即使是非常大的数据。这是我的实验，因为我需要一些中间解决方案，以便我可以将 Flutter 应用程序连接到 tcp 套接字。为此，我选择 auqeduct.io。今天来自 Gazi 的帮助我找到了在 ============ 行之间完成我的代码的解决方案。

因为我正在使用 auqeduct，他们的句柄函数看起来像这样。

@override
  Future<RequestOrResponse> handle(Request request) async {

因此，我尝试修改我的代码并使用 Future 将套接字数据作为字符串返回。我可以在 ============ 行之间使用下面的代码获取数据，但是我无法使用 Future _handle(String _request) 异步获取任何数据。

_socket.listen((data) 打印数据无法将数据分配给字符串，因此我无法返回字符串。

作品： print("(1) $_secureResponse");

不起作用： _secureResponse = new String.fromCharCodes(data).trim();

如果我不使用 Future 并将代码放在 main() 中，则一切正常。

在我的测试服务器中，我发送了一个“Hello World”，作为回报，我得到了“欢迎先生/女士”。

我的问题是：如何从 Dart 中的 Future 返回套接字数据？

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

Socket socket;
String _errorData;
String _secureResponse;

void main() async {

  var _test = await _handle("Hello World");
  print("Print _test: $_test");

}


Future<String> _handle(String _request) async {
  print("Future Starts Here");
  print("Request: $_request");
    _errorData = "Server_Error";
    if (_request != null) {
      print("Request has data");
      // =============================================================
      Socket _socket;
      await Socket.connect("192.168.22.120", 3000).then((Socket sock) {
        _socket = sock;
        _socket.listen((data) {
          print("Socket start to listen to database");
          // GET FROM SERVER *********************
          _secureResponse =  new String.fromCharCodes(data).trim();
          print("(1) $_secureResponse");
        }, onError: ((error, StackTrace trace) {
          _secureResponse = _errorData;
          print("(2) $_secureResponse");
        }), onDone: ((){
          _socket.destroy();
          exit(0);
        }), cancelOnError: false);
      }).then((_) {
        print("Socket sends data to database");
        // SENT TO SERVER ************************
        _socket.write('$_request\r\n');
      }).catchError((AsyncError e) {
        _secureResponse = _errorData;
        print("(3) $_secureResponse");
        exit(1);
      });
      // ==============================================================
    } else {
      _secureResponse = _errorData;
      print("(4) $_secureResponse");
    }
  print("(6) $_secureResponse");
  print("Future Ends Here");
  return _secureResponse;
}

结果：

1. 未来从这里开始
2. 请求：“你好世界”
3. 请求有数据 Socket 发送数据到数据库
4. (6)空。 ---预期回报“欢迎先生/女士”
5. 未来到此结束
6. Print_test: null ---预期回报“欢迎先生/女士”
7. socket开始监听数据库
8. (1) “欢迎先生/女士”

Answer 1

这可能会奏效。不过，我认为您应该阅读有关流/期货/异步/等待的信息。

Future<String> _handle(String _request) async {
  print("Future Starts Here");
  print("Request: $_request");
    _errorData = "Server_Error";
    if (_request != null) {
      print("Request has data");
      // =============================================================
      Socket _socket;
      await Socket.connect("192.168.22.120”, 3000).then((Socket sock) {
        _socket = sock;
      }).then((_) {
        print("Socket sends data to database");
        // SENT TO SERVER ************************
        _socket.write('$_request\r\n');
        return _socket.first;
      }).then((data) {
        print("Socket start to listen to database");
        // GET FROM SERVER *********************
        _secureResponse =  new String.fromCharCodes(data).trim();
        print("(1) $_secureResponse");
      }).catchError((AsyncError e) {
        _secureResponse = _errorData;
        print("(3) $_secureResponse");
        exit(1);
      });
      // ==============================================================
    } else {
      _secureResponse = _errorData;
      print("(4) $_secureResponse");
    }
  print("(6) $_secureResponse");
  print("Future Ends Here");
  return _secureResponse;
}