无法通过蓝牙从Flatter应用程序向Pycom板发送数据。为什么?

2024-06-26 00:22:04 发布

您现在位置:Python中文网/ 问答频道 /正文

我想要达到的目标

将数据从具有flutter_blue的颤振应用程序发送到具有连接的Pycom WiPyPycom Pytrack 2 board

问题

当我将测试数据从flatter应用程序发送到Pycom板时,Pycom代码中的write callback handler方法从未被调用。在我看来,Pycom代码似乎无法识别或收到我从Flatter应用程序向其发送和写入数据的通知。我不知道是什么原因造成的,也不知道问题在事件链中的何处。可能数据从一开始就没有成功发送,或者数据到达了,但是我的回调方法代码中有错误,它侦听Pycom板上的传入写入

颤振应用程序代码(发送方)

我使用Flatter_blue库编写了一个简单的蓝牙客户端:

import 'package:flutter_blue/flutter_blue.dart';

class BluetoothClient {
  Future<List<ScanResult>> scanForDevices() async {
    FlutterBlue flutterBlue = FlutterBlue.instance;

    var scanRes = <ScanResult>[];
    flutterBlue.scanResults.listen((scanResults) {
      for (ScanResult scanResult in scanResults) {
        scanRes.add(scanResult);
      }
    });

    await flutterBlue.startScan(timeout: Duration(seconds: 4));
    await flutterBlue.stopScan();

    scanRes = filterDuplicateResults(scanRes);
    sortScanResults(scanRes);

    printScanResults(scanRes);

    return scanRes;
  }

  List<ScanResult> filterDuplicateResults(List<ScanResult> scanResults) {
    var uniques = <ScanResult>[];

    for (var scanResult in scanResults) {
      var uniquesContain = scanResultsHave(uniques, scanResult);
      if (!uniquesContain) uniques.add(scanResult);
    }

    return uniques;
  }

  sortScanResults(List<ScanResult> scanResults) {
    scanResults.sort((a, b) => a.device.name.compareTo(b.device.name));
  }

  bool scanResultsHave(List<ScanResult> scanResults, ScanResult scanResult) {
    var index = scanResults
        .indexWhere((ScanResult sr) => sr.device.id == scanResult.device.id);
    return index >= 0;
  }

  Future<List<BluetoothService>> getServices(BluetoothDevice device) async {
    var services = await device.discoverServices();
    return services;
  }

  Future<List<BluetoothCharacteristic>> getCharacteristics(
      BluetoothDevice device) async {
    var services = await getServices(device);

    var characteristics = <BluetoothCharacteristic>[];
    for (var service in services)
      characteristics.addAll(service.characteristics);

    return characteristics;
  }

  List<BluetoothDevice> getDevicesFromResults(List<ScanResult> scanResults) {
    var devices = scanResults.map((scanResult) => scanResult.device).toList();
    return devices;
  }

  Future<BluetoothDeviceState> getDeviceState(BluetoothDevice device) async {
    var stateList = await device.state.toList();
    return stateList.first;
  }

  Future connect(BluetoothDevice device) async {
    var timeout = Duration(seconds: 10);
    var autoConnect = false;
    try {
      await device.connect(timeout: timeout, autoConnect: autoConnect);
    } catch (e) {
      print(e);
    }
  }

  printScanResults(List<ScanResult> scanResults) {
    for (var scanResult in scanResults) printScanResult(scanResult);
  }

  printScanResult(ScanResult scanResult) {
    print("==== BLUETOOTH DEVICE ====");
    print("Name: ${scanResult.device.name}");
    print("Local name: ${scanResult.advertisementData.localName}");
    print("Type: ${scanResult.device.type}");
    print("Id: ${scanResult.device.id}");
    print("Connectable: ${scanResult.advertisementData.connectable}");
    print("Power level: ${scanResult.advertisementData.txPowerLevel}");
    print(
        "Manufacturer data: ${scanResult.advertisementData.manufacturerData}");
    print("Service data: ${scanResult.advertisementData.serviceData}");
    print("==========================");
  }

  Future printDeviceInfo(BluetoothDevice device) async {
    try {
      var services = await getServices(device);
      var characteristics = await getCharacteristics(device);
      print("=== DEVICE INFO ===");
      for (var service in services) print(service);
      for (var characteristic in characteristics) print(characteristic);
      print("===================");
    } catch (e) {
      print(e);
    }
  }

  Future<BluetoothService> getWaterSwitchService(BluetoothDevice device) async {
    var services = await getServices(device);
    var service =
        services.firstWhere((serv) => serv.uuid.toString().startsWith("3"));
    return service;
  }

  BluetoothCharacteristic getWaterSwitchCharacteristic(
      BluetoothService service) {
    var characteristics = service.characteristics;
    var characteristic = characteristics
        .firstWhere((char) => char.uuid.toString().startsWith("3"));
    return characteristic;
  }

  bool writeAllowed(BluetoothCharacteristic characteristic) {
    var properties = characteristic.properties;
    return properties.write;
  }

  bool writeWithoutResponseAllowed(BluetoothCharacteristic characteristic) {
    var properties = characteristic.properties;
    return properties.writeWithoutResponse;
  }
}

一个测试页面,创建一些测试数据,并在连接到电路板后将其发送到电路板。它使用上面的Bluetooth客户端类与Pycom板通信:

import 'dart:convert';

import 'package:flutter/cupertino.dart';
import 'package:flutter/material.dart';
import 'package:flutter_blue/flutter_blue.dart';
import 'package:gustavsberg_waterswitch_mobile/clients/BluetoothClient.dart';
import 'package:gustavsberg_waterswitch_mobile/helpers/DeviceHelper.dart';
import 'package:gustavsberg_waterswitch_mobile/globals.dart' as globals;
import 'package:gustavsberg_waterswitch_mobile/widgets/Buttons/CustomIconButton.dart';
import 'package:gustavsberg_waterswitch_mobile/widgets/Buttons/CustomTextButton.dart';

class BluetoothTestPage extends StatefulWidget {
  @override
  _BluetoothTestPageState createState() => _BluetoothTestPageState();
}

class _BluetoothTestPageState extends State<BluetoothTestPage> {
  BluetoothClient bluetoothClient;
  List<BluetoothDevice> bluetoothDevices;
  ScrollController scrollController;

  @override
  void initState() {
    init();
    super.initState();
  }

  init() {
    scrollController = new ScrollController();
    bluetoothClient = new BluetoothClient();
    bluetoothDevices = [];
  }

  @override
  Widget build(BuildContext context) {
    DeviceHelper.readDisplayDimensions(context);
    return Scaffold(
      body: buildBody(),
    );
  }

  buildBody() {
    return Container(
      width: globals.displayWidth,
      height: globals.displayHeight,
      child: Stack(
        children: [buildControlsLayer()],
      ),
    );
  }

  buildControlsLayer() {
    return Container(
        child: Column(
      mainAxisAlignment: MainAxisAlignment.center,
      mainAxisSize: MainAxisSize.max,
      crossAxisAlignment: CrossAxisAlignment.stretch,
      children: [buildScanButton(), buildDeviceList()],
    ));
  }

  buildScanButton() {
    return Expanded(
      flex: 10,
      child: CustomTextButton(
        onPressed: onScanPressed,
        text: "Scan",
      ),
    );
  }

  onScanPressed() {
    clearDeviceList();
    scanDevices();
  }

  Future scanDevices() async {
    var scanResults = await bluetoothClient.scanForDevices();
    var devices = bluetoothClient.getDevicesFromResults(scanResults);
    setBluetoothDevices(devices);
  }

  setBluetoothDevices(List<BluetoothDevice> devices) {
    if (mounted)
      setState(() {
        bluetoothDevices = devices;
      });
    else
      bluetoothDevices = devices;
  }

  buildDeviceList() {
    return Expanded(
        flex: 100,
        child: Container(
          child: Scrollbar(
            controller: scrollController,
            child: ListView(
              controller: scrollController,
              children: buildDeviceButtons(),
            ),
          ),
        ));
  }

  List<Widget> buildDeviceButtons() {
    var deviceButtons = <Widget>[];
    for (var device in bluetoothDevices) {
      var deviceButton = buildDeviceButton(device);
      deviceButtons.add(deviceButton);
    }

    return deviceButtons;
  }

  Widget buildDeviceButton(BluetoothDevice device) {
    return Container(
      child: CustomIconButton(
        text: "${device.name}, ${device.id}",
        onTap: () {
          onDeviceButtonTap(device);
        },
        iconData: Icons.devices,
      ),
    );
  }

  Future onDeviceButtonTap(BluetoothDevice device) async {
    await bluetoothClient.connect(device);
    await runDeviceTests(device);
  }

  Future runDeviceTests(BluetoothDevice device) async {
    // Print device info
    bluetoothClient.printDeviceInfo(device);

    var service = await bluetoothClient.getWaterSwitchService(device);
    var characteristic = bluetoothClient.getWaterSwitchCharacteristic(service);
    print(service);
    print(characteristic);

    var testData = buildTestData();
    await writeDataWithoutResponseToCharacteristic(characteristic, testData);

    // Send test data to device
    // await writeToDevice(device, testData);
  }

  Future writeToDevice(BluetoothDevice device, List<int> data) async {
    var characteristics = await bluetoothClient.getCharacteristics(device);
    await writeDataToCharacteristics(characteristics, data);
  }

  Future writeDataToCharacteristics(
      List<BluetoothCharacteristic> characteristics, List<int> data) async {
    for (var characteristic in characteristics) {
      await writeDataWithoutResponseToCharacteristic(characteristic, data);
    }
  }

  Future writeDataToCharacteristic(
      BluetoothCharacteristic characteristic, List<int> data) async {
    if (!bluetoothClient.writeAllowed(characteristic)) return;

    try {
      await characteristic.write(data);
    } catch (e) {
      print(e);
    }
  }

  Future writeDataWithoutResponseToCharacteristic(
      BluetoothCharacteristic characteristic, List<int> data) async {
    if (!bluetoothClient.writeWithoutResponseAllowed(characteristic)) return;

    try {
      await characteristic.write(data, withoutResponse: true);
    } catch (e) {
      print(e);
    }
  }

  List<int> buildTestData() {
    var str = "Hello bluetooth space!";
    var bytes = utf8.encode(str);
    return bytes;
  }

  clearDeviceList() {
    setBluetoothDevices([]);
  }
}

Pycom板代码(接收器)

main.py:

from network import Bluetooth
import time

bluetooth = Bluetooth()
bluetooth.set_advertisement(name='LoPy', service_uuid=b'1234567890123456')

def char_handler(chr, data):
    print("char_handler called!!!")
    events, value = data
    if events & Bluetooth.CHAR_WRITE_EVENT:
        print("Write request with value = {}".format(value))
    else:
        print('Read request on char 1')

service = bluetooth.service(uuid=b'1234567890123456', isprimary=True)
service.start()

characteristic = service.characteristic(uuid=b'2234567890123456', permissions=14, properties=14, value=64)
characteristic.callback(trigger=Bluetooth.CHAR_WRITE_EVENT | Bluetooth.CHAR_READ_EVENT, handler=char_handler)

bluetooth.advertise(True)

while True:
    print("Listening...")
    time.sleep(3)

尽管从Flatter应用程序写入数据,但从未调用写入回调方法char_handler

到目前为止什么有效

我已确认设备已连接。我还确认,Flutter应用程序会写入我在Pycom代码中创建的服务和特征,以侦听传入的写入

问题:

为什么Pycom代码没有得到通知或运行write回调方法

谢谢


Tags: asyncreturnvardeviceservicefutureawaitlist