Android Wear 数据同步机制总结
当手机与手表建立蓝牙连接之后,数据就可以通过Google Play Service进行传输。
同步数据对象Data Item
DataItem提供手机与手表数据存储的自动同步,一个DataItem对象由其创建者与路径组成的URI所确定。一个DataItem对象为手机和手表提供了一个数据通路,开发者通过改变指定的DataItem实现手机和手表的数据自动同步。
访问数据层API
DataItem可以提供手机和手表数据的保存,改变该对象的操作则依赖数据层API(the Data Layer APIs),也就是说,在改变DataItem数据之前,需要先访问数据层,获得一个GoogleApiClient实例,从而能够使用数据层API。
下面是实例化GoogleApiClient的代码
GoogleApiClient mGoogleAppiClient = new GoogleApiClient.Builder(this) .addConnectionCallbacks(new ConnectionCallbacks() { @Override public void onConnected(Bundle connectionHint) { Log.d(TAG, "onConnected: " + connectionHint); // Now you canuse the data layer API } @Override public void onConnectionSuspended(int cause) { Log.d(TAG, "onConnectionSuspended: " + cause); } }) .addOnConnectionFailedListener(new OnConnectionFailedListener() { @Override public void onConnectionFailed(ConnectionResult result) { Log.d(TAG, "onConnectionFailed: " + result); } }) .addApi(Wearable.API) .build();
在使用数据层Api的之前,需要先调用connect()方法,如果成功则会回调onConnected()方法,否则回调onConnectionFailed()。
同步DataItems
GoogleApiClient连接成功后,就可以通过DataItem进行数据同步了。
一个DataItem包括连个部分,一个是Payload,这是一个字节数组,可以通过序列化或者反序列化保存需要的数据类型和对象;另一个是Path,这是一个唯一的字符串,由反斜杠开头,区别不同的DataItem。
通常在开发过程中是使用DataMap类实现DataItem接口,类似Bundle键值对的存储方式。
下面是使用的DataMap步骤:
1、 创建PutDataMapRequest对象,为DataItem设置path值;
2、 使用put…()方法为DataMap设置需要的数据;
3、 调用PutDataMapRequest.asPutDataRequest()创建PutDataRequest对象;
4、 调用DataApi.putDataItem()请求系统创建DataItem。
如果此时手机和手表没有建立连接,则会将数据保存在Buffer中,等下次连接后会发送到另一方。
下面是使用DataMap创建DataItem的方法
PutDataMapRequest dataMap = PutDataMapRequest.create("/count"); dataMap.getDataMap().putInt(COUNT_KEY, count++); PutDataRequest request = dataMap.asPutDataRequest(); PendingResult<DataApi.DataItemResult> pendingResult = Wearable.DataApi .putDataItem(mGoogleApiClient, request);
监听数据层事件
由于数据层同步或发送的数据连接手机和手表,所以经常需要获知何时DataItem被创建以及手机与手表什么时候连接或断开等事件。
监听数据层时间可以使用两种方式,一种是继承WearableListenerService,一种是在Activity中实现DataApi.DataListener。无论使用两种方式的哪种,可以重写其需要的回调方法执行相应的操作。
1、 使用WearableListenerService
该service在手机和手表端都可以使用,如果在一方不需要监听数据层时间可以不适用该服务。
例如,可以在手机端接收和设置DataItem,然后在手表端实现该服务,监听数据层的事件,从而修改手表的UI。
WearableListenerService提供回调接口onDataChanged()处理DataItem的变化,当DataItem被创建、更改或删除,手机和手表的该事件将被触发。
下面是使用WearableListenerService的方法
1、 创建一个类继承WearableListenerService;
2、 监听需要的事件,如onDataChanged();
3、 在配置文件中声明一个intentfilter通知系统监听WearableListenerService,这样在系统需要的时候就会绑定WearableListenerService。
下面代码是一个简单的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); } } }
下面代码是配置文件中声明的intentfilter
<service android:name=".DataLayerListenerService"> <intent-filter> <action android:name="com.google.android.gms.wearable.BIND_LISTENER" /> </intent-filter> </service>
使用DataApi.DataListener监听数据层
如果不需要后台长时间进行监听,可以使用DataApi.DataListener进行监听,下面是使用该方式的方法。
1、 使用DataApi.DataListener接口
2、 在onCreate中创建 GoogleApiClient,访问数据层API
3、 在onStart中调用connect()连接Google PlayService
4、 但连接上GooglePlay Service后,系统调用onConnected(),通知Google Play service该activity监听数据层事件
5、 在onStop中调用DataApi.removeListener()
6、 实现 onDataChanged()回调
下面是使用DataApi.DataListener监听数据层事件的代码
public class MainActivity extends Activity implements DataApi.DataListener, ConnectionCallbacks, OnConnectionFailedListener { @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()); } } }
获取手机通知大家的服务
Android提供了一个服务类接口NotificationListenerService,继承该服务,可以获取手机中应用发起的通知,在配置文件中需要添加如下声明和权限
<service android:name=".NotificationListener" android:label="@string/service_name" android:permission="android.permission.BIND_NOTIFICATION_LISTENER_SERVICE"> <intent-filter> <action android:name="android.service.notification.NotificationListenerService" /> </intent-filter> </service>
这样在系统设置中会出现一个是否允许该服务捕获通知的选项,在设置--安全与隐私--通知读取权限
该服务有两个抽象方法需要实现,分别是当有通知发起与通知被销毁,都会触发其回调方法。
public class NotificationCollectorService extends NotificationListenerService { @Override public void onNotificationPosted(StatusBarNotification sbn) { } @Override public void onNotificationRemoved(StatusBarNotification sbn) { } }
也就是说当系统发现某应用产生通知或者用户删除某通知,都会回调该服务的这两个函数,函数的参数StatusBarNotification包含着该通知的具体信息。
如果是在Android Wear开发中,使用该方法捕获手机的通知,然后同步到手表中,就是使用该服务进行的中转。
通知同步
接收到的通知以StatusBarNotification对象形式传递给回调函数onNotificationPosted(),
调用StatusBarNotification对象的公共方法,分别取出StatusBarNotification中的PackageName、Tag、Id、notification对象和PostTime,通过这些值去创建DataItem。