Android 建立手机与手表数据同步机制总结

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。

巴特西

Android 建立手机与手表数据同步机制总结

最新文章

热门文章