[.Net] .net core 使用阿里云分布式日志的配置方法

LogServiceClientBuilders.HttpBuilder
  .Endpoint("<endpoint>", "<projectName>")
  .Credential("<accessKeyId>", "<accessKey>")
  .Build();

using Aliyun.Api.LogService;
using Autofac;
namespace Examples.DependencyInjection
{
  public static class AutofacExample
  {
    public static void Register(ContainerBuilder containerBuilder)
    {
      containerBuilder
        .Register(context => LogServiceClientBuilders.HttpBuilder
          // 服务入口<endpoint>及项目名<projectName>
          .Endpoint("<endpoint>", "<projectName>")
          // 访问密钥信息
          .Credential("<accessKeyId>", "<accessKey>")
          .Build())
        // `ILogServiceClient`所有成员是线程安全的，建议使用Singleton模式。
        .SingleInstance();
    }
  }
}

   

• 实现.net core DI   
  
• 加入队列,让日志先入列,再提交到阿里云,提高系统吞吐量   
  
• 对日志模型进行封装,满足基础业务需求
  

public static AliyunLogBuilder AddAliyunLog(this IServiceCollection services, Action<AliyunSLSOptions> setupAction)
  {
    if (setupAction == null)
    {
      throw new ArgumentNullException(nameof(setupAction));
    }
    //var options = new AliyunSLSOptions();
    //setupAction(options);
    services.Configure(setupAction);
    services.AddHttpClient();
    services.AddSingleton<AliyunSLSClient>();
    services.AddSingleton<AliyunLogClient>();
    services.AddHostedService<HostedService>();
    return new AliyunLogBuilder(services);
  }

/// <summary>
  /// 写日志
  /// </summary>
  /// <param name="log"></param>
  /// <returns></returns>
  public async Task Log(LogModel log)
  {
    AliyunLogBuilder.logQueue.Enqueue(log);
  }

/// <summary>
  /// 消费队列
  /// </summary>
  Task.Run(async () =>
  {
    using (var serviceScope = _provider.GetService<IServiceScopeFactory>().CreateScope())
    {
      var _options = serviceScope.ServiceProvider.GetRequiredService<IOptions<AliyunSLSOptions>>();
      var _client = serviceScope.ServiceProvider.GetRequiredService<AliyunSLSClient>();
      while (true)
      {
        try
        {
          if (AliyunLogBuilder.logQueue.Count>0)
          {
            var log = AliyunLogBuilder.logQueue.Dequeue();
            var logInfo = new LogInfo
            {
              Contents =
            {
              {"Topic", log.Topic.ToString()},
              {"OrderNo", log.OrderNo},
              {"ClassName", log.ClassName},
              { "Desc",log.Desc},
              { "Html",log.Html},
              { "PostDate",log.PostDate},
            },
              Time = DateTime.Parse(log.PostDate)
            };
            List<LogInfo> list = new List<LogInfo>() { logInfo };
            var logGroupInfo = new LogGroupInfo
            {
              Topic = log.Topic.ToString(),
              Source = "localhost",
              Logs = list
            };
            await _client.PostLogs(new PostLogsRequest(_options.Value.LogStoreName, logGroupInfo));
          }
          else
          {
            await Task.Delay(1000);
          }
        }
        catch (Exception ex)
        {
          await Task.Delay(1000);
        }
      }
    }
  });

public class LogModel
  {
    /// <summary>
    /// 所在类
    /// </summary>
    public string ClassName { get; set; }

    /// <summary>
    /// 订单号
    /// </summary>
    public string OrderNo { get; set; }

    /// <summary>
    /// 提交时间
    /// </summary>
    public string PostDate { get; set; }

    /// <summary>
    /// 描述
    /// </summary>
    public string Desc { get; set; }

    /// <summary>
    /// 长字段描述
    /// </summary>
    public string Html { get; set; }
    /// <summary>
    /// 日志主题
    /// </summary>
    public string Topic { get; set; } = "3";
  }

方案A. install-package Aliyun.Log.Core 
方案B. nuget包管理工具搜索 Aliyun.Log.Core

services.AddAliyunLog(m =>
  {
    m.AccessKey = sls.GetValue<string>("AccessKey");
    m.AccessKeyId = sls.GetValue<string>("AccessKeyId");
    m.Endpoint = sls.GetValue<string>("Host");
    m.Project = sls.GetValue<string>("Project");
    m.LogStoreName = sls.GetValue<string>("LogstoreName");
  });

//获取对象
private readonly IOptions<SlsOptions> _options;
private readonly AliyunLogClient _aliyunLogClient;
public HomeController(IOptions<SlsOptions> options, AliyunLogClient aliyunLogClient)
{
  _options = options;
  _aliyunLogClient = aliyunLogClient;
}
[HttpGet("/api/sendlog")]
public async Task<JsonResult> SendLog(string topic="1")
{
  //日志模型
  LogModel logModel = new LogModel()
  {
    ClassName = "Aliyun.log",
    Desc = "6666666666xxxxxx",
    Html = "99999999999xxxxx",
    Topic = topic,
    OrderNo = Guid.NewGuid().ToString("N"),
    PostDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
  };
  await _aliyunLogClient.Log(logModel);
  return Json("0");
}