【ConcurrentDictionary】并发测试

前言

参考博文：

https://www.cnblogs.com/xiaomowang/p/12400440.html

测试代码

        [HttpGet]
        public async Task<MessageModel<string>> UseConDic(int index, string key, string value)
        {
            var r = await _utilBLL.UseConDic(index, key, value);

            return new MessageModel<string>(true, "Success") { Data = r };
        }

    public interface IUtilBLL
    {
        Task<string> UseConDic(int index, string key, string value);
    }

    public class UtilBLL : IUtilBLL
    {
        private static readonly ConcurrentDictionary<string, string> pairs = new ConcurrentDictionary<string, string>();

        public async Task<string> UseConDic(int index, string key, string value)
        {
            var pId = System.Diagnostics.Process.GetCurrentProcess().Id;

            int count = pairs.Count;

            var val = pairs.GetOrAdd(key, value);

            return $"pId：{pId}，执行前：{count}个，执行后：{pairs.Count}个。val：{val}";
        }
    }

        /// <summary>
        /// 将接口导入到SqlServer
        /// </summary>
        /// <returns></returns>
        static async Task TestAddConDicLogs()
        {
            Console.WriteLine($"{DateTime.Now}开始执行");
            SqlSugarScope sqlSugarScope = new SqlSugarScope(new ConnectionConfig()
            {
                DbType = SqlSugar.DbType.SqlServer,
                ConnectionString = "server=.;database=ConTest;uid=sa;pwd=123456;",
                IsAutoCloseConnection = true,
            });

            string filePath = @"D:\Logs\2021-11-30\warn.txt";

            List<ConDicLogs> lst = new List<ConDicLogs>();

            var fileContent = File.ReadAllLines(filePath, Encoding.UTF8);
            for (int i = 0; i < fileContent.Length; i++)
            {
                string str = fileContent[i];

                if (str.Contains("Util.UseConDic") == false)
                    continue;

                ConDicLogs conDicLogs = new ConDicLogs();

                {
                    string p = str[str.IndexOf("参数:")..];
                    string para = p[p.IndexOf("【")..p.IndexOf("】")];
                    para = para.Replace("【", "");
                    para = para.Replace("query:", "");
                    para = para.Replace(".", "");
                    para = para.Replace("】", "");

                    string[] s1 = para.Split("&");

                    conDicLogs.p_index = s1[0];
                    conDicLogs.p_key = s1[1];
                    conDicLogs.p_value = s1[2];

                    conDicLogs.p_index = conDicLogs.p_index.Replace("index=", "");
                    conDicLogs.p_key = conDicLogs.p_key.Replace("key=", "");
                    conDicLogs.p_value = conDicLogs.p_value.Replace("value=", "");
                }

                {
                    string p = str[str.IndexOf("Data")..];
                    string para = p[p.IndexOf("pId")..p.IndexOf("}")];
                    para = para.Replace("\"", "");
                    para = para.Replace("}", "");

                    conDicLogs.r_pId = para[para.IndexOf("pId：")..para.IndexOf("，", para.IndexOf("pId："))];
                    conDicLogs.r_ExecBefore = para[para.IndexOf("执行前：")..para.IndexOf("个", para.IndexOf("执行前："))];
                    conDicLogs.r_ExecAfter = para[para.IndexOf("执行后：")..para.IndexOf("个", para.IndexOf("执行后："))];
                    conDicLogs.r_val = para[para.IndexOf("val：")..];

                    conDicLogs.r_pId = conDicLogs.r_pId.Replace("pId：", "");
                    conDicLogs.r_ExecBefore = conDicLogs.r_ExecBefore.Replace("执行前：", "");
                    conDicLogs.r_ExecAfter = conDicLogs.r_ExecAfter.Replace("执行后：", "");
                    conDicLogs.r_val = conDicLogs.r_val.Replace("val：", "");
                }

                Console.WriteLine($"第{i}个");

                lst.Add(conDicLogs);
            }
            Console.WriteLine("加载导入数据的集合完成");

            var r = sqlSugarScope.Insertable(lst).ExecuteCommand();

            Console.WriteLine($"{DateTime.Now}结束执行");
        }

/*创建接口日志表*/
CREATE TABLE [dbo].[ConDicLogs](
    [p_index] [varchar](10) NULL,
    [p_key] [varchar](10) NULL,
    [p_value] [varchar](10) NULL,
    [r_pId] [varchar](10) NULL,
    [r_ExecBefore] [varchar](10) NULL,
    [r_ExecAfter] [varchar](10) NULL,
    [r_val] [varchar](10) NULL
) ON [PRIMARY]
GO

/*
select count(1)
from ConDicLogs
where r_pId='31356'

select count(1)
from ConDicLogs
where r_val='18836'

select *
from ConDicLogs
where r_pId='31356' and r_ExecBefore=0
*/