Flutter TCP Socket通信插件tcp_socket_flutter的使用

简介

这是一个允许你通过网络连接到Socket的Flutter插件。所有数据都使用UTF-8进行读取。

设置

配置

TCPSocketSetUp.setConfig(
  const SocketConfig(
    port: 8000,
    numberSplit: 10000,
    timeoutEachTimesSendData: Duration(milliseconds: 50),
  ),
);

初始化设备信息

await TCPSocketSetUp.init();

服务器端

final TCPSocketServer _server = TCPSocketServer();
final result = await _server.initServer(
  onData: (ip, sourcePort, event) {
    print('Server receive data from: $ip:$sourcePort');
    print('Server receive data: $event');
  },
  onDone: (ip, sourcePort) {},
  onError: (error, ip, sourcePort) {},
);
print(result);

服务器发送数据

await _server.sendData(
  FormDataSending(
    type: 'Server send info',
    data: getRandomString(1000000),
  ),
);

客户端

final TCPSocketClient _client = TCPSocketClient();
final result = await _client.connectToServer(
  '192.168.0.101',
  onData: (event) {
    print('Client receive data: $event');
  },
  onDone: () {},
  onError: (error) {},
);
print('Connect to server $result');

客户端发送数据

await _client.sendData(
  FormDataSending(
    type: 'Client send info',
    data: getRandomString(1000000),
  ),
);

许可证和贡献者

• 使用MIT许可证，详情见 LICENSE。
• 贡献者列表见 AUTHORS。

示例代码

以下是完整的示例代码：

import 'dart:math';

import 'package:flutter/material.dart';
import 'package:tcp_socket_flutter/tcp_socket_flutter.dart';

void main() {
  runApp(const MyApp());
}

class MyApp extends StatelessWidget {
  const MyApp({super.key});

  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Demo',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: const MyHomePage(title: 'Flutter Demo Home Page'),
    );
  }
}

class MyHomePage extends StatefulWidget {
  const MyHomePage({super.key, required this.title});

  final String title;

  [@override](/user/override)
  State<MyHomePage> createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  final TCPSocketServer _server = TCPSocketServer();
  final TCPSocketClient _client = TCPSocketClient();

  final _chars = 'AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsTtUuVvWwXxYyZz1234567890';
  final Random _rnd = Random();

  String getRandomString(int length) => String.fromCharCodes(Iterable.generate(
      length, (_) => _chars.codeUnitAt(_rnd.nextInt(_chars.length))));

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text(widget.title),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: [
            MaterialButton(
              color: Colors.blue,
              onPressed: () async {
                TCPSocketSetUp.setConfig(
                  const SocketConfig(
                    port: 8000,
                    numberSplit: 10000,
                    timeoutEachTimesSendData: Duration(milliseconds: 50),
                  ),
                );
                print(TCPSocketSetUp.config.toJson());
              },
              child: const Text('设置端口为8000'),
            ),
            const SizedBox(
              height: 20,
            ),
            MaterialButton(
              color: Colors.blue,
              onPressed: () async {
                await TCPSocketSetUp.init();
                print('获取设备信息完成');
              },
              child: const Text('获取IP信息'),
            ),
            const SizedBox(
              height: 20,
            ),
            const Text('服务器 ------------'),
            const SizedBox(
              height: 20,
            ),
            MaterialButton(
              color: Colors.blue,
              onPressed: () async {
                final result = await _server.initServer(
                  onData: (ip, sourcePort, event) {
                    print('服务器接收数据来自: $ip:$sourcePort');
                    print('服务器接收数据: $event');
                  },
                  onDone: (ip, sourcePort) {},
                  onError: (error, ip, sourcePort) {},
                );
                print(result);
                print('启动服务器成功');
              },
              child: const Text('启动服务器'),
            ),
            MaterialButton(
              color: Colors.blue,
              onPressed: () async {
                await _server.sendData(
                  FormDataSending(
                    type: '服务器发送信息',
                    data: getRandomString(1000000),
                  ),
                );
              },
              child: const Text('服务器发送数据'),
            ),
            const SizedBox(
              height: 20,
            ),
            const Text('客户端 ------------'),
            const SizedBox(
              height: 20,
            ),
            MaterialButton(
              color: Colors.blue,
              onPressed: () async {
                final result = await _client.connectToServer(
                  '192.168.0.101',
                  onData: (event) {
                    print('客户端接收数据: $event');
                  },
                  onDone: () {},
                  onError: (error) {},
                );
                print('连接到服务器 $result');
              },
              child: const Text('连接到服务器'),
            ),
            const SizedBox(
              height: 20,
            ),
            MaterialButton(
              color: Colors.blue,
              onPressed: () async {
                await _client.sendData(
                  FormDataSending(
                    type: '客户端发送信息',
                    data: getRandomString(1000000),
                  ),
                );
              },
              child: const Text('客户端发送数据'),
            ),
          ],
        ),
      ),
    );
  }
}