src/DotNetCommon.Core/Logger/InternalLogger.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using DotNetCommon.Extensions;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DotNetCommon.Logger
{
    internal class LoggerHelper
    {
        internal static bool hasInitQueue = false;
        /// <summary>
        /// 单例
        /// </summary>
        public static readonly ILogger Instance = new InternalLogger<object>("");

        internal static BlockingCollection<LogContext> messageQueue = new BlockingCollection<LogContext>();
    }
    internal class InternalLogger<T> : ILogger, ILogger<T>
    {
        internal InternalLogger(string categoryName)
        {
            this.CategoryName = categoryName;
            InitQueue();
        }

        /// <summary>
        /// 日志类别
        /// </summary>
        public string CategoryName { get; set; }
        private static void InitQueue()
        {
            if (!LoggerHelper.hasInitQueue)
            {
                lock (typeof(ILogger))
                {
                    if (!LoggerHelper.hasInitQueue)
                    {
                        LoggerHelper.hasInitQueue = true;
                        Task.Factory.StartNew(() =>
                        {
                            while (true)
                            {
                                try
                                {
                                    var ctx = LoggerHelper.messageQueue.Take();
                                    LogFile(ctx);
                                }
                                catch (Exception ex)
                                {
                                    LogInternal(ex);
                                }
                            }
                        }, TaskCreationOptions.LongRunning);
                    }
                }
            }