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

/// <summary> /// 写日志 /// </summary> /// <param></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分布式日志内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章: