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

В этом документе описывается, как синхронизировать данные между устройством Wear OS и портативным устройством.

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

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

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

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

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

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

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

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

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

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

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

Передача данных

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

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

Примечание: Хотя теоретически размер элементов данных ограничен 100 КБ, на практике можно использовать и более крупные элементы данных. Для больших элементов данных разделяйте данные по уникальным путям и избегайте использования одного пути для всех данных. Передача больших файлов данных во многих случаях влияет на пользовательский опыт, поэтому тестируйте свои приложения, чтобы убедиться в их хорошей производительности при передаче больших файлов данных.

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

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

Котлин 

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

Java 

private static Asset createAssetFromBitmap(Bitmap bitmap) {
    final ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
    bitmap.compress(Bitmap.CompressFormat.PNG, 100, byteStream);
    return Asset.createFromBytes(byteStream.toByteArray());
}

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

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

Котлин 

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

Java 

Bitmap bitmap = BitmapFactory.decodeResource(getResources(), R.drawable.image);
Asset asset = createAssetFromBitmap(bitmap);
PutDataRequest request = PutDataRequest.create("/image");
request.putAsset("profileImage", asset);
Task<DataItem> putTask = Wearable.getDataClient(context).putDataItem(request);

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

Котлин 

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

Java 

Bitmap bitmap = BitmapFactory.decodeResource(getResources(), R.drawable.image);
Asset asset = createAssetFromBitmap(bitmap);
PutDataMapRequest dataMap = PutDataMapRequest.create("/image");
dataMap.getDataMap().putAsset("profileImage", asset);
PutDataRequest request = dataMap.asPutDataRequest();
Task<DataItem> putTask = Wearable.getDataClient(context).putDataItem(request);

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

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

override fun onDataChanged(dataEvents: DataEventBuffer) {
    dataEvents
        .filter { it.type == DataEvent.TYPE_CHANGED && it.dataItem.uri.path == "/image" }
        .forEach { event ->
            val bitmap: Bitmap? = DataMapItem.fromDataItem(event.dataItem)
                .dataMap.getAsset("profileImage")
                ?.let { asset -> loadBitmapFromAsset(asset) }
            // Do something with the bitmap
        }
}

fun loadBitmapFromAsset(asset: Asset): Bitmap? {
    // Convert asset into a file descriptor and block until it's ready
    val assetInputStream: InputStream? =
        Tasks.await(Wearable.getDataClient(this).getFdForAsset(asset))
            ?.inputStream

    return assetInputStream?.let { inputStream ->
        // Decode the stream into a bitmap
        BitmapFactory.decodeStream(inputStream)
    } ?: run {
        // Requested an unknown asset
        null
    }
}
DataLayerActivity.kt

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