同步数据单元

编写:wly2014 - 原文: http://developer.android.com/training/wearables/data-layer/data-items.html

DataItem是指系统用于同步手持设备与可穿戴设备间数据的接口。一个DataItem通常包括以下几点:

  • Pyload - 一个字节数组,我们可以用来设置任何数据,让我们的对象序列化和反序列化。Pyload的大小限制在100k之内。

  • Path - 唯一且以前斜线开头的字符串(如:”/path/to/data”)。

通常不直接实现DataItem,而是:

  1. 创建一个PutdataRequest对象,指明一个字符串路径以唯一确定该 item。
  2. 调用setData())方法设置Pyload。
  3. 调用DataApi.putDataItem()方法,请求系统创建数据元。
  4. 当请求数据元的时候,系统会返回正确实现DataItem接口的对象。

然而,我们建议使用Data Map来显示装在一个易用的类似Bundle接口中的数据元,而不是用setData()来处理原始字节。

用 Data Map 同步数据

使用DataMap类,将数据元处理为 Android Bundle的形式,因此会完成对象的序列化和反序列化,我们就可以以键值对(key-value)的形式操纵数据。

如何使用data map:

  1. 创建一个 PutDataMapRequest对象,设置数据元的路径。

    Note: 数据元的路径字符串是唯一确定的,这样能够使我们从连接任意一端访问数据元。路径须以前斜线开始。如果我们想在应用中使用分层数据,就要创建一个适合数据结构的路径方案。

  2. 调用PutDataMapRequest.getDataMap())获取一个我们可以使用的data map 对象。
  3. 使用put…()方法,如:putString(),为data map设置数据。
  4. 调用PutDataMapRequest.asPutDataRequest())获得PutDataRequest对象。
  5. 调用 DataApi.putDataItem() 请求系统创建数据元。

    Note: 如果手机和可穿戴设备没有连接,数据会缓冲并在重新建立连接时同步。

接下的例子中的increaseCounter()方法展示了如何创建一个data map,并设置数据:

  1. public class MainActivity extends Activity implements
  2. DataApi.DataListener,
  3. GoogleApiClient.ConnectionCallbacks,
  4. GoogleApiClient.OnConnectionFailedListener {
  5. private static final String COUNT_KEY = "com.example.key.count";
  6. private GoogleApiClient mGoogleApiClient;
  7. private int count = 0;
  8. ...
  9. // Create a data map and put data in it
  10. private void increaseCounter() {
  11. PutDataMapRequest putDataMapReq = PutDataMapRequest.create("/count");
  12. putDataMapReq.getDataMap().putInt(COUNT_KEY, count++);
  13. PutDataRequest putDataReq = putDataMapReq.asPutDataRequest();
  14. PendingResult<DataApi.DataItemResult> pendingResult =
  15. Wearable.DataApi.putDataItem(mGoogleApiClient, putDataReq);
  16. }
  17. ...
  18. }

有关控制 PendingResult 对象的更多信息,请参见 Wait for the Status of Data Layer Calls

监听数据元事件

如果数据层连接的一端数据发生改变,我们很可能想要被告知在连接的另一端发生的任何改变。我们可以通过实现一个数据元事件的监听器来完成。

当定义在上一个例子中的counter的值发生改变时,下面例子的代码片段能够通知我们的app。

  1. public class MainActivity extends Activity implements
  2. DataApi.DataListener,
  3. GoogleApiClient.ConnectionCallbacks,
  4. GoogleApiClient.OnConnectionFailedListener {
  5. private static final String COUNT_KEY = "com.example.key.count";
  6. private GoogleApiClient mGoogleApiClient;
  7. private int count = 0;
  8. @Override
  9. protected void onCreate(Bundle savedInstanceState) {
  10. super.onCreate(savedInstanceState);
  11. setContentView(R.layout.activity_main);
  12. mGoogleApiClient = new GoogleApiClient.Builder(this)
  13. .addApi(Wearable.API)
  14. .addConnectionCallbacks(this)
  15. .addOnConnectionFailedListener(this)
  16. .build();
  17. }
  18. @Override
  19. protected void onResume() {
  20. super.onStart();
  21. mGoogleApiClient.connect();
  22. }
  23. @Override
  24. public void onConnected(Bundle bundle) {
  25. Wearable.DataApi.addListener(mGoogleApiClient, this);
  26. }
  27. @Override
  28. protected void onPause() {
  29. super.onPause();
  30. Wearable.DataApi.removeListener(mGoogleApiClient, this);
  31. mGoogleApiClient.disconnect();
  32. }
  33. @Override
  34. public void onDataChanged(DataEventBuffer dataEvents) {
  35. for (DataEvent event : dataEvents) {
  36. if (event.getType() == DataEvent.TYPE_CHANGED) {
  37. // DataItem 改变了
  38. DataItem item = event.getDataItem();
  39. if (item.getUri().getPath().compareTo("/count") == 0) {
  40. DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap();
  41. updateCount(dataMap.getInt(COUNT_KEY));
  42. }
  43. } else if (event.getType() == DataEvent.TYPE_DELETED) {
  44. // DataItem 删除了
  45. }
  46. }
  47. }
  48. // 我们的更新 count 的方法
  49. private void updateCount(int c) { ... }
  50. ...
  51. }

这个activity是实现了 DataItem.DataListener 接口。该activity在onConnected()方法中增加自身成为数据元事件的监听器,并在onPause()方法中移除监听器。

我们也可以用一个service实现监听,请见 监听数据层事件