基于Yarp裁剪的支持请求转发 和 影子流量 的HTTP代理组件
- Service Register
builder.Services.AddHttpForwarder(options => {
options.MaxRetries = 3;
options.ShadowSendExceptionHandler = async (url, times,request, error) =>
{
await global::System.Console.Out.WriteLineAsync($"地址:{url}的请求发生第{times}次异常 原因:{error}");
await ValueTask.CompletedTask;
};
});- Using
IHttpForwarder
app.Run(async (ctx) =>
{
ctx.Request.EnableBuffering();
var forward = ctx.RequestServices.GetRequiredService<IHttpForwarder>();
await forward.SendAsync(ctx, new[] { "http:https://demo1.example.com", "http:https://demo2.example.com" }, (u, m) =>
{
Console.WriteLine("此处可以调整请求相关参数，注意：一次修改主请求和影子请求都生效(注意不要重复设置)");
return ValueTask.CompletedTask;
});
});