better_socket_wrapper #

better_socket_wrapper 是一个用于在 Flutter 中实现 WebSocket 通信的插件。它封装了底层的 WebSocket 连接逻辑，并提供了更简洁的 API 来处理连接、消息接收和错误处理。

使用步骤 #

以下是一个完整的示例，展示如何使用 better_socket_wrapper 插件来实现 WebSocket 的连接、发送消息和关闭连接。

1. 添加依赖

在项目的 pubspec.yaml 文件中添加 better_socket_wrapper 依赖：

dependencies:
  better_socket_wrapper: ^版本号

然后运行以下命令安装依赖：

flutter pub get

2. 初始化 WebSocket 连接

首先，我们需要初始化 WebSocket 连接并设置监听器。

import 'dart:convert';
import 'dart:typed_data';

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

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

class MyApp extends StatefulWidget {
  [@override](/user/override)
  _MyAppState createState() => _MyAppState();
}

class _MyAppState extends State<MyApp> {
  String _platformVersion = 'Unknown';

  [@override](/user/override)
  void initState() {
    super.initState();
    initPlatformState();
  }

  // 初始化平台状态
  Future<void> initPlatformState() async {
    String platformVersion;
    try {
      platformVersion = (await BetterSocketWrapper.platformVersion)!;

      // 设置监听器
      BetterSocketWrapper.addListener(
        onOpen: (httpStatus, httpStatusMessage) {
          print("WebSocket 连接成功 --- httpStatus:$httpStatus  httpStatusMessage:$httpStatusMessage");
        },
        onMessage: (message) {
          print("接收到消息 --- message:$message");
        },
        onClose: (code, reason, remote) {
          print("WebSocket 关闭 --- code:$code  reason:$reason  remote:$remote");
        },
        onError: (message) {
          print("发生错误 --- message:$message");
        },
      );

      // 配置 HTTP 头部并连接 WebSocket
      var headers = {"origin": "wss://api.matrixone.io/coinsdata/api/MarketsList/"};
      BetterSocketWrapper.connentSocket(
        "wss://api.matrixone.io/coinsdata/api/MarketsList/",
        httpHeaders: headers,
        trustAllHost: true,
      );
    } on Exception catch (e) {
      platformVersion = '连接失败: $e';
    }

    if (!mounted) return;

    setState(() {
      _platformVersion = platformVersion;
    });
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: const Text('WebSocket 示例'),
        ),
        body: Center(
          child: Column(
            mainAxisAlignment: MainAxisAlignment.center,
            children: [
              Text('运行状态: $_platformVersion\n'),
              ElevatedButton(
                onPressed: () {
                  // 发送消息
                  var data = {"market": "USDT", "exchange": "BN"};
                  BetterSocketWrapper.sendByteMsg(Uint8List.fromList(jsonEncode(data).codeUnits));
                },
                child: Text('发送消息'),
              ),
              ElevatedButton(
                onPressed: () {
                  // 关闭 WebSocket 连接
                  BetterSocketWrapper.close();
                },
                child: Text('关闭连接'),
              ),
            ],
          ),
        ),
      ),
    );
  }

  [@override](/user/override)
  void dispose() {
    BetterSocketWrapper.close(); // 确保在组件销毁时关闭 WebSocket 连接
    super.dispose();
  }
}