处理数据层的事件
最后更新于：2022-04-01 01:42:17
> 编写:[wly2014](https://github.com/wly2014) - 原文: [http://developer.android.com/training/wearables/data-layer/events.html](http://developer.android.com/training/wearables/data-layer/events.html)
当做出数据层上的调用时，你可以得到它完成后的调用状态，也可以用监听器监听到调用最终实现的改变。
### 等待数据层调用状态
注意到，调用数据层API，有时会返回[PendingResult](#)，如 [putDataItem()](#))。PendingResult一被创建，操作就会在后台排列等候。之后你若无动作，这些操作最终会默默完成。然而，通常要处理操作完成后的结果，PendingResult能够让你同步或异步地等待结果。
### 异步等待
若你的代码运行在主UI线程上，不使阻塞调用数据层API。你可以增加一个PendingResult对象回调来运行异步调用，将在操作完成时触发。
~~~
pendingResult.setResultCallback(new ResultCallback<DataItemResult>() {
@Override
public void onResult(final DataItemResult result) {
if(result.getStatus().isSuccess()) {
Log.d(TAG, "Data item set: " + result.getDataItem().getUri());
}
}
});
~~~
### 同步等待
如果你的代码是运行在后台服务的一个单独的处理线程上（[WearableListenerService](#)的情况）,则适合调用阻塞。在这种情况下,你可以用PendingResult对象调用[await()](#)),它将阻塞至请求完成,并返回一个Result对象。
~~~
DataItemResult result = pendingResult.await();
if(result.getStatus().isSuccess()) {
Log.d(TAG, "Data item set: " + result.getDataItem().getUri());
}
~~~
# 监听数据层事件
因为数据层在手持和可穿戴设备间同步并发送数据,所以通常要监听重要事件,例如创建数据元,接受消息,或当可穿戴设备和手机连接时。
对于监听数据层事件，有两种选择：
- 创建一个继承自WearableListenerService的service。
- 创建一个实现[DataApi.DataListener](#)接口的[activity](# "An activity represents a single screen with a user interface.")。
通过这两种选择，你覆写任何你关心的数据事件回调方法来处理您的实现。
### 使用 WearableListenerService
典型地，在你的手持设备和可穿戴设备上都创建该service实例。如果你不关心其中一个应用中的数据事件，就不需要在相应的应用中实现此service。
例如,您可以在一个手持设备应用程序上操作数据元对象,可穿戴设备的应用监听这些更新并更新UI。而可穿戴不更新任何数据元,所以手持设备的应用不监听任何可穿戴式设备应用的数据事件。
你可以用 WearableListenerService监听如下事件：
- [onDataChanged()](#)) - 当数据元对象创建，更改，删除时调用。一连接端的事件将触发两端的回调方法。
- [onMessageReceived()](#)) - 消息从一连接端发出时在另一连接端触发此回调方法。
- [onPeerConnected()](#)) 和 [onPeerDisconnected()](#)) - 当与手持或可穿戴设备连接或断开时调用。一连接端连接状态的改变会在两端触发此回调方法。
创建WearableListenerService：
1. 创建一个继承自WearableListenerService的类。
1. 监听你关心的事件，比如onDataChanged()。
1. 在Android manifest中声明一个intent filter，通知系统你的WearableListenerService。这样允许系统需要时绑定你的service。
下例展示如何实现一个简单的WearableListenerService：
~~~
public class DataLayerListenerService extends WearableListenerService {
private static final String TAG = "DataLayerSample";
private static final String START_ACTIVITY_PATH = "/start-activity";
private static final String DATA_ITEM_RECEIVED_PATH = "/data-item-received";
@Override
public void onDataChanged(DataEventBuffer dataEvents) {
if (Log.isLoggable(TAG, Log.DEBUG)) {
Log.d(TAG, "onDataChanged: " + dataEvents);
}
final List events = FreezableUtils
.freezeIterable(dataEvents);
GoogleApiClient googleApiClient = new GoogleApiClient.Builder(this)
.addApi(Wearable.API)
.build();
ConnectionResult connectionResult =
googleApiClient.blockingConnect(30, TimeUnit.SECONDS);
if (!connectionResult.isSuccess()) {
Log.e(TAG, "Failed to connect to GoogleApiClient.");
return;
}
// Loop through the events and send a message
// to the node that created the data item.
for (DataEvent event : events) {
Uri uri = event.getDataItem().getUri();
// Get the node id from the host value of the URI
String nodeId = uri.getHost();
// Set the data of the message to be the bytes of the URI
byte[] payload = uri.toString().getBytes();
// Send the RPC
Wearable.MessageApi.sendMessage(googleApiClient, nodeId,
DATA_ITEM_RECEIVED_PATH, payload);
}
}
}
~~~
这是Android mainfest中相应的intent filter：
~~~
<service android:name=".DataLayerListenerService">
<intent-filter>
<action android:name="com.google.android.gms.wearable.BIND_LISTENER" />
</intent-filter>
</service>
~~~
### 数据层回调权限
为了在数据层事件上向你的程序提供回调方法，Google Play services 绑定到你的WearableListenerService，通过IPC调用回调方法。这样的结果是,你的回调方法继承了调用进程的权限。
如果你想在一个回调中执行权限操作,安全检查会失败,因为你的回调是以调用进程的身份运行,而不是应用程序进程的身份运行。
为了解决这个问题,在进入IPC后使用[clearCallingIdentity()](#))重置身份,当你完成权限操作后，使用[restoreCallingIdentity()](#))恢复身份:
~~~
long token = Binder.clearCallingIdentity();
try {
performOperationRequiringPermissions();
} finally {
Binder.restoreCallingIdentity(token);
}
~~~
### 使用监听者 [Activity](# "An activity represents a single screen with a user interface.")
如果你的应用只关心当用户与应用交互时产生的数据层事件，并且不需要一个长时间运行的service来处理每一次数据的改变，那么你可以在一个[activity](# "An activity represents a single screen with a user interface.")中通过实现如下一个和多个接口监听事件：
- [DataApi.DataListener](http://developer.android.com/reference/com/google/android/gms/wearable/DataApi.DataListener.html)
- [MessageApi.MessageListener](http://developer.android.com/reference/com/google/android/gms/wearable/MessageApi.MessageListener.html)
- [NodeApi.NodeListener](http://developer.android.com/reference/com/google/android/gms/wearable/NodeApi.NodeListener.html)
如何创建一个[activity](# "An activity represents a single screen with a user interface.")监听数据事件：
- 实现所需的接口。
- 在onCreate(Bundle)中创建 GoogleApiClient实例。
- 在onStart()中调用connect() 将客户端连接到 Google Play services。
- 当连接到Google Play services后，系统调用 onConnected()。这里你调用[DataApi.addListener()](http://developer.android.com/reference/com/google/android/gms/wearable/DataApi.html#addListener(com.google.android.gms.common.api.GoogleApiClient, com.google.android.gms.wearable.DataApi.DataListener)), [MessageApi.addListener()](http://developer.android.com/reference/com/google/android/gms/wearable/MessageApi.html#addListener(com.google.android.gms.common.api.GoogleApiClient, com.google.android.gms.wearable.MessageApi.MessageListener)), 或 [NodeApi.addListener()](http://developer.android.com/reference/com/google/android/gms/wearable/NodeApi.html#addListener(com.google.android.gms.common.api.GoogleApiClient, com.google.android.gms.wearable.NodeApi.NodeListener))以告知Google Play services，你的[activity](# "An activity represents a single screen with a user interface.")要监听数据层事件。
- 在 onStop()中，用 [DataApi.removeListener()](http://developer.android.com/reference/com/google/android/gms/wearable/DataApi.html#removeListener(com.google.android.gms.common.api.GoogleApiClient, com.google.android.gms.wearable.DataApi.DataListener)), [MessageApi.removeListener()](http://developer.android.com/reference/com/google/android/gms/wearable/MessageApi.html#removeListener(com.google.android.gms.common.api.GoogleApiClient, com.google.android.gms.wearable.MessageApi.MessageListener))或[NodeApi.removeListener()](http://developer.android.com/reference/com/google/android/gms/wearable/NodeApi.html#removeListener(com.google.android.gms.common.api.GoogleApiClient, com.google.android.gms.wearable.NodeApi.NodeListener)) 注销监听。
- 基于你实现的接口继而实现 onDataChanged(), onMessageReceived(), onPeerConnected()和 onPeerDisconnected()。
这是实现DataApi.DataListener的例子 ：
~~~
public class MainActivity extends Activity implements
DataApi.DataListener, ConnectionCallbacks, OnConnectionFailedListener {
private GoogleApiClient mGoogleApiClient;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
mGoogleApiClient = new GoogleApiClient.Builder(this)
.addApi(Wearable.API)
.addConnectionCallbacks(this)
.addOnConnectionFailedListener(this)
.build();
}
@Override
protected void onStart() {
super.onStart();
if (!mResolvingError) {
mGoogleApiClient.connect();
}
}
@Override
public void onConnected(Bundle connectionHint) {
if (Log.isLoggable(TAG, Log.DEBUG)) {
Log.d(TAG, "Connected to Google Api Service");
}
Wearable.DataApi.addListener(mGoogleApiClient, this);
}
@Override
protected void onStop() {
if (null != mGoogleApiClient && mGoogleApiClient.isConnected()) {
Wearable.DataApi.removeListener(mGoogleApiClient, this);
mGoogleApiClient.disconnect();
}
super.onStop();
}
@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());
}
}
}
}
~~~