如何使用 SyncAdapter 处理远程服务器的 RESTful 更新

我观看了 Google I/O REST 演讲并阅读了幻灯片：http://www.google.com/events/io/2010/sessions/developing-RESTful-android-apps.html http://www.google.com/events/io/2010/sessions/developing-RESTful-android-apps.html

我仍然有点不清楚如何很好地处理远程服务器抛出的更新错误。我已经实现了自己的 ContentProvider 和 SyncAdapter。考虑这种情况：

通过 REST 调用更新用户的联系方式：

1. 使用 ContentResolver 请求更新。
2. 我的内容提供商立即地更新应用程序的本地 Sqlite 数据库并请求同步（按照 Google I/O 演讲中的建议）。
3. 我的 SyncAdapter.onPerformSync() 被调用并执行 REST 调用来更新远程数据。
4. 远程服务器响应“错误：无效的电话号码”（例如）。

我的问题是，SyncAdapter 向我的 ContentProvider 发出信号表明此更改需要从应用程序的本地数据库中撤回，并向我的 Activity 发出信号表明更新请求失败（并传递返回的错误消息）的最佳方式是什么从服务器）？

我的活动需要在等待结果时显示进度微调器，并了解请求是成功还是失败。

为了使用服务器中的内容更新本地应用程序数据库，SyncAdapter 模式对我来说完全有意义，而且我工作得很好。但对于更新from该应用程序to服务器，我似乎找不到处理上述情况的好方法。

还有一件事......;）

假设我调用 ContentResolver.notifyChange(uri, null, true);从我的 ContentProvider 的 update() 方法中。true随着android:supportsUploading="true"将导致我的 SyncAdapter 的 onPerformSync() 被调用。很好，但是在 onPerformSync() 内部，我如何知道应该同步哪个 URI？我不想每次收到同步请求时都简单地刷新整个数据库。但您甚至无法将 Bundle 传递到 notificationChangeCall() 中以传递给 onPerformSync()。

我见过的 onPerformSync() 的所有示例都非常简单，并且没有使用自定义 ContentProvider，有任何现实世界的示例吗？这些文档有点像鸟巢。 Virgil Doobjanschi，先生，您让我在没有桨的情况下留在小溪里。

如果您的目标是 API 级别 7，简短的回答是“不要”。这种情况在后来的 API 中可能有所改善，但事实上……我强烈建议完全避免使用 SyncAdapter；它的记录非常糟糕，并且“自动”帐户/身份验证管理的代价很高，因为它的 API 也很复杂且记录不足。除了最琐碎的用例之外，API 的这一部分还没有经过深思熟虑。

这就是我最终采用的模式。在我的活动中，我有一个处理程序，其中包含来自自定义处理程序超类的简单添加（可以检查m_bStopped bool):

private ResponseHandler mHandler = new ResponseHandler();

class ResponseHandler extends StopableHandler {

    @Override
    public void handleMessage(Message msg) {
        if (isStopped()) {
            return;
        }
        if (msg.what == WebAPIClient.GET_PLANS_RESPONSE) {
            ...
        } 
        ...
    }
}

该活动将调用 REST 请求，如下所示。请注意，处理程序被传递到 WebClient 类（用于构建/发出 HTTP 请求等的帮助程序类）。 WebClient 在接收到返回给活动的消息的 HTTP 响应时使用此处理程序，并让它知道数据已被接收，并且在我的情况下，已存储在 SQLite 数据库中（我建议这样做）。在大多数活动中，我会调用mHandler.stopHandler(); in onPause() and mHandler.startHandler(); in onResume()以避免 HTTP 响应被发送回非活动活动等。事实证明这是一个非常强大的方法。

final Bundle bundle = new Bundle();
bundle.putBoolean(WebAPIRequestHelper.REQUEST_CREATESIMKITORDER, true);
bundle.putString(WebAPIRequestHelper.REQUEST_PARAM_KIT_TYPE, sCVN);       
final Runnable runnable = new Runnable() { public void run() {
    VendApplication.getWebClient().processRequest(null, bundle, null, null, null,
                    mHandler, NewAccountActivity.this);
    }};
mRequestThread = Utils.performOnBackgroundThread(runnable);

Handler.handleMessage()在主线程上调用。因此，您可以在此处停止进度对话框并安全地执行其他活动操作。

我声明了一个 ContentProvider：

<provider android:name="au.com.myproj.android.app.webapi.WebAPIProvider"
          android:authorities="au.com.myproj.android.app.provider.webapiprovider"
          android:syncable="true" />

并实现它来创建和管理对 SQLite 数据库的访问：

public class WebAPIProvider extends ContentProvider

因此，您可以将光标放在活动中的数据库上，如下所示：

mCursor = this.getContentResolver().query (
          WebAPIProvider.PRODUCTS_URI, null, 
          Utils.getProductsWhereClause(this), null, 
          Utils.getProductsOrderClause(this));
startManagingCursor(mCursor);

我找到了org.apache.commons.lang3.text.StrSubstitutor类对于构建 REST API 所需的笨拙 XML 请求非常有帮助，我必须与例如集成在WebAPIRequestHelper我有类似的辅助方法：

public static String makeAuthenticateQueryString(Bundle params)
{
    Map<String, String> valuesMap = new HashMap<String, String>();
    checkRequiredParam("makeAuthenticateQueryString()", params, REQUEST_PARAM_ACCOUNTNUMBER);
    checkRequiredParam("makeAuthenticateQueryString()", params, REQUEST_PARAM_ACCOUNTPASSWORD);

    valuesMap.put(REQUEST_PARAM_APIUSERNAME, API_USERNAME);
    valuesMap.put(REQUEST_PARAM_ACCOUNTNUMBER, params.getString(REQUEST_PARAM_ACCOUNTNUMBER));
    valuesMap.put(REQUEST_PARAM_ACCOUNTPASSWORD, params.getString(REQUEST_PARAM_ACCOUNTPASSWORD));

    String xmlTemplate = VendApplication.getContext().getString(R.string.XMLREQUEST_AUTHENTICATE_ACCOUNT);
    StrSubstitutor sub = new StrSubstitutor(valuesMap);
    return sub.replace(xmlTemplate);
}

我会将其附加到适当的端点 URL。

以下是有关 WebClient 类如何执行 HTTP 请求的更多详细信息。这是processRequest()之前在 Runnable 中调用的方法。注意handler参数，用于将结果消息返回给ResponseHandler我在上面描述过。这syncResult是 SyncAdapter 使用的 out 参数来进行指数退避等。我在executeRequest()，增加它的各种错误计数等。同样，文档非常少，需要 PITA 才能工作。parseXML()发挥了卓越的作用简单的 XML 库 http://simple.sourceforge.net/.

public synchronized void processRequest(Account account, Bundle extras, String authority, ContentProviderClient provider, SyncResult syncResult, Handler handler, Context context)
{
    // Helper to construct the query string from the query params passed in the extras Bundle.
    HttpUriRequest request = createHTTPRequest(extras);
    // Helper to perform the HTTP request using org.apache.http.impl.client.DefaultHttpClient.
    InputStream instream = executeRequest(request, syncResult);

    /*
     * Process the result.
     */
    if(extras.containsKey(WebAPIRequestHelper.REQUEST_GETBALANCE))
    {
        GetServiceBalanceResponse xmlDoc = parseXML(GetServiceBalanceResponse.class, instream, syncResult);
        Assert.assertNotNull(handler);
        Message m = handler.obtainMessage(WebAPIClient.GET_BALANCE_RESPONSE, xmlDoc);
        m.sendToTarget();
    }
    else if(extras.containsKey(WebAPIRequestHelper.REQUEST_GETACCOUNTINFO))
    {
      ...
    }
    ...

}

您应该对 HTTP 请求设置一些超时，这样应用程序就不会在移动数据丢失或从 Wifi 切换到 3G 时永远等待。如果发生超时，这将导致抛出异常。

    // Set the timeout in milliseconds until a connection is established.
    int timeoutConnection = 30000;
    HttpConnectionParams.setConnectionTimeout(httpParameters, timeoutConnection);
    // Set the default socket timeout (SO_TIMEOUT) in milliseconds which is the timeout for waiting for data.
    int timeoutSocket = 30000;
    HttpConnectionParams.setSoTimeout(httpParameters, timeoutSocket);
    HttpClient client = new DefaultHttpClient(httpParameters);          

总的来说，SyncAdapter 和 Accounts 的东西非常痛苦，花费了我很多时间却没有任何收获。 ContentProvider 相当有用，主要用于游标和事务支持。 SQLite 数据库非常好。 Handler 类非常棒。我现在将使用 AsyncTask 类，而不是像上面那样创建自己的线程来生成 HTTP 请求。

我希望这个漫无目的的解释对某人有所帮助。