如何在Windows Phone 8中为RestClient设置超时时间?

6
我正在使用RestSharp API调用Web服务。但是我遇到了一个问题,当服务器的响应时间超过RestClient的默认超时时间(即100秒)时,我总是得到 StatusCode = NotFound 。我也尝试硬编码Timeout和ReadWriteTimeout参数值,但没有帮助。有人能建议在这里可以做什么吗?
我的代码如下:
public async Task<WebDownloadResult> SyncMobileData(string encryptedstring)
    {
        WebDownloadResult response = new WebDownloadResult();
        var client = new RestClient(BaseUrl + Constants.WEB_SERVICE_NAME);
        client.Timeout = CONN_TIMEOUT;
        client.ReadWriteTimeout = CONN_TIMEOUT;
        var request = new RestRequest(Method.POST);

        byte[] encryptedbytes=System.Text.Encoding.UTF8.GetBytes(encryptedstring);
        request.AddParameter("", encryptedbytes, ParameterType.RequestBody);

        try
        {
            response = await client.GetResponseBytesAsync(request);
        }
        catch (Exception outer)
        {
            response.ErrorOccured = true;
            response.ErrorMessage = outer.Message;
        }
        return response;

    }

假设 CONN_TIMEOUT=600000,下面是我的响应处理类:

public static class RestClientExtensions
{
    private static Task<T> GetResponseFromServer<T>(this RestClient client, IRestRequest request, Func<WebDownloadResult, T> selector)
    {
        var tcs = new TaskCompletionSource<T>();
        WebDownloadResult webResponse = new WebDownloadResult();
        var loginResponse = client.ExecuteAsync(request, r =>
        {

            if (r.ErrorException == null && r.StatusCode == HttpStatusCode.OK)
            {
                webResponse.StatusCode = r.StatusCode;
                webResponse.StatusCodeNumber = (int)r.StatusCode;
                webResponse.Result = r.Content;
                webResponse.ErrorOccured = r.StatusCode == HttpStatusCode.OK ? false : true;
                tcs.SetResult(selector(webResponse));
            }
            else
            {
                tcs.SetException(new Exception(r.StatusCode.ToString()));
            }

        });
        return tcs.Task;
    }

    private static Task<T> GetResponseFromServerForMW<T>(this RestClient client, IRestRequest request, Func<WebDownloadResult, T> selector)
    {
        var tcs = new TaskCompletionSource<T>();
        WebDownloadResult webResponse = new WebDownloadResult();
        var loginResponse = client.ExecuteAsync(request, r =>
        {

            if (r.ErrorException == null && r.StatusCode == HttpStatusCode.OK)
            {
                webResponse.StatusCode = r.StatusCode;
                if (r.Headers.FirstOrDefault(header => header.Name.Equals("P_RET_SYNC_ID")).Value != null)
                {
                    webResponse.AdditionalParameter = r.Headers.FirstOrDefault(header => header.Name.Equals("P_RET_SYNC_ID")).Value;

                }
                webResponse.StatusCodeNumber = (int)r.StatusCode;
                webResponse.Result = r.RawBytes;
                webResponse.ErrorOccured = r.StatusCode == HttpStatusCode.OK ? false : true;
                tcs.SetResult(selector(webResponse));
            }
            else
            {
                tcs.SetException(new Exception(r.StatusCode.ToString()));

            }

        });
        return tcs.Task;
    }

    private static Task<T> GetRawResponseFromServer<T>(this RestClient client, IRestRequest request, Func<WebDownloadResult, T> selector)
    {
        var tcs = new TaskCompletionSource<T>();
        WebDownloadResult webResponse = new WebDownloadResult();
        var loginResponse = client.ExecuteAsync(request, r =>
        {
            if (r.ErrorException == null && r.StatusCode == HttpStatusCode.OK)
            {
                webResponse.StatusCode = r.StatusCode;
                webResponse.StatusCodeNumber = (int)r.StatusCode;
                webResponse.Result = r.RawBytes;
                webResponse.ErrorOccured = r.StatusCode == HttpStatusCode.OK ? false : true;
                tcs.SetResult(selector(webResponse));
            }
            else
            {
                tcs.SetException(new Exception(r.StatusDescription));
            }

        });
        return tcs.Task;
    }

    public static Task<WebDownloadResult> GetResponseAsync(this RestClient client, IRestRequest request)
    {
        return client.GetResponseFromServer(request, r => r);
    }

    public static Task<WebDownloadResult> GetResponseAsyncForMW(this RestClient client, IRestRequest request)
    {
        return client.GetResponseFromServerForMW(request, r => r);
    }

    public static Task<WebDownloadResult> GetResponseBytesAsync(this RestClient client, IRestRequest request)
    {
        return client.GetRawResponseFromServer(request, r => r);
    }


}

以下是 WebDownloadResult

public class WebDownloadResult
{
    public HttpStatusCode StatusCode { get; set; }
    public string ErrorMessage { get; set; }
    public int StatusCodeNumber { get; set; }
    public bool ErrorOccured { get; set; }
    public object Result { get; set; }
    public object AdditionalParameter { get; set; }
}

你理解 CONN_TIMEOUT=600000 意味着多长时间? 你得到 StatusCode=NotFound 意味着 404 http 服务器错误。 - Krunal Mevada
我一开始没有添加CONN_TIMEOUT = 600000,即10分钟的超时时间。我从20秒、30秒等开始尝试,但由于服务器执行某些操作需要时间来发送响应,因此它需要更长的时间。当超过默认的100秒超时时间时,我会收到NotFound错误,但对于其他Web服务,它可以完美地工作。 - Kinjan Bhavsar
1个回答

0

你的代码可能正在使用 默认的 HttpWebRequest.Timeout

请尝试像这样显式地将其传递给 RestRequest -

request.AddParameter("Timeout", options.Timeout.Value);

你可以尝试这样更好的版本 -
var client = new RestClient(baseUrl)
{
    Timeout = someTimeoutInMilliseconds
};

var request = new RestRequest(url)
{
    Method = Method.GET,
    Timeout = someTimeoutInMilliseconds
};

选项只是一个保存超时时间的变量。那篇文章讨论了另一个/无关的问题,尽管复制的代码风格很整齐。值得一试。 - Arvin

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接