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

首页 > 代码库 > Android 建立手机与手表数据同步机制总结

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

2024-07-18 16:40:23 220人阅读

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。

声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉：投诉/举报工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。

联系
我们

首页 > 代码库 > Android 建立手机与手表数据同步机制总结

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

看完仍有疑问？有类似问题直接问程序猿