Синхронизировать данные

В этом документе описывается, как синхронизировать данные между устройством Wear OS и телефоном. В разделе «Обзор» вы найдете информацию о том, когда следует использовать API уровня данных, а когда — собственную инфраструктуру.

Отправляйте и синхронизируйте данные напрямую из сети.

Создавайте приложения для Wear OS, которые будут напрямую взаимодействовать с сетью . Используйте те же API, что и для мобильной разработки, но учитывайте некоторые специфические особенности Wear OS.

Синхронизируйте данные с помощью API уровня данных Wear OS.

DataClient предоставляет API для компонентов, позволяющих читать или записывать данные в DataItem или Asset .

Можно устанавливать параметры данных и ресурсов, даже не будучи подключенным к каким-либо устройствам. Синхронизация происходит при установлении сетевого соединения между устройствами. Эти данные являются конфиденциальными для вашего приложения и доступны только на других устройствах.

• DataItem синхронизируется между всеми устройствами в сети Wear OS. Как правило, они имеют небольшой размер.

• Используйте Asset для переноса более крупного файла, например изображения. Система отслеживает, какие объекты Asset уже были перенесены, и автоматически выполняет дедупликацию.

Внимательно следите за событиями во время богослужений.

Расширьте класс WearableListenerService . Система управляет жизненным циклом базового класса WearableListenerService , привязываясь к сервису, когда необходимо отправлять данные или сообщения, и отвязываясь от сервиса, когда работа не требуется.

Внимательно следите за событиями в ходе деятельности.

Реализуйте интерфейс OnDataChangedListener . Используйте этот интерфейс вместо WearableListenerService , если хотите отслеживать изменения только тогда, когда пользователь активно использует ваше приложение.

Описание: Передача больших бинарных объектов, таких как изображения, между телефонами Android и часами Wear OS с использованием Assets в API уровня данных. Ключевые слова: Wear OS, API уровня данных, Assets, передача данных по Bluetooth, синхронизация данных, DataMap, PutDataRequest

Синхронизация данных

Для обмена большими бинарными объектами по протоколу Bluetooth, например, голосовой записью с другого устройства, можно прикрепить Asset к элементу данных, а затем поместить этот элемент данных в реплицированное хранилище данных. Однако, если обмен происходит однократно между двумя подключенными устройствами, следует рассмотреть возможность более простой прямой передачи .

Примечание: API уровня данных может отправлять сообщения и синхронизировать данные только с телефонами, работающими под управлением Android или Wear OS. Если устройство Wear OS сопряжено с устройством iOS, API уровня данных работать не будет.

По этой причине не используйте API уровня данных в качестве основного способа связи с сетью. Вместо этого следуйте тому же принципу в приложении Wear OS, что и в мобильном приложении — с некоторыми незначительными отличиями, как описано в разделе «Доступ к сети и синхронизация в Wear OS» .

Автоматическое кэширование данных в рамках проекта Assets предотвращает повторную передачу и экономит пропускную способность Bluetooth. Распространенный подход заключается в том, что мобильное приложение загружает изображение, уменьшает его до подходящего размера для отображения на часах и передает его в приложение на часах в качестве ресурса. Следующие примеры демонстрируют этот подход.

Передача актива

Создайте ресурс, используя один из методов create...() класса Asset . Преобразуйте растровое изображение в массив байтов, а затем вызовите метод createFromBytes() для создания ресурса, как показано в следующем примере.

private fun createAssetFromBitmap(bitmap: Bitmap): Asset =
    ByteArrayOutputStream().let { byteStream ->
        bitmap.compress(Bitmap.CompressFormat.PNG, 100, byteStream)
        Asset.createFromBytes(byteStream.toByteArray())
    }
DataLayerActivity.kt

Далее, привяжите ресурс к элементу данных с помощью метода putAsset() в DataMap или PutDataRequest . Затем поместите элемент данных в хранилище данных, используя метод putDataItem() , как показано в следующих примерах.

В следующем примере используется PutDataRequest :

private fun Context.sendImagePutDataRequest(): Task<DataItem> {

    val asset: Asset = createAssetFromBitmap(BitmapFactory.decodeResource(resources, R.drawable.ic_walk))
    val request: PutDataRequest = PutDataRequest.create("/image").apply {
        putAsset("profileImage", asset)
    }
    val putTask: Task<DataItem> = Wearable.getDataClient(this).putDataItem(request)

    return putTask
}
DataLayerActivity.kt

В следующем примере используется PutDataMapRequest :

private fun Context.sendImagePutDataMapRequest(): Task<DataItem> {

    val asset: Asset = createAssetFromBitmap(BitmapFactory.decodeResource(resources, R.drawable.ic_walk))
    val request: PutDataRequest = PutDataMapRequest.create("/image").run {
        dataMap.putAsset("profileImage", asset)
        asPutDataRequest()
    }
    val putTask: Task<DataItem> = Wearable.getDataClient(this).putDataItem(request)

    return putTask
}
DataLayerActivity.kt

Получение активов

После создания ресурса обычно происходит его чтение и извлечение на другой стороне соединения. В следующем примере показано, как реализовать функцию обратного вызова для обнаружения изменения ресурса и его извлечения:

override fun onDataChanged(dataEvents: DataEventBuffer) {
    dataEvents
        .filter { it.type == DataEvent.TYPE_CHANGED && it.dataItem.uri.path == "/image" }
        .forEach { event ->
            val asset = DataMapItem.fromDataItem(event.dataItem)
                .dataMap.getAsset("profileImage")

            asset?.let { safeAsset ->
                lifecycleScope.launch {
                    val bitmap = loadBitmapFromAsset(safeAsset)
                    // Do something with the bitmap
                }
            }
        }
}

private suspend fun loadBitmapFromAsset(asset: Asset): Bitmap? = withContext(Dispatchers.IO) {
    try {
        val assetResult = Wearable.getDataClient(this@DataLayerActivity2)
            .getFdForAsset(asset)
            .await()

        assetResult?.inputStream?.use { inputStream ->
            BitmapFactory.decodeStream(inputStream)
        }
    } catch (e: Exception) {
        e.printStackTrace()
        null
    }
}
DataLayerActivity.kt

Для получения более подробной информации см. пример проекта DataLayer на GitHub.