如何在Swift中通过CoreBluetooth实现OBD-II设备的持续读写控制？

我尝试通过持续执行读写请求，从车辆OBD-II总线获取实时数据，使用Swift的CoreBluetooth框架连接并与OBD-II BLE适配器通信。我的目标是：

• 用户处于LiveDataView()页面时，持续更新4个不同传感器的实时数据
• 用户离开该页面、应用进入后台或被关闭时，停止请求

尝试的方案1：利用peripheralIsReady(toSendWriteWithoutResponse) #

我首先尝试使用内置的无响应写入回调函数，该函数本应在适配器准备好接收写入请求时通知管理器：

func peripheralIsReady(toSendWriteWithoutResponse peripheral: CBPeripheral) {
    for item in commands {
        self.write(value: item, characteristic: self.obdSensorCharacteristic!)
        self.read(characteristic: self.obdSensorCharacteristic!)
        print("Sent item \(String(data:item, encoding:.utf8)!) to \(String(describing: obdSensorCharacteristic))\n in the new peripheralIsReady()!")
        
    }
}

问题：此方法无效，会向适配器发送大量写入请求，造成拥堵。

尝试的方案2：使用定时器 #

之后我尝试使用定时器，反复请求PID "0105"（发动机冷却液温度）时，调试控制台显示正常，但LiveDataView()中的发动机冷却液温度并未更新：

func peripheral(_ peripheral: CBPeripheral, didDiscoverCharacteristicsFor service: CBService, error: Error?) {
    for characteristic in service.characteristics ?? [] {
        if (String(describing: characteristic.uuid)) == "BEF8D6C9-9C21-4C9E-B632-BD58C1009F9F" {
            obdSensorCharacteristic = characteristic
            peripheral.setNotifyValue(true, for: characteristic)
            print("Found \(characteristic), waiting on values:")
            print("Characteristic Value: \(String(describing: characteristic.value))")
            
            if stopData {
                Timer.scheduledTimer(withTimeInterval: 1, repeats: true, block: { timer in
                    self.requestData()
                    
                    if self.stopData == false {
                        timer.invalidate()
                    }
                })
            }
        }
    }
}

func requestData() {
    if ((obdSensorPeripheral?.canSendWriteWithoutResponse) != nil && sendData) {

        if sendData {
            self.write(value: commands[0], characteristic: self.obdSensorCharacteristic!)
            self.read(characteristic: self.obdSensorCharacteristic!)
            
        }
    }
}

问题：控制台输出正常，但UI未更新；且定时器不是最优的持续读写方式。

提问 #

除了定时器，在CoreBluetooth中有没有更好的方式持续读写OBD-II BLE设备？有没有更优的外设特征读写控制方法？

1. 基于回调的串行请求机制（替代定时器） #

OBD-II BLE设备需要等待前一个请求的响应返回后，再发送下一个请求，避免总线拥堵。你可以维护一个请求队列，在didUpdateValueFor characteristic回调中处理完当前响应后，再发送队列中的下一个请求：

// 维护待发送的命令队列
private var commandQueue: [Data] = []
// 标记当前是否正在处理请求，避免并发发送
private var isProcessingRequest = false

// 进入页面时启动实时更新
func startLiveDataUpdates() {
    commandQueue = commands // commands是你的4个传感器请求数组
    processNextCommand()
}

// 处理队列中的下一个命令
private func processNextCommand() {
    guard !commandQueue.isEmpty, !isProcessingRequest, 
          let characteristic = obdSensorCharacteristic,
          let peripheral = obdSensorPeripheral else { return }
    
    isProcessingRequest = true
    let nextCommand = commandQueue.removeFirst()
    // 发送无响应写入请求，若设备需要确认则改用.withResponse
    peripheral.writeValue(nextCommand, for: characteristic, type: .withoutResponse)
}

// 监听特征值更新回调
func peripheral(_ peripheral: CBPeripheral, didUpdateValueFor characteristic: CBCharacteristic, error: Error?) {
    guard error == nil, let data = characteristic.value else {
        isProcessingRequest = false
        processNextCommand() // 出错后继续下一个请求，或按需处理错误
        return
    }
    
    // 解析OBD-II响应并更新UI
    parseOBDResponse(data)
    
    // 延迟发送下一个请求（适配OBD-II总线响应间隔，建议200-500ms）
    DispatchQueue.main.asyncAfter(deadline: .now() + 0.2) {
        self.isProcessingRequest = false
        self.processNextCommand()
        
        // 队列空了就重新填充，实现循环请求
        if self.commandQueue.isEmpty {
            self.commandQueue = self.commands
        }
    }
}

这种方式完全依赖CoreBluetooth回调，避免了定时器的时间误差，也不会造成请求拥堵。

2. 正确利用BLE通知特性（替代主动read） #

你已经调用了peripheral.setNotifyValue(true, for: characteristic)，但多数OBD-II BLE设备收到请求后，会主动通过通知推送响应数据，不需要主动调用read(_:)：

• 删除requestData()中的read(characteristic: self.obdSensorCharacteristic!)调用
• 所有响应数据都在didUpdateValueFor回调中处理

3. 生命周期与后台状态管理 #

实现“进入页面启动、离开/后台停止”的逻辑，结合页面生命周期和系统通知：
SwiftUI场景：

struct LiveDataView: View {
    @StateObject var obdManager: OBDManager // 你的CoreBluetooth管理类
    
    var body: some View {
        // 页面内容
    }
    .onAppear {
        obdManager.startLiveDataUpdates()
    }
    .onDisappear {
        obdManager.stopLiveDataUpdates()
    }
    .onReceive(NotificationCenter.default.publisher(for: UIApplication.willResignActiveNotification)) { _ in
        obdManager.stopLiveDataUpdates()
    }
    .onReceive(NotificationCenter.default.publisher(for: UIApplication.didBecomeActiveNotification)) { _ in
        if obdManager.isConnected {
            obdManager.startLiveDataUpdates()
        }
    }
}

在OBDManager中实现停止逻辑：

func stopLiveDataUpdates() {
    commandQueue.removeAll()
    isProcessingRequest = false
    // 可选：发送设备支持的停止实时数据命令
}

4. 修复UI不更新问题 #

CoreBluetooth回调默认在后台线程执行，更新UI必须切换到主线程：

func parseOBDResponse(_ data: Data) {
    // 解析数据逻辑
    let coolantTemp = parsedCoolantTemp
    
    DispatchQueue.main.async {
        // 更新LiveDataView绑定的数据
        self.coolantTemperature = coolantTemp
    }
}

关键注意事项 #

• 不要在peripheralIsReady(toSendWriteWithoutResponse)中批量发送命令，该回调仅表示设备可以接受下一个无响应写入，应每次只发一个
• OBD-II总线有固有延迟，请求间隔建议控制在200-500ms
• 发送前始终检查CBPeripheral的canSendWriteWithoutResponse状态，确保设备可接收写入

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