知識星球本文介紹Ocelot中的QoS(Quality of Service)，其使用了Polly對超時等請求下游失敗等情況進行熔斷。
1、新增Nuget包
新增 Ocelot.Provider.Polly 到OcelotGetway專案中
2、修改 Startup.ConfigureServices 如下來新增Polly：
services
.AddOcelot(new ConfigurationBuilder()
.AddJsonFile("configuration.json")
.Build())
.AddConsul()
.AddPolly()
.AddCacheManager(x => x.WithDictionaryHandle())
.AddAdministration("/administration", "secret");
3、在WebApiA中新增一個SlowController，並新增如下程式碼：
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
namespace WebApiA.Controllers
{
public class SlowController : Controller
{
[Produces("application/json")]
[Route("api/[controller]/[action]")]
public async Task<string> GetName()
{
await Task.Delay(6000);
return "Jonathan";
}
}
}
其中 GetName 延時6秒傳回。
4、在configuration.json的 ReRoutes 節點新增一個新的路由來訪問剛才新增的api方法
{
"DownstreamPathTemplate": "/api/Slow/GetName",
"DownstreamScheme": "http",
"DownstreamHostAndPorts": [
{
"Host": "localhost",
"Port": 5001
}
],
"UpstreamPathTemplate": "/GetName",
"UpstreamHttpMethod": [ "Get" ],
"QoSOptions": {
"ExceptionsAllowedBeforeBreaking":3,
"DurationOfBreak":60000,
"TimeoutValue": 1000
}
}
其中透過 QoSOptions 對該路由新增QoS，對其中的3個屬性解釋如下：
- ExceptionsAllowedBeforeBreaking：發生幾次請求異常（比如超時）後進行熔斷，該值必須大於0
- DurationOfBreak：熔斷時間（單位：毫秒）
- TimeoutValue：下游請求超時時間（單位：毫秒，預設90秒）
用一句話描述上述配置：對http://localhost:5001/api/Slow/GetName請求超過1s將會超時，發生三次超時後保持60s熔斷。
執行WebApiA與OcelotGetway專案，然後請求http://localhost:5000/GetName多次：
可以看到在前3次請求，Time在1000ms之後傳回503，在第四次以後發生熔斷，請求後立即（Time在100ms左右）傳回503。
官方檔案中說可以只配置TimeoutValue而不配置其它兩個來達到修改超時時間的功能，如下：
"QoSOptions": {
"TimeoutValue":5000
}
該配置存在bug，因為如上配置 ExceptionsAllowedBeforeBreaking 將會為0，將會觸發Polly配置異常，我已經向Ocelot提交了一個Pull Request來修複該問題，並且已經被合併到主分支中，預計在下一個版本中該問題將不會存在。
如果你現在想修改超時時間，但是又不想使用熔斷，可以配置如下：
"QoSOptions": {
"ExceptionsAllowedBeforeBreaking":10000,
"DurationOfBreak": 1,
"TimeoutValue": 1000
}
在發生很多次異常才會進行熔斷，並且立即從熔斷中恢復。
相關文章：
原文地址：https://www.jianshu.com/p/c7f5f9515962
