在 Servicestack JsonServiceClient Get 方法上实现重试的最佳解决方案是什么？

Question

在我的项目中，我使用 Servicestack 从特定的 URL 获取数据，这个过程是可配置的，我在单独的线程中调用获取数据，如果出现超时错误，我想实现重试。我在 JsonServiceClient 上创建了包装器 class 并在那里实现重试，但我想知道这种方法的最佳解决方案是什么。

var _client = new JsonServiceClient { Timeout = timeout };
var counter = 0;
do
{
    try
    {
        result = _client.Get<TResponse>(url);
        break;
    }
    catch (Exception exp)
    {
        //Logging exception
    }
}
while (++counter < this.Retry);

Answer 1

I created wrapper class on JsonServiceClient and implement retry there, but I want to know what's the best solution for this approach.

我同意你的做法。扩展 JsonServiceClient 并实现您的重试逻辑，这是实现可重用性和可维护性的最佳方法，前提是您已实现如下内容。

延长`JsonServiceClient`

扩展 JsonServiceClient 以便您可以合并自己的重试逻辑。然后它可以很容易地在您的代码中重用，而无需使用 while 并且每次您想要发出请求时都会进行计数器。

如果你看到这里的JsonServiceClientBase.cs代码，你会注意到所有的动词方法如Get<TResponse> Post<TResponse> ... Put等都是调用通过Send<TResponse>(object request) 方法。

因此通过重写这个方法，我们可以很容易地在所有动词上实现重试功能，而无需改变它的用法。

public class MyJsonServiceClientWithRetry : JsonServiceClient
{

    public MyJsonServiceClientWithRetry()
    {
    }

    public MyJsonServiceClientWithRetry(int retryAttempts)
    {
        RetryAttempts = retryAttempts;
    }

    public MyJsonServiceClientWithRetry(string baseUri) : base(baseUri)
    {
    }

    public MyJsonServiceClientWithRetry(string syncReplyBaseUri, string asyncOneWayBaseUri) : base(syncReplyBaseUri, asyncOneWayBaseUri)
    {
    }


    // Retry attempts property
    public int RetryAttempts { get; set; }


    public override TResponse Send<TResponse> (string httpMethod, string relativeOrAbsoluteUrl, object request)
    {
        int attempts = RetryAttempts;

        while(true) 
        {
            attempts--;

            try {
                return base.Send<TResponse> (httpMethod, relativeOrAbsoluteUrl, request);
            } catch (WebServiceException webException) {

                // Throw the exception if the number of retries is 0 or we have made a bad request, or are unauthenticated
                if(attempts == 0 || webException.StatusCode == 400 || webException.StatusCode == 401)
                    throw;

            } catch (Exception exception) {

                // Throw the exception if the number of retries is 0
                if(attempts == 0) 
                    throw;
            }
        }
    }
}

用法：

将对 JsonServiceClient 的引用替换为 MyJsonServiceClientWithRetry
设置尝试次数
正常使用客户端。（包装在 try/catch 块中以在超过重试后捕获异常）

var client = new MyJsonServiceClientWithRetry ("http://localhost:8080") {
    RetryAttempts = 3,
    Timeout = new TimeSpan(0, 0, 30)
};


try
{
    var myRequestDto = new MyRequest {
        Name = "John Smith"
    };

    // This request will be attempted 3 times (if there is an exception)
    var response = client.Get<MyResponse>(myRequestDto);

    // Do something with response ...

} catch(Exception ex) {
    // Exception thrown here after 3 attempts (or immediately if status code is 400 / 401)
}

备注：

如果抛出状态代码为 400 或 401 的 WebServiceException，我不会重试，因为在不更改它的情况下再次尝试此请求似乎是多余的。显然你可以自定义这个逻辑。

如果连接超时，则超时错误将作为 WebException 抛出。如果您想专门处理这种情况。

希望对您有所帮助。

在 Servicestack JsonServiceClient Get 方法上实现重试的最佳解决方案是什么？

Whats the best solution to implement retry on Servicestack JsonServiceClient Get method?

c#

servicestack

延长`JsonServiceClient`

用法：

备注：

在 Servicestack JsonServiceClient Get 方法上实现重试的最佳解决方案是什么？

Whats the best solution to implement retry on Servicestack JsonServiceClient Get method?

c#

servicestack

延长JsonServiceClient

用法：

备注：

延长`JsonServiceClient`