import 'dart:typed_data';
import 'package:flutter/foundation.dart';
import 'dart:io';
import 'package:flutter/material.dart';
void main() async {
Socket sock = await Socket.connect('192.168.1.150', 2662);
print('Connected to: ${sock.remoteAddress.address}:${sock.remotePort}');
runApp(MyApp(sock));
sock.listen(
(Uint8List data) {
final serverResponse = String.fromCharCodes(data);
print('Server: $serverResponse');
},
onError: (error) {
print(error);
sock.destroy();
},
onDone: () {
print('Server left.');
sock.destroy();
},
);
}
class MyApp extends StatelessWidget {
Socket socket;
MyApp(Socket s) {
this.socket = s;
s.listen(
(Uint8List data) {
final serverResponse = String.fromCharCodes(data);
print('Server: $serverResponse');
},
// handle errors
onError: (error) {
print(error);
s.destroy();
},
onDone: () {
print('Server left.');
s.destroy();
},
);
}
@override
Widget build(BuildContext context) {
final title = 'Example';
return MaterialApp(
title: title,
home: MyHomePage(
title: title,
channel: socket,
),
);
}
}
class MyHomePage extends StatefulWidget {
final String title;
final Socket channel;
MyHomePage({Key key, @required this.title, @required this.channel})
: super(key: key);
@override
_MyHomePageState createState() => _MyHomePageState();
}
class _MyHomePageState extends State<MyHomePage> {
TextEditingController _controller = TextEditingController();
@override
Widget build(BuildContext context) {
return Scaffold(
appBar: AppBar(
title: Text(widget.title),
),
body: Padding(
padding: const EdgeInsets.all(20.0),
child: Column(
crossAxisAlignment: CrossAxisAlignment.start,
children: <Widget>[
Form(
child: TextFormField(
controller: _controller,
decoration: InputDecoration(labelText: 'Send a message'),
),
),
StreamBuilder(
stream: widget.channel,
builder: (context, snapshot) {
return Padding(
padding: const EdgeInsets.symmetric(vertical: 24.0),
child: Text(snapshot.hasData
? '${String.fromCharCodes(snapshot.data)}'
: ''),
);
},
)
],
),
),
floatingActionButton: FloatingActionButton(
onPressed: _sendMessage,
tooltip: 'Send message',
child: Icon(Icons.send),
), // This trailing comma makes auto-formatting nicer for build methods.
);
}
void _sendMessage() {
if (_controller.text.isNotEmpty) {
widget.channel.write(_controller.text);
}
}
@override
void dispose() {
widget.channel.close();
super.dispose();
}
}
当我在模拟器上运行代码时,出现了以下错误:
" Debug service listening on ws://127.0.0.1:59871/2EzZsU03nwc=/ws Syncing files to device AOSP on IA Emulator..."
以及
"E/flutter (24126): [ERROR:flutter/lib/ui/ui_dart_state.cc(186)] Unhandled Exception: SocketException: OS Error: Connection timed out, errno = 110, address = 192.168.1.131, port = 51170"
我该如何解决这个问题?
谢谢。
socket.bind("tcp://127.0.0.1:5556")
的接收器。我使用socket = await Socket.connect('127.0.0.1', 5556);
连接了Flutter,但是当我使用socket.add(utf8.encode('hello'));
发送消息时,在其他程序中没有接收到任何内容。 - West