Flutter网络连接检测插件wma_connectivity的使用

wma_connectivity 插件结合了不同的网络事件源，并尝试通过加权移动平均法来估计设备的连接状态。

开始使用

以下是一个简单的示例代码，展示了如何使用 wma_connectivity 插件：

class Conn extends StatefulWidget {
  const Conn({Key key}) : super(key: key);

  [@override](/user/override)
  _ConnState createState() => _ConnState();
}

class _ConnState extends State<Conn> {
  final wmaConnectivity = WmaConnectivity(
    sensors: [
      ApiSensor(
        uri: 'https://api.contoso.com/ping',
        interval: const Duration(seconds: 10),
        timeout: const Duration(seconds: 5),
      ),
      DnsSensor(
        hosts: [
          'cloudflare.com',
          'google.com',
          'microsoft.com',
        ],
        interval: const Duration(seconds: 10),
        timeout: const Duration(seconds: 3),
      )
    ],
    window: const Duration(seconds: 25),
  );

  [@override](/user/override)
  void dispose() {
    wmaConnectivity.dispose(); // 记住，在不再需要时要释放它
    super.dispose();
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return StreamBuilder<List<Connection>>(
      stream: wmaConnectivity.connections,
      builder: (context, snapshot) {
        if (!snapshot.hasData) {
          return Container();
        }
        final connections = snapshot.data;
        // 检查连接列表
        for (final conn in connections) {
          if (conn is DnsConnection && conn.connected) {
            // 对于DNS连接信息做些有趣的事情...
          } else if (conn is ApiConnection && conn.connected) {
            // 对于API连接信息做些更有趣的事情...
          }
        }
      }
    );
  }
}

在上面的代码中，我们创建了一个名为 Conn 的 StatefulWidget。在这个类中，我们初始化了 WmaConnectivity 实例，该实例使用了两个传感器：ApiSensor 和 DnsSensor。这些传感器会定期检查网络连接状态，并将结果传递给 StreamBuilder。StreamBuilder 会根据最新的数据构建 UI。

自定义传感器

如果你希望扩展库的功能，可以实现自己的 Sensor 接口。所有类型的库都经过了良好的文档化，因此你可以从现有的 ApiSensor 和 DnsSensor 实现中获取灵感。

SocketException

你可能会注意到有一个看似未使用的 SensorEventType 叫做 SocketExceptionSensorEventType。这是为了简化使用过程，因为大多数情况下你可能想要监听 SocketException 异常并将其加入到结果中。

如果你正在使用 dio 库，可以通过创建一个 Interceptor 并监听 SocketException 异常来实现这一点。然后将这些异常转换为 Stream<SensorEvent>。

例如：

import 'dart:io';

import 'package:dio/dio.dart';
import 'package:rxdart/rxdart.dart';
import 'package:wma_connectivity/wma_connectivity.dart';

class SocketExceptionInterceptor extends Interceptor implements Sensor {
  SocketExceptionInterceptor();

  // 这将是我们的事件流
  final _events = PublishSubject<SensorEvent>();

  [@override](/user/override)
  Future onError(DioError err) async {
    if (err.type == DioErrorType.DEFAULT) {
      final error = err.error;
      if (error is SocketException) {
        // 这里记录事件
        _events.add(SensorEvent.socketException());
      }
    }
    return super.onError(err);
  }

  [@override](/user/override)
  void dispose() {
    // 记得清理资源
    _events.close();
  }

  // 返回 PublishSubject
  [@override](/user/override)
  Stream<SensorEvent> get events => _events;

  // 使用已有的事件类型或自定义
  [@override](/user/override)
  SensorEventType get type => const SocketExceptionSensorEventType(); 
}