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

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

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

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

Синхронизация данных с помощью API Wear OS Data Layer

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

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

  • DataItem синхронизируется на всех устройствах в сети Wear OS. Обычно они имеют небольшой размер.

  • Используйте 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())
    }

Ява 

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)

Ява 

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)

Ява 

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(context).getFdForAsset(asset))
            ?.inputStream

    return assetInputStream?.let { inputStream ->
        // Decode the stream into a bitmap
        BitmapFactory.decodeStream(inputStream)
    } ?: run {
        Log.w(TAG, "Requested an unknown Asset.")
        null
    }
}

Ява 

@Override
public void onDataChanged(DataEventBuffer dataEvents) {
  for (DataEvent event : dataEvents) {
    if (event.getType() == DataEvent.TYPE_CHANGED &&
        event.getDataItem().getUri().getPath().equals("/image")) {
      DataMapItem dataMapItem = DataMapItem.fromDataItem(event.getDataItem());
      Asset profileAsset = dataMapItem.getDataMap().getAsset("profileImage");
      Bitmap bitmap = loadBitmapFromAsset(profileAsset);
      // Do something with the bitmap
    }
  }
}

public Bitmap loadBitmapFromAsset(Asset asset) {
    if (asset == null) {
        throw new IllegalArgumentException("Asset must be non-null");
    }
    // Convert asset into a file descriptor and block until it's ready
    InputStream assetInputStream =
        Tasks.await(Wearable.getDataClient(context).getFdForAsset(asset))
            .getInputStream();
    if (assetInputStream == null) {
        Log.w(TAG, "Requested an unknown Asset.");
        return null;
    }
    // Decode the stream into a bitmap
    return BitmapFactory.decodeStream(assetInputStream);
}

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