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

前言

好久沒有出來夸白了,今天教大家簡單的使用阿里云分布式日志,來存儲日志,沒有阿里云賬號的,可以免費注冊一個

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

阿里云日志地址:https://sls.console.aliyun.com/lognext/profile

先開通阿里云日志,這個比較簡單授權就可以了

選擇接入數(shù)據(jù),我們這里選 .net

選擇項目名稱,沒有項目的可以去創(chuàng)建一個,項目名稱后面會用到,如果你有購買阿里云ecs,項目區(qū)域最好選擇跟ecs同一個區(qū)域(每個區(qū)域的地址不一樣,同一個區(qū)域可以選擇內(nèi)網(wǎng)通訊,速度更快),如果沒有,就隨便選個區(qū)域,我這里選擇的是杭州

選擇日志庫,沒有就創(chuàng)建一個

數(shù)據(jù)源配置,這個先不用管,后面有教程

設置分析配置,例如我這里設置了兩個,可以根據(jù)業(yè)務需求來,沒有特殊要求不用設置

開通完成,可以正常看到儀盤表

設置密鑰

通過sdk 寫入日志

阿里云有提供對應的sdk(阿里云 .net sdk的質(zhì)量大家都懂),它主要是通過構造一個靜態(tài)對象來提供訪問的,地址: 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();
      }
  }
}

中間個有小插曲,由于公司使用阿里云日志比較早,也非常穩(wěn)定,替換成我申請的阿里云日志的配置,發(fā)送日志一直報錯,找了半天沒找到原因,提了工單,原來阿里云使用了新的sdk

重新封裝阿里云日志sdk(aliyun.log.core) https://github.com/wmowm/aliyun.log.core問了下群友,剛好有大佬重寫過向阿里云提交日志這塊,一番py交易,代碼塊到手,主要是數(shù)據(jù)組裝,加密,發(fā)送,發(fā)送部分的代碼基于http的protobuf服務實現(xiàn),這里直接從阿里云開源的sdk里拷貝過來,開始重新封裝,主要實現(xiàn)以下功能

• 實現(xiàn).net core di
• 加入隊列,讓日志先入列,再提交到阿里云,提高系統(tǒng)吞吐量
• 對日志模型進行封裝,滿足基礎業(yè)務需求

代碼如下

添加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);
            }
        }
    }
});

定義日志模型,可以根據(jù)業(yè)務情況拓展

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

簡單的查詢?nèi)罩?/h2>

同事寫了一個查詢阿里云日志的工具,非常實用,我用 .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分布式日志內(nèi)容請搜索碩編程以前的文章，希望大家多多支持碩編程！