本指南介绍了如何实现日历数据的“增量同步”。使用此方法,您可以使所有日历集合的数据保持同步,同时节省带宽。
目录
概览
增量同步包含两个阶段:
首次同步时,系统会执行初始完整同步,以便将客户端的状态与服务器的状态完全同步。客户端将获得需要保留的同步令牌。
系统会重复执行增量同步,并使用自上次同步以来发生的所有更改更新客户端。每次,客户端都会提供从服务器获得的先前同步令牌,并存储响应中的新同步令牌。
初始完整同步
初始完整同步是对您要同步的集合的所有资源的原始请求。如果您只想同步特定资源子集,可以选择使用请求参数来限制列表请求。
在对列表操作的响应中,您会找到一个名为
nextSyncToken 的字段,该字段表示同步令牌。您需要存储
nextSyncToken的值。如果结果集过大且响应
分页,则 nextSyncToken
字段仅显示在最后一页上。
增量同步
借助增量同步,您可以检索自上次同步请求以来修改的所有资源。为此,您需要在 syncToken 字段中指定最新的同步令牌,然后执行列表
请求。
请注意,结果将始终包含已删除的条目,以便客户端有机会将其从存储空间中移除。
如果自上次
增量同步请求以来更改了大量资源,您可能会在列表结果中找到 pageToken 而不是 syncToken。在这种情况下,您需要执行与增量同步中用于检索第一页的列表查询完全相同的
查询(使用完全相同的 syncToken),将 pageToken 附加到该查询,然后
对所有后续请求进行分页,直到在最后一页上找到另一个 syncToken。请务必存储此 syncToken,以供日后进行下一次同步
请求时使用。
以下是需要增量分页同步的示例查询:
原始查询
GET /calendars/primary/events?maxResults=10&singleEvents=true&syncToken=CPDAlvWDx70CEPDAlvWDx
// Result contains the following
"nextPageToken":"CiAKGjBpNDd2Nmp2Zml2cXRwYjBpOXA",
检索下一页
GET /calendars/primary/events?maxResults=10&singleEvents=true&syncToken=CPDAlvWDx70CEPDAlvWDx&pageToken=CiAKGjBpNDd2Nmp2Zml2cXRwYjBpOXA
服务器要求的完整同步
有时,服务器会因各种原因(包括令牌过期或相关 ACL 发生更改)而使同步令牌失效。
在这种情况下,服务器将使用
响应代码410响应增量请求。这应触发客户端存储的完全清除和新的完整同步。
示例代码
下面的示例代码段演示了如何将同步令牌与 Java 客户端库搭配使用。首次调用 run 方法时,它将执行完整同步并存储同步令牌。在后续每次执行时,它都会加载已保存的同步令牌并执行增量同步。
private static void run() throws IOException { // Construct the {@link Calendar.Events.List} request, but don't execute it yet. Calendar.Events.List request = client.events().list("primary"); // Load the sync token stored from the last execution, if any. String syncToken = syncSettingsDataStore.get(SYNC_TOKEN_KEY); if (syncToken == null) { System.out.println("Performing full sync."); // Set the filters you want to use during the full sync. Sync tokens aren't compatible with // most filters, but you may want to limit your full sync to only a certain date range. // In this example we are only syncing events up to a year old. Date oneYearAgo = Utils.getRelativeDate(java.util.Calendar.YEAR, -1); request.setTimeMin(new DateTime(oneYearAgo, TimeZone.getTimeZone("UTC"))); } else { System.out.println("Performing incremental sync."); request.setSyncToken(syncToken); } // Retrieve the events, one page at a time. String pageToken = null; Events events = null; do { request.setPageToken(pageToken); try { events = request.execute(); } catch (GoogleJsonResponseException e) { if (e.getStatusCode() == 410) { // A 410 status code, "Gone", indicates that the sync token is invalid. System.out.println("Invalid sync token, clearing event store and re-syncing."); syncSettingsDataStore.delete(SYNC_TOKEN_KEY); eventDataStore.clear(); run(); } else { throw e; } } List<Event> items = events.getItems(); if (items.size() == 0) { System.out.println("No new events to sync."); } else { for (Event event : items) { syncEvent(event); } } pageToken = events.getNextPageToken(); } while (pageToken != null); // Store the sync token from the last request to be used during the next execution. syncSettingsDataStore.set(SYNC_TOKEN_KEY, events.getNextSyncToken()); System.out.println("Sync complete."); }
旧版同步
对于事件集合,您仍然可以采用
旧版方式进行同步,方法是保留事件列表
请求中更新的字段的值,然后使用 modifiedSince 字段检索更新的事件。
我们不再推荐这种方法,因为它更容易出错,例如遗漏更新(如果未强制执行查询限制)。
此外,它仅适用于事件。