如何 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;
}
结果:
- 未来从这里开始
- 请求:“Hello World”
- 请求有数据Socket向数据库发送数据
- (6) null. --- 预期 return "欢迎Sir/Madam
- 未来在这里结束
- Print_test: null --- 预期 return "欢迎Sir/Madam
- Socket 开始监听数据库
- (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;
}
我可能会使用下面的代码在 =========== 行之间将数据发送到服务器并取回数据,即使是非常大的数据。这是我的实验,因为我需要一些中间解决方案,以便我可以将我的 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;
}
结果:
- 未来从这里开始
- 请求:“Hello World”
- 请求有数据Socket向数据库发送数据
- (6) null. --- 预期 return "欢迎Sir/Madam
- 未来在这里结束
- Print_test: null --- 预期 return "欢迎Sir/Madam
- Socket 开始监听数据库
- (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;
}