243 lines
9.5 KiB
C#
243 lines
9.5 KiB
C#
//
|
||
// HttpLogServiceClientBuilder.cs
|
||
//
|
||
// Author:
|
||
// MiNG <developer@ming.gz.cn>
|
||
//
|
||
// Copyright (c) 2018 Alibaba Cloud
|
||
//
|
||
// Permission is hereby granted, free of charge, to any person obtaining a copy
|
||
// of this software and associated documentation files (the "Software"), to deal
|
||
// in the Software without restriction, including without limitation the rights
|
||
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||
// copies of the Software, and to permit persons to whom the Software is
|
||
// furnished to do so, subject to the following conditions:
|
||
//
|
||
// The above copyright notice and this permission notice shall be included in
|
||
// all copies or substantial portions of the Software.
|
||
//
|
||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||
// THE SOFTWARE.
|
||
|
||
using System;
|
||
using System.Net;
|
||
using System.Net.Http;
|
||
using Aliyun.Api.LogService.Infrastructure.Authentication;
|
||
using Aliyun.Api.LogService.Utils;
|
||
|
||
namespace Aliyun.Api.LogService.Infrastructure.Protocol.Http
|
||
{
|
||
public class HttpLogServiceClientBuilder
|
||
{
|
||
private Uri endpoint;
|
||
|
||
private Func<Credential> credentialProvider;
|
||
|
||
private Boolean? useProxy;
|
||
|
||
private WebProxy proxy;
|
||
|
||
private TimeSpan? timeout;
|
||
|
||
/// <summary>
|
||
/// 设置服务入口地址以及项目名称。
|
||
/// </summary>
|
||
/// <param name="endpoint">服务入口地址，协议部分可以忽略（支持如：end.point 或 http://end.point 或 https://end.point）。</param>
|
||
/// <param name="project">项目名称。</param>
|
||
/// <returns>当前实例。</returns>
|
||
public HttpLogServiceClientBuilder Endpoint(String endpoint, String project)
|
||
{
|
||
Ensure.NotEmpty(endpoint, nameof(endpoint));
|
||
Ensure.NotEmpty(project, nameof(project));
|
||
|
||
this.endpoint = parseUri(endpoint, project);
|
||
|
||
return this;
|
||
}
|
||
|
||
private Uri parseUri(String endpoint, String project)
|
||
{
|
||
Uri uri;
|
||
if (endpoint.StartsWith("http://"))
|
||
{
|
||
uri = new UriBuilder(endpoint.Insert(7, project + ".")).Uri;
|
||
} else if (endpoint.StartsWith("https://"))
|
||
{
|
||
uri = new UriBuilder(endpoint.Insert(8, project + ".")).Uri;
|
||
} else
|
||
{
|
||
uri = new UriBuilder("http://" + project + "." + endpoint).Uri;
|
||
}
|
||
|
||
return uri;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置服务入口地址以及项目名称。
|
||
/// </summary>
|
||
/// <param name="endpoint">服务入口地址。</param>
|
||
/// <param name="project">项目名称。</param>
|
||
/// <returns>当前实例。</returns>
|
||
public HttpLogServiceClientBuilder Endpoint(Uri endpoint, String project)
|
||
{
|
||
Ensure.NotNull(endpoint, nameof(endpoint));
|
||
Ensure.NotEmpty(project, nameof(project));
|
||
|
||
this.endpoint = parseUri(endpoint.Host, project);
|
||
|
||
return this;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置服务使用的 accessKeyId 和 accessKey，此方法设置的凭据只能用于 RAM 模式下的主账号/子账号的访问。
|
||
/// 跨账号访问需要使用 STS 模式并定时刷新凭据信息，<see cref="Credential(Func{Aliyun.Api.LogService.Infrastructure.Authentication.Credential})"/>。
|
||
/// </summary>
|
||
/// <param name="accessKeyId">accessKeyId。</param>
|
||
/// <param name="accessKey">accessKey。</param>
|
||
/// <returns>当前实例。</returns>
|
||
public HttpLogServiceClientBuilder Credential(String accessKeyId, String accessKey)
|
||
{
|
||
Ensure.NotEmpty(accessKeyId, nameof(accessKeyId));
|
||
Ensure.NotEmpty(accessKey, nameof(accessKey));
|
||
|
||
var credential = new Credential(accessKeyId, accessKey);
|
||
this.credentialProvider = () => credential;
|
||
|
||
return this;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置服务使用的 accessKeyId、 accessKey 及 stsToken 的动态提供者。
|
||
/// 此方法设置的凭据支持 RAM 及 STS 模式。
|
||
/// </summary>
|
||
/// <param name="credentialProvider">凭据提供者。需要注意的是提供的 <paramref name="credentialProvider"/> 在每次请求中都会被调用，请注意缓存有效的服务凭据。</param>
|
||
/// <returns>当前实例。</returns>
|
||
public HttpLogServiceClientBuilder Credential(Func<Credential> credentialProvider)
|
||
{
|
||
Ensure.NotNull(credentialProvider, nameof(credentialProvider));
|
||
|
||
this.credentialProvider = credentialProvider;
|
||
|
||
return this;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置连接是否使用代理。
|
||
/// 如果无法确定是否需要使用，或想使用系统默认配置，请跳过此方法的调用即可。
|
||
/// </summary>
|
||
/// <param name="useProxy"><c>true</c> 表示使用代理，<c>false</c> 表示不使用代理（同时会跳过系统级别的代理设置）。</param>
|
||
/// <returns>当前实例。</returns>
|
||
public HttpLogServiceClientBuilder UseProxy(Boolean useProxy)
|
||
{
|
||
this.useProxy = useProxy;
|
||
|
||
return this;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置使用代理的信息。
|
||
/// 如果 <see cref="UseProxy"/> 设置为 <c>false</c> 则此项设置无意义。
|
||
/// </summary>
|
||
/// <param name="proxyHost">代理地址（必填）。</param>
|
||
/// <param name="proxyPort">代理端口（可选），不填则使用默认端口。</param>
|
||
/// <param name="proxyUserName">代理验证用户（可选），不填则跳过验证。</param>
|
||
/// <param name="proxyPassword">代理验证密码（可选），不填或者 <paramref name="proxyUserName"/> 为空时跳过验证。</param>
|
||
/// <param name="proxyDomain">代理验证域（可选）。</param>
|
||
/// <returns>当前实例。</returns>
|
||
public HttpLogServiceClientBuilder Proxy(String proxyHost,
|
||
Int32? proxyPort = null, String proxyUserName = null, String proxyPassword = null, String proxyDomain = null)
|
||
{
|
||
Ensure.NotEmpty(proxyHost, nameof(proxyHost));
|
||
|
||
var webProxy = proxyPort.HasValue
|
||
? new WebProxy(proxyHost, proxyPort.Value)
|
||
: new WebProxy(proxyHost);
|
||
|
||
if (proxyUserName.IsNotEmpty())
|
||
{
|
||
webProxy.Credentials = proxyDomain.IsEmpty()
|
||
? new NetworkCredential(proxyUserName, proxyPassword ?? String.Empty)
|
||
: new NetworkCredential(proxyUserName, proxyPassword ?? String.Empty, proxyDomain);
|
||
}
|
||
|
||
this.proxy = webProxy;
|
||
|
||
return this;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置请求超时时间，单位毫秒，需要使用其它单位的请使用 <see cref="RequestTimeout(TimeSpan)"/>。
|
||
/// 如跳过此项设置，则使用底层框架的默认超时时间。
|
||
/// </summary>
|
||
/// <param name="timeoutMillis">请求超时时间，单位毫秒。</param>
|
||
/// <returns>当前实例。</returns>
|
||
public HttpLogServiceClientBuilder RequestTimeout(Int32 timeoutMillis)
|
||
{
|
||
return this.RequestTimeout(TimeSpan.FromMilliseconds(timeoutMillis));
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置请求超时时间。
|
||
/// 如跳过此项设置，则使用底层框架的默认超时时间。
|
||
/// </summary>
|
||
/// <param name="timeout">请求超时时间。</param>
|
||
/// <returns>当前实例。</returns>
|
||
public HttpLogServiceClientBuilder RequestTimeout(TimeSpan timeout)
|
||
{
|
||
this.timeout = timeout;
|
||
|
||
return this;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据上述设置构建 <see cref="HttpLogServiceClient"/>。
|
||
/// </summary>
|
||
/// <returns>构建好的 <see cref="HttpLogServiceClient"/>。</returns>
|
||
public HttpLogServiceClient Build()
|
||
{
|
||
Ensure.NotNull(this.endpoint, nameof(this.endpoint));
|
||
Ensure.NotNull(this.credentialProvider, nameof(this.credentialProvider));
|
||
|
||
HttpClient httpClient;
|
||
if (this.useProxy != null || this.proxy != null)
|
||
{
|
||
var httpClientHandler = new HttpClientHandler();
|
||
|
||
if (this.useProxy != null)
|
||
{
|
||
httpClientHandler.UseProxy = this.useProxy.Value;
|
||
}
|
||
|
||
if (this.proxy != null)
|
||
{
|
||
httpClientHandler.Proxy = this.proxy;
|
||
}
|
||
|
||
httpClient = new HttpClient(httpClientHandler);
|
||
} else
|
||
{
|
||
httpClient = new HttpClient();
|
||
}
|
||
|
||
httpClient.BaseAddress = this.endpoint;
|
||
|
||
// Default use project scope api.
|
||
httpClient.DefaultRequestHeaders.Host = this.endpoint.Host;
|
||
|
||
if (this.timeout != null)
|
||
{
|
||
httpClient.Timeout = this.timeout.Value;
|
||
}
|
||
|
||
var client = new HttpLogServiceClient(httpClient, this.credentialProvider);
|
||
|
||
return client;
|
||
}
|
||
}
|
||
}
|