如何 return 从 Dart 中的 Future 套接字数据?

How to return socket data from Future in Dart?

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

因为我正在使用 auqeduct,所以它们的句柄函数如下所示。

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

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

获取任何数据

_socket.listen((data) 打印数据无法将数据分配给字符串,所以我不能 return 字符串。

有效: print("(1) $_secureResponse");

无效: _secureResponse = new String.fromCharCodes(data).trim();

如果我不使用 Future 并将代码放在 main() 中,一切都可以正常工作。

在我的测试服务器中,我发送了一个“Hello World”,在 return 中,我收到了“欢迎 Sir/Madam”。

我的问题是:如何在 Dart 中 return 从 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. 请求:“Hello World
  3. 请求有数据Socket向数据库发送数据
  4. (6) null. --- 预期 return "欢迎Sir/Madam
  5. 未来在这里结束
  6. Print_test: null --- 预期 return "欢迎Sir/Madam
  7. Socket 开始监听数据库
  8. (1)“欢迎Sir/Madam

这可能有效。不过,我认为您应该阅读有关 streams/futures/async/await 的内容。

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;
}