Android Wear開發 - 數據通訊 - 第二節 : 數據的發送與接收

本節由介紹3種數據的發送接收:
1.Data Items : 比特類型數據,限制100KB以內
2.Assets : 資源類型數據,大小無上限
3.Message : 發送消息,觸發指令

http://developer.android.com/training/wearables/data-layer/data-items.html

1.Syncing Data Items

DataItem定義了同步手機和手表的數據接口.一個DataItem對象一般包括下面2個部分:

• 負載 : 一個比特類型數組,支持任意實現了序列化接口的對象.負載最大是100KB.
• 路徑 : 一個唯一的字符串，且必須以＂/"斜杠作為開頭,如"/path/to/data"

一般來說是不需要自己實現DataItem接口的,而是通過以下方式:

1. 創建一個PutDataRequest對象,用一個唯一的字符串ID來定義.
2. 調用setData()方法將負載數據傳入
3. 調用DataApi.putDataItem()請求系統來構建數據單元
4. 當請求數據單元時,系統會返回實現了DataItem接口的對象

以上的方式並非最佳的選擇,還可以通過DataMap的方式來實現,這類似於Bundle.

Sync Data with a Data Map

因為DataMap的方式是用Bundle實現的,所以它幫我們解決了序列化問題,並且可以使用鍵值對的方式來操控數據.

使用方法

1. 構造一個PutDataMapRequest對象,設置唯一ID.
2. 調用PutDataMapRequest.getDataMap()來獲取一個數據map.
3. 用put...()方法來設置所需的數據.
4. 調用PutDataMapRequest.asPutDataRequest()來獲取一個PutDataRequest對象.
5. 調用DataApi.putDataItem()請求系統傳遞數據.

注意:此時手表和手機若未連接,則會緩存在發送端,待到兩端連接時再進行同步.
代碼樣例

private void syncData() {
    PutDataMapRequest dataMap = PutDataMapRequest.create("/count");
    dataMap.getDataMap().putInt(COUNT_KEY, count++);
    PutDataRequest request = dataMap.asPutDataRequest();
    PendingResult<DataApi.DataItemResult> pendingResult = Wearable.DataApi
        .putDataItem(mGoogleApiClient, request);
}

Listen for Data Item Events

當任意一端的數據發生變化時,這時候如果想通知到另外一端,可以通過監聽數據改變接口來實現:

代碼樣例

@Override
public void onDataChanged(DataEventBuffer dataEvents) {
    for (DataEvent event : dataEvents) {
        if (event.getType() == DataEvent.TYPE_DELETED) {
            Log.d(TAG, "DataItem deleted: " + event.getDataItem().getUri());
        } else if (event.getType() == DataEvent.TYPE_CHANGED) {
             Log.d(TAG, "DataItem changed: " + event.getDataItem().getUri());
        }
    }
}

http://developer.android.com/training/wearables/data-layer/assets.html

2.Transferring Assets

若想通過藍牙發送較大的二進制數據塊,例如圖片,則需要將數據綁定到Asset對象上.

Assets自動地處理了數據緩存的阻止重發和保存藍牙數據帶寬.一個通用模式來處理手機應用下載圖片,再處理成適當的尺寸,最后轉換成asset發送到手表.

注意:數據單元Data Item被限制在100KB以內,而Assets則是沒有限制的.但是傳輸大數據量的Assets會影響到用戶體驗,所以若是迫不得已必須傳較大的Assets,要多測試.

Transfer an Asset

構建好了Assets,則可以通過PutDataRequest或PutDataMapRequest的方式傳遞數據

PutDataRequest:

private void transferAsset{
    Bitmap bitmap = BitmapFactory.decodeResource(getResources(), R.drawable.image);
    Asset asset = createAssetFromBitmap(bitmap);
    PutDataRequest request = PutDataRequest.create("/image");
    request.putAsset("profileImage", asset);
    Wearable.DataApi.putDataItem(mGoogleApiClient, request);   
}

PutDataMapRequest:

private void transferAsset{
    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();
    PendingResult<DataApi.DataItemResult> pendingResult = Wearable.DataApi
        .putDataItem(mGoogleApiClient, request);
}

Receive assets

@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");
    }
    ConnectionResult result =
           mGoogleApiClient.blockingConnect(TIMEOUT_MS, TimeUnit.MILLISECONDS);
    if (!result.isSuccess()) {
        return null;
    }
    // convert asset into a file descriptor and block until it's ready
    InputStream assetInputStream = Wearable.DataApi.getFdForAsset(
            mGoogleApiClient, asset).await().getInputStream();
            mGoogleApiClient.disconnect();

    if (assetInputStream == null) {
        Log.w(TAG, "Requested an unknown Asset.");
        return null;
    }
    // decode the stream into a bitmap
    return BitmapFactory.decodeStream(assetInputStream);
}

http://developer.android.com/training/wearables/data-layer/messages.html

3.Sending and Receiving Messages

可以通過MessageApi來發送以下兩種數據:

• 任意類型的數據
• 擁有唯一鍵值對的消息動作

與DataItem的雙向同步不同,message是單向的.Message通過單向的連接發送到另一端,這有利於遠程調用(RPC - remote procedure calls).

Send a Message

以下是一個發送消息啟動Activity的樣例,在發送消息時,會阻塞線程,直到消息送達或者超時.

Node node; // the connected device to send the message to
GoogleApiClient mGoogleApiClient;
public static final START_ACTIVITY_PATH = "/start/MainActivity";
...

    SendMessageResult result = Wearable.MessageApi.sendMessage(
            mGoogleApiClient, node, START_ACTIVITY_PATH, null).await();
    if (!result.getStatus().isSuccess()) {
        Log.e(TAG, "ERROR: failed to send Message: " + result.getStatus());
    }

以下是獲取所有的和Android Wear應用相連接的節點.

private Collection<String> getNodes() {
    HashSet <String>results = new HashSet<String>();
    NodeApi.GetConnectedNodesResult nodes =
            Wearable.NodeApi.getConnectedNodes(mGoogleApiClient).await();
    for (Node node : nodes.getNodes()) {
        results.add(node.getId());
    }
    return results;
}

Receive a Message

以下是接收消息的例子,與上一個發送消息的例子對應.在處理接收到的消息之前,需要使用MessageApi.addListener()注冊監聽器.具體在其他章節中有講述.

@Override
public void onMessageReceived(MessageEvent messageEvent) {
    if (messageEvent.getPath().equals(START_ACTIVITY_PATH)) {
        Intent startIntent = new Intent(this, MainActivity.class);
        startIntent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
        startActivity(startIntent);
    }
}