.net core 使用阿里雲分散式日誌

前言

好久沒有出來誇白了,今天教大家簡單的使用阿里雲分散式日誌,來儲存日誌,沒有阿里雲賬號的,可以免費註冊一個

開通阿里雲分散式日誌(有一定的免費額度,個人測試學習完全沒問題的,香)

阿里雲日誌地址:https://sls.console.aliyun.com/lognext/profile

先開通阿里雲日誌,這個比較簡單授權就可以了
選擇接入資料,我們這裡選 .NET
選擇專案名稱,沒有專案的可以去建立一個,專案名稱後面會用到,如果你有購買阿里雲ECS,專案區域最好選擇跟ECS同一個區域(每個區域的地址不一樣,同一個區域可以選擇內網通訊,速度更快),如果沒有,就隨便選個區域,我這裡選擇的是杭州
選擇日誌庫,沒有就建立一個
資料來源配置,這個先不用管,後面有教程
設定分析配置,例如我這裡設定了兩個,可以根據業務需求來,沒有特殊要求不用設定
開通完成,可以正常看到儀盤表
設定金鑰

通過SDK 寫入日誌

阿里雲有提供對應的SDK(阿里雲 .NET SDK的質量大家都懂),它主要是通過構造一個靜態物件來提供訪問的,地址: https://github.com/aliyun/aliyun-log-dotnetcore-sdk
阿里雲程式碼

    LogServiceClientBuilders.HttpBuilder

    .Endpoint("<endpoint>", "<projectName>")

    .Credential("<accessKeyId>", "<accessKey>")

    .Build();

阿里雲提供的依賴注入程式碼(autofac),很遺憾按照這個方式,並沒有獲取到物件

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

        }

    }

}

中間個有小插曲,由於公司使用阿里雲日誌比較早,也非常穩定,替換成我申請的阿里雲日誌的配置,傳送日誌一直報錯,找了半天沒找到原因,提了工單,原來阿里雲使用了新的SDK

重新封裝阿里雲日誌SDK(Aliyun.Log.Core) https://github.com/wmowm/Aliyun.Log.Core

問了下群友,剛好有大佬重寫過向阿里雲提交日誌這塊,一番py交易,程式碼塊到手,主要是資料組裝,加密,傳送,傳送部分的程式碼基於http的protobuf服務實現,這裡直接從阿里雲開源的SDK裡拷貝過來,開始重新封裝,主要實現以下功能

實現 .net core DI
加入佇列,讓日誌先入列,再提交到阿里雲,提高系統吞吐量
對日誌模型進行封裝,滿足基礎業務需求

程式碼如下

新增ServiceCollection 拓展,定義一個阿里雲日誌的配置資訊委託,然後將需要注入的服務註冊進去即可

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

  }

加入佇列比較簡單,定義一個佇列,使用HostedService 消費佇列

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

  }

使用Aliyun.Log.Core

獲取Aliyun.Log.Core包

方案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");

}

簡單的查詢日誌

同事寫了一個查詢阿里雲日誌的工具,非常實用,我用 .net core又抄了一遍,一併開源在github,地址: https://github.com/wmowm/Aliyun.Log.Core/tree/main/Aliyun.Log.Core.Client

推薦我自己寫的一個Redis訊息佇列中介軟體InitQ,操作簡單可以下載的玩玩
https://github.com/wmowm/initq

.net core 使用阿里雲分散式日誌

.net core 使用阿里雲分散式日誌

前言

開通阿里雲分散式日誌(有一定的免費額度,個人測試學習完全沒問題的,香)

通過SDK 寫入日誌

重新封裝阿里雲日誌SDK(Aliyun.Log.Core) https://github.com/wmowm/Aliyun.Log.Core

程式碼如下

使用Aliyun.Log.Core

簡單的查詢日誌

最新文章