Android BLE 稳定连接管理器（Kotlin版）完整代码骨架（下篇）

在上一篇文章：

《Android 蓝牙连接不稳定怎么解决？BLE 稳定性架构设计（上篇）》

我们讲清楚了 BLE 稳定性的核心思想：

• 连接状态机
• GATT 操作串行化
• 超时机制
• 断开清理
• 指数退避重连
• 生命周期管理
• 完整日志系统

这一篇我们直接落地：

实现一个 Android BLE 稳定连接管理器。

目标：

• BLE 连接可控
• 自动重连
• 串行 GATT 操作
• 支持超时
• 支持日志
• Kotlin 协程架构

一、整体架构设计

BLE 连接管理器整体结构：

BleManager │ ├── ConnectionStateMachine ├── OperationQueue ├── RetryPolicy ├── DeviceSession └── GattCallback

核心职责：

二、定义 BLE 连接状态

BLE 连接必须有完整状态。

sealed class BleConnectState { object Idle : BleConnectState() object Scanning : BleConnectState() object Connecting : BleConnectState() object Connected : BleConnectState() object ServiceDiscovered : BleConnectState() object Ready : BleConnectState() data class Disconnected(val reason: String) : BleConnectState() data class Failed(val code: Int) : BleConnectState() }

状态说明：

三、定义 GATT 操作接口

所有 GATT 操作必须串行执行。

interface BleOperation { suspend fun execute(gatt: BluetoothGatt): Boolean }

例如写入操作：

class WriteOperation( private val characteristic: BluetoothGattCharacteristic, private val data: ByteArray ) : BleOperation { override suspend fun execute(gatt: BluetoothGatt): Boolean { characteristic.value = data return gatt.writeCharacteristic(characteristic) } }

四、GATT 操作队列（核心）

BLE 操作必须排队。

class OperationQueue { private val queue: ArrayDeque<suspend () -> Unit> = ArrayDeque() private var running = false fun enqueue(op: suspend () -> Unit) { queue.addLast(op) if (!running) { next() } } private fun next() { val op = queue.removeFirstOrNull() ?: run { running = false return } running = true GlobalScope.launch { op.invoke() next() } } }

这样所有 BLE 操作都会：

排队 ↓ 执行 ↓ 回调完成 ↓ 执行下一个

五、BLE Manager 核心结构

class BleManager( private val context: Context ) { private var bluetoothGatt: BluetoothGatt? = null private var currentDevice: BluetoothDevice? = null private val operationQueue = OperationQueue() private var retryCount = 0 private var manualDisconnect = false private val scope = CoroutineScope(Dispatchers.IO) }

字段说明：

六、建立连接

连接入口：

fun connect(device: BluetoothDevice) { manualDisconnect = false currentDevice = device bluetoothGatt?.close() bluetoothGatt = null bluetoothGatt = device.connectGatt( context, false, gattCallback ) }

注意：

autoConnect = false

避免 Android 某些机型异常。

七、断开连接

fun disconnect() { manualDisconnect = true bluetoothGatt?.disconnect() }

断开后必须释放资源：

private fun clearGatt() { bluetoothGatt?.close() bluetoothGatt = null }

八、自动重连策略

使用指数退避算法。

private fun nextRetryDelay(): Long { val delay = (1000L * (1 shl retryCount)) return minOf(delay, 15000) }

重连逻辑：

private fun scheduleReconnect() { retryCount++ val delay = nextRetryDelay() scope.launch { delay(delay) currentDevice?.let { connect(it) } } }

九、GattCallback 实现

核心 BLE 回调：

private val gattCallback = object : BluetoothGattCallback() { override fun onConnectionStateChange( gatt: BluetoothGatt, status: Int, newState: Int ) { if (newState == BluetoothProfile.STATE_CONNECTED) { log("connected") gatt.discoverServices() } else if (newState == BluetoothProfile.STATE_DISCONNECTED) { log("disconnected status=$status") clearGatt() if (!manualDisconnect) { scheduleReconnect() } } } override fun onServicesDiscovered( gatt: BluetoothGatt, status: Int ) { if (status == BluetoothGatt.GATT_SUCCESS) { log("services discovered") } else { log("service discover failed") } } override fun onMtuChanged( gatt: BluetoothGatt, mtu: Int, status: Int ) { log("mtu changed $mtu") } }

十、MTU 协商

连接成功后可以协商 MTU。

fun requestMtu(size: Int = 247) { bluetoothGatt?.requestMtu(size) }

MTU 默认：23 。 协商后可以提升数据吞吐。

十一、开启通知

BLE 通信通常依赖 Notification。

fun enableNotification( characteristic: BluetoothGattCharacteristic ) { bluetoothGatt?.setCharacteristicNotification( characteristic, true ) val descriptor = characteristic.getDescriptor( UUID.fromString(CLIENT_CONFIG_UUID) ) descriptor.value = BluetoothGattDescriptor.ENABLE_NOTIFICATION_VALUE bluetoothGatt?.writeDescriptor(descriptor) }

十二、写数据

写入特征值：

fun write( characteristic: BluetoothGattCharacteristic, data: ByteArray ) { operationQueue.enqueue { characteristic.value = data bluetoothGatt?.writeCharacteristic(characteristic) } }

这样写入操作就会：

排队
↓
串行执行

避免 BLE 操作冲突。

十三、超时机制（推荐）

很多 BLE API 不保证回调。

建议增加超时：

suspend fun waitResponse(timeout: Long) { withTimeoutOrNull(timeout) { suspendCancellableCoroutine<Unit> { } } ?: run { log("timeout") disconnect() } }

十四、日志系统

BLE 排查必须有日志。

private fun log(msg: String) { Log.d("BLE", msg) }

推荐日志格式：

[BLE] startScan [BLE] stopScan [BLE] connectGatt [BLE] connected [BLE] discoverServices [BLE] mtuChanged [BLE] notifyEnabled [BLE] writeCharacteristic [BLE] disconnected status=133

十五、完整流程

最终 BLE 流程：

扫描设备 ↓ 停止扫描 ↓ connectGatt ↓ 连接成功 ↓ discoverServices ↓ requestMtu ↓ enableNotification ↓ Ready ↓ 数据通信 ↓ 断线 → 自动重连

十六、工程实践建议

BLE 稳定性关键点：

十七、总结

Android BLE 不稳定的根本原因并不是：

蓝牙不好用。

而是很多项目：

• 没有连接管理

• 没有操作队列

• 没有超时机制

• 没有断线重连

当 BLE 架构设计完善后，稳定性会显著提升。

一句话总结：

BLE 连接不是一个 API 调用，而是一套完整的连接管理系统。

第三篇（高级篇）：

《Android BLE 十大经典坑：133错误、notify失败、服务发现异常》