ouczbs/FastGithub
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

默认超时时间2分钟

Browse Source
This commit is contained in:
xljiulang 2021-07-24 11:56:37 +08:00
parent bd4133aa2c
commit f95b19d024
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
FastGithub.Http/HttpClient.cs
View File

@ -11,6 +11,7 @@ namespace FastGithub.Http
public class HttpClient : HttpMessageInvoker public class HttpClient : HttpMessageInvoker
{ {
private readonly DomainConfig domainConfig; private readonly DomainConfig domainConfig;
private readonly TimeSpan defaltTimeout = TimeSpan.FromMinutes(2d);
/// <summary> /// <summary>
/// http客户端 /// http客户端
@ -50,7 +51,10 @@ namespace FastGithub.Http
TlsSniPattern = this.domainConfig.GetTlsSniPattern(), TlsSniPattern = this.domainConfig.GetTlsSniPattern(),
TlsIgnoreNameMismatch = this.domainConfig.TlsIgnoreNameMismatch TlsIgnoreNameMismatch = this.domainConfig.TlsIgnoreNameMismatch
}); });
return base.SendAsync(request, cancellationToken);
using var timeoutTokenSource = new CancellationTokenSource(this.domainConfig.Timeout ?? defaltTimeout);
using var linkedTokenSource = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, timeoutTokenSource.Token);
return base.SendAsync(request, linkedTokenSource.Token);
} }
} }
} }

4
FastGithub.ReverseProxy/ReverseProxyMiddleware.cs
View File

@ -56,9 +56,7 @@ namespace FastGithub.ReverseProxy
{ {
var destinationPrefix = GetDestinationPrefix(host, domainConfig.Destination); var destinationPrefix = GetDestinationPrefix(host, domainConfig.Destination);
var httpClient = this.httpClientFactory.CreateHttpClient(domainConfig); var httpClient = this.httpClientFactory.CreateHttpClient(domainConfig);
var requestConfig = new ForwarderRequestConfig { Timeout = domainConfig.Timeout }; var error = await httpForwarder.SendAsync(context, destinationPrefix, httpClient);
var error = await httpForwarder.SendAsync(context, destinationPrefix, httpClient, requestConfig);
await HandleErrorAsync(context, error); await HandleErrorAsync(context, error);
} }
} }