.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分布式日志內容請搜索碩編程以前的文章，希望大家多多支持碩編程！
C++實戰