Проблема при использовании RxBleClient для сканирования устройств BLE в фоновом режиме
Я сканирую устройства BLE, созданные на устройстве iOS. Затем я подключаюсь к конкретному сервису и читаю конкретные характеристики. Он отлично работает, когда на переднем плане находится iOS-приложение с сервисом GATT. Но при скрытии приложения сервера iOS клиент Android перестает обнаруживать устройства BLE GATT.
public static ScanFilter[] getFilters(UUID serviceUuid) {
...
filters.add(new ScanFilter.Builder().setServiceUuid(new ParcelUuid(serviceUuid)).build());
return filters.toArray(new ScanFilter[filters.size()]);
}
public static ScanSettings getScanSettings() {
return new ScanSettings.Builder()
.setScanMode(ScanSettings.SCAN_MODE_LOW_LATENCY) // change if needed
.setCallbackType(ScanSettings.CALLBACK_TYPE_ALL_MATCHES) // change if needed
.build();
}
Приложение BLE Scanner успешно видит скрытый сервер GATT
Обновления Вот фильтры части кода
public final class ScannerUtil {
public static final List<UUID> BEACON_UUUIDs = Arrays.asList(
...........
UUID.fromString("a8427a96-70bd-4a7e-9008-6e5c3d445a2b"));
public static ScanSettings getScanSettings() {
return new ScanSettings.Builder()
.setScanMode(ScanSettings.SCAN_MODE_BALANCED) // change if needed
.setCallbackType(ScanSettings.CALLBACK_TYPE_ALL_MATCHES) // change if needed
.build();
}
public static ScanFilter[] getFilters(UUID serviceUuid) {
List<ScanFilter> filters = Stream.of(BEACON_UUUIDs)
.map(iBeaconScanFilter::setScanFilter)
.collect(toList());
filters.add(new ScanFilter.Builder().setServiceUuid(new ParcelUuid(serviceUuid)).build());
return filters.toArray(new ScanFilter[filters.size()]);
}
}
Полный код класса сканера ниже:
public class BLEGlobalScanner {
private final ScannerConfiguration configuration;
private final Context context;
private final RxBleClient rxBleClient;
private final Map<String, String> devicesMap = new HashMap<>();
private final Map<String, DeviceApoloBeacon> beaconsMap = new HashMap<>();
private final ScanFilter[] scanFilter;
public BLEGlobalScanner(ScannerConfiguration configuration, Context context) {
this.configuration = configuration;
this.context = context;
this.rxBleClient = RxBleClient.create(context);
this.scanFilter = getFilters(configuration.beacons(), configuration.gattServer().server());
}
public Observable<BluetoothDeviceApolo> start() {
return bluetoothEnableObservable(context).switchMap(aBoolean -> startScanner())
.filter(Optional::isPresent)
.map(Optional::get);
}
private Observable<Optional<BluetoothDeviceApolo>> startScanner() {
return rxBleClient.scanBleDevices(getScanSettings(), scanFilter)
.buffer(2, TimeUnit.SECONDS)
.flatMap(rxBleDevices -> Observable.from(rxBleDevices)
.distinct(scanResult -> scanResult.getBleDevice().getMacAddress())
.concatMap(this::handleDevices)
.map(Optional::of))
.observeOn(mainThread())
.onErrorResumeNext(throwable -> {
Timber.e(throwable, "startScanner");
return Observable.just(Optional.empty());
})
.onExceptionResumeNext(Observable.just(Optional.empty()))
.retry();
}
private Observable<BluetoothDeviceApolo> handleDevices(ScanResult scanResult) {
if (beaconsMap.containsKey(scanResult.getBleDevice().getMacAddress())) {
return Observable.fromCallable(() -> beaconsMap.get(scanResult.getBleDevice().getMacAddress()))
.map(beacon -> beacon.toBuilder()
.lastSeen(System.currentTimeMillis())
.rssi(scanResult.getRssi())
.build());
} else {
return handleBeacon(scanResult)
.map(device -> (BluetoothDeviceApolo) device)
.switchIfEmpty(
handleDevice(scanResult).map(deviceApolo -> (BluetoothDeviceApolo) deviceApolo)
);
}
}
private Observable<DeviceApoloBeacon> handleBeacon(ScanResult scanResult) {
return Observable.fromCallable(() -> scanResult.getScanRecord().getManufacturerSpecificData(COMPANY_ID_APPLE))
.filter(bytes -> bytes != null)
.filter(bytes -> DeviceApoloBeacon.requiredManufactureSize == bytes.length)
.map(bytes -> DeviceApoloBeacon.builder()
.manufacturedData(bytes)
.lastSeen(System.currentTimeMillis())
.rssi(scanResult.getRssi())
.build())
.filter(beacon -> configuration.beacons().contains(beacon.uuuid()))
.doOnNext(beacon -> beaconsMap.put(scanResult.getBleDevice().getMacAddress(), beacon));
}
private Observable<DeviceApolo> handleDevice(ScanResult scanResult) {
final RxBleDevice rxBleDevice = scanResult.getBleDevice();
if (devicesMap.containsKey(rxBleDevice.getMacAddress())) {
return Observable.fromCallable(() -> devicesMap.get(rxBleDevice.getMacAddress()))
.timestamp()
.map(deviceStr -> DeviceApolo.create(deviceStr.getValue(), deviceStr.getTimestampMillis(), scanResult.getRssi()));
} else {
return readCharacteristic(rxBleDevice, scanResult.getRssi());
}
}
private Observable<DeviceApolo> readCharacteristic(RxBleDevice rxBleDevice, final int rssi) {
return rxBleDevice.establishConnection(false)
.compose(new ConnectionSharingAdapter())
.switchMap(rxBleConnection -> rxBleConnection.readCharacteristic(configuration.gattServer().characteristic()))
.map(String::new)
.doOnNext(s -> devicesMap.put(rxBleDevice.getMacAddress(), s))
.timestamp()
.map(deviceStr -> DeviceApolo.create(deviceStr.getValue(), deviceStr.getTimestampMillis(), rssi))
.retry();
}
}
1 ответ
Нет проблем с вашим кодом и нет проблем с RxAndroidBle
, Периферийное устройство, которое вы сканируете, в конце концов обнаружено.
То, что вы испытываете, это предполагаемое поведение приложения iOS в фоновом режиме - поиск The bluetooth-peripheral Background Execution Mode
на официальном справочном сайте.
Ссылка гласит:
Если все приложения, размещающие рекламу, находятся в фоновом режиме, частота, с которой ваше периферийное устройство отправляет рекламные пакеты, может уменьшиться.
Если вы намереваетесь использовать приложение iOS в качестве периферийного устройства, тогда вы ничего не можете сделать (см. Документацию). В качестве альтернативы вы можете проверить, можете ли вы реализовать свое периферийное устройство на другом оборудовании (я не знаю вашего точного варианта использования, но не в этом вопрос).
С уважением