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

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

connectivity_plus_ohos 插件允许 Flutter 应用程序在 OpenHarmony 上发现可用的网络连接类型。

依赖安装

在 pubspec.yaml 文件中添加以下依赖项：

dependencies:
  connectivity_plus: 5.0.2
  connectivity_plus_ohos: any

在项目的 module.json5 文件中增加以下权限设置：

{
  "requestPermissions": [
    {"name": "ohos.permission.INTERNET"},
    {"name": "ohos.permission.GET_NETWORK_INFO"}
  ]
}

完整示例

以下是使用 connectivity_plus_ohos 的完整示例代码：

// Copyright 2017 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

// ignore_for_file: public_member_api_docs

import 'dart:async';
import 'dart:developer' as developer;

import 'package:connectivity_plus/connectivity_plus.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';

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

class MyApp extends StatelessWidget {
  const MyApp({Key? key}) : super(key: key);

  // 这个小部件是你的应用程序的根。
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Demo',
      theme: ThemeData(
        useMaterial3: true,
        colorSchemeSeed: const Color(0x9f4376f8),
      ),
      home: const MyHomePage(title: 'Flutter Demo Home Page'),
    );
  }
}

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

  final String title;

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

class _MyHomePageState extends State<MyHomePage> {
  ConnectivityResult _connectionStatus = ConnectivityResult.none;
  final Connectivity _connectivity = Connectivity();
  late StreamSubscription<ConnectivityResult> _connectivitySubscription;

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

    _connectivitySubscription =
        _connectivity.onConnectivityChanged.listen(_updateConnectionStatus);
  }

  [@override](/user/override)
  void dispose() {
    _connectivitySubscription.cancel();
    super.dispose();
  }

  // 平台消息是异步的，因此我们在一个异步方法中初始化。
  Future<void> initConnectivity() async {
    late ConnectivityResult result;
    // 平台消息可能失败，所以我们使用带有 PlatformException 的 try/catch。
    try {
      result = await _connectivity.checkConnectivity();
    } on PlatformException catch (e) {
      developer.log('无法检查连接状态', error: e);
      return;
    }

    // 如果小部件在异步平台消息还在进行时从树中移除，
    // 我们希望丢弃回复而不是调用 setState 来更新我们的非存在外观。
    if (!mounted) {
      return Future.value(null);
    }

    return _updateConnectionStatus(result);
  }

  Future<void> _updateConnectionStatus(ConnectivityResult result) async {
    setState(() {
      _connectionStatus = result;
    });
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: const Text('Connectivity 示例应用'),
        elevation: 4,
      ),
      body: Center(
        child: Text('连接状态: ${_connectionStatus.toString()}'),
      ),
    );
  }
}