asynchronous - Flutter 同步连接到多个 BLE 设备

Question

我正在使用 flutter 通过 flutterBlue 库开发蓝牙低功耗应用程序，我们可能会同时连接到多个外围设备。 如果我单独连接到多个外围设备并同时向所有外围设备发送命令，我就可以连接到它们。 对于状态管理，我的 BluetoothHelper 是我的 ScopedModel 的模型。

class BluetoothHelper extends Model {

  bool isProcessing = false; 
  int val = 0;

  FlutterBlue flutterBlue = FlutterBlue.instance; //bluetooth library instance

  StreamSubscription scanSubscription;
  Map<DeviceIdentifier, ScanResult> scanResults = new Map();

  /// State
  StreamSubscription stateSubscription;
  BluetoothState state = BluetoothState.unknown;

  /// Device
  List<BluetoothDevice> devicesList = new List(); //todo

  bool get isConnected => (deviceList.size != 0);
  StreamSubscription deviceConnection;
  StreamSubscription deviceStateSubscription;
  List<BluetoothService> services = new List();
  Map<Guid, StreamSubscription> valueChangedSubscriptions = {};
  BluetoothDeviceState deviceState = BluetoothDeviceState.disconnected;

  Future startScan(String uuid) async {
    isProcessing = true;
    if (val == 0) {
      Future.delayed(Duration(milliseconds: 25), () => scanAndConnect(uuid));
      val++;
    } else {
      Future.delayed(Duration(seconds: 4), () => scanAndConnect(uuid));
    }
  }

  scanAndConnect(String uuid){
    scanSubscription =
        flutterBlue.scan(timeout: const Duration(seconds: 120), withServices: [
          //new Guid('FB755D40-8DE5-481E-A369-21C0B3F39664')]
        ]).listen((scanResult) {
          if (scanResult.device.id.toString() == uuid) {
            scanResults[scanResult.device.id] = scanResult;

            print("found! Attempting to connect" + scanResult.device.id.toString());
            device = scanResult.device;

            //connect(device);
            connect(device);
          }
        }, onDone: stopScan);
  }

  Future connect(BluetoothDevice d) {

    deviceConnection = flutterBlue.connect(d).listen(
          null,
        );

    deviceStateSubscription = d.onStateChanged().listen((s) {
      if (s == BluetoothDeviceState.connected) {
        stopScan();
        d.discoverServices().then((s) {
          print("connected to ${device.id.toString()}");
          services = s;
          services.forEach((service) {
            var characteristics = service.characteristics;
            for (BluetoothCharacteristic c in characteristics) {
              if (c.uuid.toString() == '') {//we look for the uuid we want to write to
                String handshakeValue ; //value is initiliazed here in code
                List<int> bytes = utf8.encode(handshakeValue);
                d.writeCharacteristic(c, bytes,
                    type: CharacteristicWriteType.withResponse);
                     devicesList.add(d);
              }
            }
          });
        });
      }
    });

  }
}

我正在尝试循环抛出所有外设唯一标识符 (UID)，然后让它们以编程方式一个接一个地连接起来。

这不是很好。它总是会连接到最后一个外围设备。似乎 flutterblue 实例一次只能扫描一个 uid，如果它收到另一个请求，它会立即丢弃最后一个请求并移动到新请求。

我将相同的逻辑应用于单个外围设备逻辑的连接，我会立即点击一个外围设备和第二个外围设备，然后它会连接到第二个外围设备。 (在连接过程发生时，我目前没有阻止 UI 或任何东西) 我需要等到第一个外围设备连接好后才能移动到下一个外围设备。

上面的代码是我获得外围设备的唯一方法，但是这段代码存在很大的问题。它目前只能连接到 2 个设备。它使用延迟而不是回调来实现连接，方法是在移动到第二个外围设备之前为扫描和连接提供足够的时间。

我的第一直觉是将 startScan 和 connect 方法转换为异步方法，但这并不像我希望的那样有效。

{等待连接(设备)； } => 给出“内置标识符“await”不能用作类型。我可能只是错误地设置了异步。

我四处寻找替代品，我遇到了完成者和孤立者。我不确定这有多相关。

用户界面方面:

我为包装在作用域模型后代中的按钮的 ontap 设置了以下方法。这将可靠地加载带有几个 uid 的 peripheralUIDs 列表，然后一个接一个地连接到它们。

connectAllPeripherals(BluetoothHelper model, List<String> peripheralUIDs) {
    for(var uuid in peripheralUIDs) { //list of strings containing the uuids for the peripherals I want to connect to
      model.startScan(uuid);
    }
}

Answer 1

不知道这一点是否仍然是一个问题。

假设您的问题尚未得到解决。我认为您遇到的问题是试图在 Flutter 中维护连接(而不是仅仅连接多个设备并让 Flutter_Blue/硬件管理连接)。

我很高兴连接到多个设备；在您设置维护多个设备属性列表的实例之后。

即我制作了一个 ble-device 类，其中包含以下各项:

StreamSubscription deviceConnection;
StreamSubscription deviceStateSubscription;
List<BluetoothService> services = new List();
Map<Guid, StreamSubscription> valueChangedSubscriptions = {};
BluetoothDeviceState deviceState = BluetoothDeviceState.disconnected;

使用从上述类初始化的新对象为每个连接的设备维护一个 LinkedHashMap 效果很好。

除此之外 - Flutter_Blue 一次只允许 1 个并发请求调用(比如读取一个特征)，但是你可以很容易地堆叠它们

 await

通过上述，我能够在几毫秒内轮询多个设备。

不知道这是否有帮助 - 但运气好的话，遇到我的问题的人会解决这个问题并节省一些时间。