Flutter网络通信插件flutter_socket_plugin的使用

Flutter网络通信插件flutter_socket_plugin的使用

FlutterSocket 插件介绍

FlutterSocket 是一个跨平台的socket插件，目前实现了客户端的基本功能：创建、连接、发送、接收、断开等。

使用示例

下面是一个完整的示例代码，展示了如何使用flutter_socket_plugin进行网络通信。

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

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

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Socket',
      home: MyHomePage(),
      theme: ThemeData(
        primaryColor: Colors.lightGreen,
      ),
    );
  }
}

class MyHomePage extends StatefulWidget {
  @override
  _MyHomePageState createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  final FlutterSocket flutterSocket = FlutterSocket();

  void initSocket() async {
    // 初始化socket
    await flutterSocket.createSocket("192.168.8.120", 10007, timeout: 20);

    // 监听连接回调
    flutterSocket.connectListener((data) {
      print("connect listener data:$data");
    });

    // 监听错误回调
    flutterSocket.errorListener((data) {
      print("error listener data:$data");
    });

    // 监听接收回调
    flutterSocket.receiveListener((data) {
      print("receive listener data:$data");
      if (data != null) {
        receiveMessage = receiveMessage + "\n" + data;
      }
      setState(() {});
    });

    // 监听断开回调
    flutterSocket.disconnectListener((data) {
      print("disconnect listener data:$data");
    });
  }

  void sendText(String text) async {
    await flutterSocket.send(text);
  }

  void disconnect() async {
    await flutterSocket.tryDisconnect();
  }

  String receiveMessage = "";

  @override
  void initState() {
    super.initState();
    initSocket();
  }

  @override
  void dispose() {
    super.dispose();
    flutterSocket.close();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('Socket'),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: <Widget>[
            ElevatedButton(
              onPressed: () {
                sendText("Hello, Server!");
              },
              child: Text('Send Message'),
            ),
            ElevatedButton(
              onPressed: () {
                disconnect();
              },
              child: Text('Disconnect'),
            ),
          ],
        ),
      ),
    );
  }
}

步骤说明

1. 初始化socket:

   await flutterSocket.createSocket("192.168.8.120", 10007, timeout: 20);
   

   创建并初始化socket连接。

2. 监听连接事件:

   flutterSocket.connectListener((data) {
     print("connect listener data:$data");
   });
   

   监听连接事件，并打印接收到的数据。

3. 监听错误事件:

   flutterSocket.errorListener((data) {
     print("error listener data:$data");
   });
   

   监听错误事件并打印错误信息。

4. 监听接收事件:

   flutterSocket.receiveListener((data) {
     print("receive listener data:$data");
     if (data != null) {
       receiveMessage = receiveMessage + "\n" + data;
     }
     setState(() {});
   });
   

   监听接收事件并处理接收到的消息。

5. 监听断开事件:

   flutterSocket.disconnectListener((data) {
     print("disconnect listener data:$data");
   });
   

   监听断开事件并打印断开消息。

6. 发送消息:

   await flutterSocket.send(textEditingController.text);
   

   发送消息到服务器。

7. 断开连接:

   await flutterSocket.tryDisconnect();
   

   断开与服务器的连接。

示例代码

你可以找到完整的示例代码 在这里。

未来计划

FlutterSocket 目前支持基本的字符串消息发送和接收。未来会逐步改进其功能，如果条件允许的话。如果你有紧急需求，可以在基础上继续添加功能，使 FlutterSocket 的的功能更加完善。

版权和许可证

此项目完全开源，许可证为MIT。欢迎点赞。

特征和bug

请在 issue tracker 提交功能请求和bug报告。

Flutter技术和其他交流群

微信：dbzy_duzhao 扫描二维码👇: