Google Drive Change Subscriptions 不起作用？

Question

我正在尝试让 'Change Subscriptions' 为 Android 使用驱动器 API，但到目前为止没有成功。

这里是简单的用例：

2 android 台设备，都使用相同的 google 帐户
他们都在他们的驱动器文件夹中订阅相同的 'file of interest'
如果文件 'changes'，无论是来自两个设备之一还是任何外部源执行的更改，订阅此文件的所有设备都会收到通知

据我所知，这正是 'Change Subscriptions' 应该为我做的。我使用的是播放服务修订版 27。

我遇到的问题：

在一台设备上本地创建的 'file content change'（或其他一些文件事件）永远不会正确传播到订阅同一文件的所有其他设备。

有谁知道这个问题的任何解决方案，或者可以指出我做错了什么？

我写了一些简单的测试代码（见下文），只需要连接 googleApiClient，这是我测试的内容：

1.

device 1 创建一个新的测试文件调用 testFileWriteNew() 并使用 testFileAddAndRemoveSubscription() 添加对此文件的更改订阅，预期的日志输出：

testfile.txt created, driveId=DriveId:CAESABi0AyDAu9XZhVMoAA== resourceId=null
onCompletion; driveId=DriveId:CAESHDBCLXNzaGVuNGlURkFOMGh0ZWtGWU5FeHVTRVUYtAMgwLvV2YVTKAA= resourceId=0B-sshen4iTFAN0htekFYNExuSEU
STATUS_SUCCESS 
added subscription to testfile.txt, driveId=DriveId:CAESHDBCLXNzaGVuNGlURkFOMGh0ZWtGWU5FeHVTRVUYtAMgwLvV2YVTKAA= resourceId=0B-sshen4iTFAN0htekFYNExuSEU

2.

device 2使用testFileAddAndRemoveSubscription()对同一文件添加更改订阅，预期的日志输出：

added subscription to testfile.txt, driveId=DriveId:CAESHDBCLXNzaGVuNGlURkFOMGh0ZWtGWU5FeHVTRVUYwgIg9I-GyZRTKAA= resourceId=0B-sshen4iTFAN0htekFYNExuSEU

正如预期的那样，两个设备上的 driveId 不同，但 resourceId 相同 0B-sshen4iTFAN0htekFYNExuSEU，因此引用了相同的 'cloud' 文件

3.

如果我通过 testFileUpdate 使用一些新数据更新文件，我会在 device 1 上得到以下信息：

testfile.txt updated, driveId=DriveId:CAESHDBCLXNzaGVuNGlURkFOMGh0ZWtGWU5FeHVTRVUYtAMgwLvV2YVTKAA= resourceId=0B-sshen4iTFAN0htekFYNExuSEU

和device 2:

testfile.txt updated, driveId=DriveId:CAESHDBCLXNzaGVuNGlURkFOMGh0ZWtGWU5FeHVTRVUYwgIg9I-GyZRTKAA= resourceId=0B-sshen4iTFAN0htekFYNExuSEU

4.

遗憾的是，服务的onChange方法中的'change of content'只在本地触发。 device 1 所做的更改永远不会到达 device 2，反之亦然。如果我使用 device 2 更新文件，我会在 device 2 上看到来自服务的以下日志：

onChange; driveId=DriveId:CAESHDBCLXNzaGVuNGlURkFOMGh0ZWtGWU5FeHVTRVUYwgIg9I-GyZRTKAA= resourceId=0B-sshen4iTFAN0htekFYNExuSEU
contentChanged
onChange; driveId=DriveId:CAESHDBCLXNzaGVuNGlURkFOMGh0ZWtGWU5FeHVTRVUYwgIg9I-GyZRTKAA= resourceId=0B-sshen4iTFAN0htekFYNExuSEU
metadataChanged

但我从未见过 onChange 方法在 device 1 上被触发，如果 device 2 触发了我期望的变化。

代码：

private boolean testFileWriteNew() {
    final DriveFolder folderRoot = Drive.DriveApi.getRootFolder(mGoogleApiClient);
    DriveContentsResult contentsResult = Drive.DriveApi.newDriveContents(mGoogleApiClient).await();
    if (!contentsResult.getStatus().isSuccess()) {
        return false;
    }
    DriveContents originalContents = contentsResult.getDriveContents();
    OutputStream os = originalContents.getOutputStream();

    try {
        os.write(String.valueOf(System.currentTimeMillis()).getBytes());
        MetadataChangeSet originalMetadata = new MetadataChangeSet.Builder().setTitle("testfile.txt").setMimeType("text/plain").build();
        // create the file in root
        DriveFolder.DriveFileResult fileResult = folderRoot.createFile(mGoogleApiClient, originalMetadata, originalContents, new ExecutionOptions.Builder().setNotifyOnCompletion(true).build()).await();
        if (!fileResult.getStatus().isSuccess()) {
            return false;
        }
        // check 'locally created' file, not yet synced to drive
        DriveResource.MetadataResult metadataResult = fileResult.getDriveFile().getMetadata(mGoogleApiClient).await();
        if (!metadataResult.getStatus().isSuccess()) {
            return false;
        }
        Log.d(TAG, "testfile.txt created, driveId=" + metadataResult.getMetadata().getDriveId().encodeToString() + " resourceId=" + metadataResult.getMetadata().getDriveId().getResourceId());
        return true;
    } catch (IOException ioe) {
        return false;
    }
}


private boolean testFileUpdate() {
    final DriveFolder folderRoot = Drive.DriveApi.getRootFolder(mGoogleApiClient);

    // find testfile
    DriveId testFile = null;
    MetadataBufferResult folderFilesSyncFolder = folderRoot.listChildren(mGoogleApiClient).await();
    if (!folderFilesSyncFolder.getStatus().isSuccess()) {
        return false;
    } else {
        MetadataBuffer bufferMetaData = folderFilesSyncFolder.getMetadataBuffer();
        for(int i = 0; i < bufferMetaData.getCount(); ++i) {
            final Metadata data = bufferMetaData.get(i);
            if(!data.isFolder() && !data.isTrashed() && data.isEditable() && data.getTitle().equalsIgnoreCase("testfile.txt")) {
                testFile = data.getDriveId();
                break;
            }
        }
        bufferMetaData.release();
    }

    if(testFile == null) {
        return false;
    }

    // update testfile
    DriveFile file = Drive.DriveApi.getFile(mGoogleApiClient, testFile);
    DriveContentsResult driveContentsResult = file.open(mGoogleApiClient, DriveFile.MODE_WRITE_ONLY, null).await();
    if (!driveContentsResult.getStatus().isSuccess()) {
        return false;
    }
    DriveContents originalContents = driveContentsResult.getDriveContents();
    OutputStream os = originalContents.getOutputStream();
    try {
        os.write(String.valueOf(System.currentTimeMillis()).getBytes());
        // commit changes
        com.google.android.gms.common.api.Status status = originalContents.commit(mGoogleApiClient, null).await();
        if(!status.isSuccess()) {
            return false;

        }
        Log.d(TAG, "testfile.txt updated, driveId=" + file.getDriveId().encodeToString() + " resourceId=" + file.getDriveId().getResourceId());
        return true;
    } catch (IOException ioe) {
        return false;
    }
}

private boolean testFileAddAndRemoveSubscription(boolean subscribe) {
    final DriveFolder folderRoot = Drive.DriveApi.getRootFolder(mGoogleApiClient);

    // find testfile
    DriveId testFile = null;
    MetadataBufferResult folderFilesSyncFolder = folderRoot.listChildren(mGoogleApiClient).await();
    if (!folderFilesSyncFolder.getStatus().isSuccess()) {
        return false;
    } else {
        MetadataBuffer bufferMetaData = folderFilesSyncFolder.getMetadataBuffer();
        for(int i = 0; i < bufferMetaData.getCount(); ++i) {
            final Metadata data = bufferMetaData.get(i);
            if(!data.isFolder() && !data.isTrashed() && data.isEditable() && data.getTitle().equalsIgnoreCase("testfile.txt")) {
                testFile = data.getDriveId();
                break;
            }
        }
        bufferMetaData.release();
    }

    if(testFile == null) {
        return false;
    }

    // subscribe & unsubscribe
    DriveFile file = Drive.DriveApi.getFile(mGoogleApiClient, testFile);
    if(subscribe) {
        com.google.android.gms.common.api.Status status = file.addChangeSubscription(mGoogleApiClient).await();
        if(!status.isSuccess()) {
            return false;
        }
        Log.d(TAG, "added subscription to testfile.txt, driveId=" + file.getDriveId().encodeToString() + " resourceId=" + file.getDriveId().getResourceId());
        return true;
    } else {
        com.google.android.gms.common.api.Status status = file.removeChangeSubscription(mGoogleApiClient).await();
        if(!status.isSuccess()) {
            return false;
        }
        Log.d(TAG, "removed subscription from testfile.txt, driveId=" + file.getDriveId().encodeToString() + " resourceId=" + file.getDriveId().getResourceId());
        return true;
    }
}

这里是服务 class:

public class ChangeService extends DriveEventService {

    // TAG
    private static final String TAG = ChangeService.class.getSimpleName();

    @Override
    public void onChange(ChangeEvent event) {
        final DriveId driveId = event.getDriveId();
        Log.e(TAG, "onChange; driveId=" + driveId.encodeToString() + " resourceId=" + driveId.getResourceId());
        if(event.hasContentChanged())       { Log.e(TAG, "contentChanged"); }
        else if(event.hasMetadataChanged()) { Log.e(TAG, "metadataChanged"); }
        else if(event.hasBeenDeleted())     { Log.e(TAG, "beenDeleted"); }
    }

    @Override
    public void onCompletion(CompletionEvent event) {
        final DriveId driveId = event.getDriveId();
        Log.e(TAG, "onCompletion; driveId=" + driveId.encodeToString() + " resourceId=" + driveId.getResourceId());
        switch (event.getStatus()) {
          case CompletionEvent.STATUS_CONFLICT:  Log.e(TAG, "STATUS_CONFLICT");  break;
          case CompletionEvent.STATUS_FAILURE:   Log.e(TAG, "STATUS_FAILURE");   break;
          case CompletionEvent.STATUS_SUCCESS:   Log.e(TAG, "STATUS_SUCCESS ");  break;
          case CompletionEvent.STATUS_CANCELED:  Log.e(TAG, "STATUS_CANCELED "); break;
        }
        event.dismiss();
    }

}

Answer 1

我相信，您正陷入与我们许多人以前一样的陷阱。我最初也假设 'DriveEventService' 负责同一帐户下多个设备运行之间的通知。 see here 我尝试过但惨遭失败（请注意自 2014 年 4 月以来的彻底沉默）。我总是只在一台设备上获取事件。所以，我实际上意识到 Change Events 仅在 GooPlaySvcs 实例中本地工作。

Steve Bazyl 在 this unrelated answer 中的评论或多或少证实了这一点（请阅读包括 'ORIGINAL POST' 的段落），证实了我的理论 'Change Events' 和 'Completion Events' 是本地的（完成事件报告网络操作的结果 - 如 http 响应）。

所以回答你的问题。经过一段时间的斗争，我不得不制定一个不同的策略：

1/ 执行 GDAA 操作（创建、更新）
2/ 等待指示您的 mod 已提升为驱动器
的完成事件 3/ 向注册参与者广播包含 ResourceId ( !) 和可选数据（最大 4K）的 GCM 消息。
4/ 'Registered participants' 回复消息并下载更新 metadata/content，解决冲突。

此解决方案来自 2014 年夏季，此后可能还有其他一些来自 Google 的预打包解决方案。我很高兴听到知道是否有更优雅的解决方案的人的意见。

坦率地说，如果完成事件没有及时反映（通知）来自另一台设备的更新，我不明白 this and this 是什么意思。

祝你好运

Google Drive Change Subscriptions 不起作用？

Google Drive Change Subscriptions not working?

android

listener

google-play-services

google-drive-android-api