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();
        }
    }
}

 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";

  }

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");
}