Flutter应用重新登录后LocationStream位置流不工作问题

问题根因 #

• 代码拼写错误：位置监听的订阅变量命名为listen，原dispose方法中误调用不存在的listener.cancel()，既无法正确取消订阅，还会在登出时抛出运行时异常
• 生命周期绑定错误：单例构造函数仅在应用首次启动时执行一次，原本写在构造函数里的监听注册逻辑，在登出取消监听后没有公开入口可以重新触发，重登时仅读取流无法重建监听链路
• 隐含逻辑隐患：如果原dispose方法中同时关闭了广播StreamController，即使后续重建监听，也无法向已关闭的流Sink添加数据，直接抛出状态异常

修复实现 #

核心原则：单例仅维护全局唯一的流实例，将定位监听的注册、销毁逻辑从构造函数剥离，通过公开方法和登录/登出状态绑定，不要在构造函数中耦合用户态相关的业务逻辑。

重构LocationService单例 #

import 'package:location/location.dart';
import 'dart:async';

class UserLocation {
  final double latitude;
  final double longitude;
  final double? accuracy;
  final DateTime? timestamp;
  UserLocation({
    required this.latitude,
    required this.longitude,
    this.accuracy,
    this.timestamp
  });
}

class LocationService {
  static final LocationService _instance = LocationService._internal();
  factory LocationService() => _instance;
  // 私有构造函数仅初始化流控制器，不启动定位逻辑
  LocationService._internal() {
    _locationStreamController = StreamController<UserLocation>.broadcast();
  }

  final Location _location = Location();
  late final StreamController<UserLocation> _locationStreamController;
  // 统一命名监听订阅变量，避免拼写错误
  StreamSubscription<LocationData>? _locationListen;

  // 对外暴露的广播位置流
  Stream<UserLocation> get locationStream => _locationStreamController.stream;

  /// 启动位置采集服务，可重复调用
  Future<void> startLocationService() async {
    // 存在活跃监听时先取消，避免重复订阅导致重复上报
    await _locationListen?.cancel();

    // 校验位置服务开关
    bool serviceEnabled = await _location.serviceEnabled();
    if (!serviceEnabled) {
      serviceEnabled = await _location.requestService();
      if (!serviceEnabled) return;
    }

    // 校验定位权限
    PermissionStatus permissionStatus = await _location.hasPermission();
    if (permissionStatus == PermissionStatus.denied) {
      permissionStatus = await _location.requestPermission();
      if (permissionStatus != PermissionStatus.granted) return;
    }

    // 配置定位参数
    await _location.changeSettings(
      accuracy: LocationAccuracy.high,
      interval: 10000,
      distanceFilter: 10,
    );
    // 开启后台定位（根据业务需求配置）
    await _location.enableBackgroundMode(enable: true);

    // 注册位置变化监听
    _locationListen = _location.onLocationChanged.listen((LocationData data) {
      if (data.latitude == null || data.longitude == null) return;
      final location = UserLocation(
        latitude: data.latitude!,
        longitude: data.longitude!,
        accuracy: data.accuracy,
        timestamp: data.time != null 
          ? DateTime.fromMillisecondsSinceEpoch(data.time!.toInt()) 
          : null
      );
      // 流未关闭时才推送数据
      if (!_locationStreamController.isClosed) {
        _locationStreamController.add(location);
      }
    });
  }

  /// 停止位置采集服务
  Future<void> stopLocationService() async {
    // 正确取消订阅，修正原拼写问题
    await _locationListen?.cancel();
    _locationListen = null;
    // 关闭后台定位
    await _location.enableBackgroundMode(enable: false);
    // *禁止关闭StreamController*，否则后续无法复用流推送数据
  }
}

绑定状态触发服务启停 #

• 应用启动阶段：不要在main函数中提前启动位置服务，未登录状态下采集位置属于无意义的资源消耗，还会提前触发权限申请影响用户体验
• 登录成功后：先调用LocationService().startLocationService()，再监听locationStream执行后端上报逻辑
• 触发登出时：先调用LocationService().stopLocationService()，取消上报逻辑的流订阅，再执行登出接口调用、跳转登录页的逻辑
• 应用生命周期切换：如果业务要求后台不需要上报位置，可在AppLifecycleState.paused状态下调用停止方法，回到AppLifecycleState.resumed且用户处于登录态时重新调用启动方法

注意事项 #

• 单例生命周期和应用进程一致，不要在构造函数中耦合和用户登录态绑定的逻辑
• 广播StreamController一旦关闭无法恢复，服务启停过程中只处理监听订阅，不要随意关闭流控制器
• 重复调用启动方法时必须先取消旧订阅，否则会出现多个监听同时生效、位置重复上报的问题
• 所有订阅对象取消前先判空，避免空指针异常

内容的提问来源于stack exchange，提问作者Iman