如何在Flutter应用程序中使用Socket？

Question

我创建了一个Flutter应用程序，需要将其连接到本地网络套接字服务。如下所示，我可以使用telnet连接，发送数据并从服务器接收数据。我使用Flutter web_socket插件和示例。我可以连接到服务器并发送数据，但无法捕获（或获取数据，它不显示任何内容）。在Flutter谷歌组中，有人建议我使用流而不是StreamBuilder。

To send data I use;         Q101:_:49785:_:ABCDE
And receive data I get;     1:_:2:_:119351:_:NİYAZİ TOROS 

当我使用这个示例(https://flutter.io/cookbook/networking/web-sockets/)时，我的socket服务出现错误：

Q: 28.06.2018 08:53:57->GET / HTTP/1.1
A: 28.06.2018 08:53:57 ->:1:_:1:_:FAIL1

例子：

Last login: Tue Jun 26 15:01:44 on ttys000
Niyazis-MBP:~ niyazitoros$ telnet
telnet> telnet 192.168.1.22 1024
Trying 192.168.1.22...
Connected to 192.168.1.22.
Escape character is '^]'.
Q101:_:49785:_:*************
1:_:2:_:119351:_:NİYAZİ TOROS

根据@Richard Heap的建议：

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

void connect(InternetAddress clientAddress, int port) {
  Future.wait([RawDatagramSocket.bind(InternetAddress.anyIPv4, 0)]).then(
      (values) {
    RawDatagramSocket _socket = values[0];
    _socket.listen((RawSocketEvent e) {
      print(e);
      switch (e) {
        case RawSocketEvent.read:
          Datagram dg = _socket.receive();
          if (dg != null) {
            dg.data.forEach((x) => print(x));
          }
          _socket.writeEventsEnabled = true;
          break;
        case RawSocketEvent.write:
          _socket.send(
              new Utf8Codec().encode('Hello from client'), clientAddress, port);
          break;
        case RawSocketEvent.closed:
          print('Client disconnected.');
      }
    });
  });
}

main(List<String> arguments) {
  print("Connecting to server..");
  var address = new InternetAddress('192.168.1.22');
  int port = 1024;
  connect(address, port);
}

我得到了这个：

/Users/niyazitoros/flutter/bin/cache/dart-sdk/bin/dart --enable-asserts --enable-vm-service:59683 /Users/niyazitoros/IdeaProjects/github/untitled/bin/main.dart
Observatory listening on http://127.0.0.1:59683/

Connecting to the server.
RawSocketEvent.write

- user9239214

Answer 1

正如attdona所提到的，

您的服务器不支持WebSocket协议，但是它公开了一个普通的TCP套接字。

因此，您需要一个TCP套接字，这里有一份很棒的关于Sockets和ServerSockets的教程，您可以在这里找到。

以下是一小段代码：

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

Socket socket;

void main() {
   Socket.connect("localhost", 4567).then((Socket sock) {
   socket = sock;
   socket.listen(dataHandler, 
      onError: errorHandler, 
      onDone: doneHandler, 
      cancelOnError: false);
   }).catchError((AsyncError e) {
      print("Unable to connect: $e");
   });
   //Connect standard in to the socket 
   stdin.listen((data) => socket.write(new String.fromCharCodes(data).trim() + '\n'));
}

void dataHandler(data){
   print(new String.fromCharCodes(data).trim());
}

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

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

- MahMoos

---

我已经点赞了这个，但是我会使用}).catchError((Object e) {来避免“Invalid argument (onError): Error handler must accept one Object...”的错误。 - Bob Hoeppner

Answer 2

您的服务器不支持Websocket协议，但它暴露了一个纯TCP socket。

这是一个使用纯TCP socket的示例，改编自https://flutter.io/cookbook/networking/web-sockets中的Flutter cookbook示例:

import 'package:flutter/foundation.dart';
import 'dart:io';
import 'package:flutter/material.dart';

void main() async {
  // modify with your true address/port
  Socket sock = await Socket.connect('192.168.1.129', 10000);
  runApp(MyApp(sock));
}

class MyApp extends StatelessWidget {
  Socket socket;

  MyApp(Socket s) {
    this.socket = s;
  }

  @override
  Widget build(BuildContext context) {
    final title = 'TcpSocket Demo';
    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();
  }
}

- attdona

---

谢谢attdona。不幸的是，它不能使用我的本地IP。但是，使用Socket sock = await Socket.connect('52.88.68.92', 1234)可以工作。此外，在这一行中有一个绿色的卷曲线。当我将鼠标悬停在其上时，它会显示“关闭dart.core.Sink的实例”。我不明白为什么不能使用我的本地IP？当我使用我的macOS并使用telnet时，它可以使用192.168.1.22。 - user9239214

我使用：print（'发送中...'）; --- widget.channel.write（_controller.text）; --- await new Future.delayed(new Duration(seconds: 5)); ---- print（'已发送！！！'）; 在控制台中，我可以看到我连接到我的网络为“已连接”，我可以看到“发送中”和“已发送”，但是当我查看我的套接字服务时，什么也没有显示... - user9239214

我已经使用真实的安卓设备进行了测试，它可以正常工作。你是在使用模拟器吗？ - attdona

是的，在模拟器和真实设备上都不起作用。当我将我的套接字监听器允许在DMZ上并提供了一个真实的IP地址后，我可以从互联网连接。套接字在Aqueduct中是否也能工作，还是我需要去找其他地方？ - user9239214

我发现在socket.write('Q101::49785::x\r\n')中需要返回\r\n，但是我无法获取信息。在socket监听中如何获取文本或字符串。 - user9239214

Answer 3

Socket.connect(localhost, port).then((socket){
            print('socket $socket');
            socket.listen((Data){
              print(new Code().decode(Data));
            });
          });

- Mohammed Sajeer ck