zoukankan      html  css  js  c++  java
  • c#解决高并发加锁(Lock)

    private static object sign = new object();
    
            public static DBHelper CreateMapping(string connStr = "")
            {
                DBHelper db = new DBHelper(connStr);
                return db;
            }
    
            /// <summary>
            /// 增删改的数据库连接字符串
            /// </summary>
            string conString = "";
            /// <summary>
            /// 查询的数据库连接字符串
            /// </summary>
            string queryConString = "";
    
            DBHelper(string connStr = "")
            {
                if (string.IsNullOrWhiteSpace(connStr))
                {
                    conString = AsString(ConfigurationManager.ConnectionStrings["DBConfig"]);
                    if(string.IsNullOrEmpty(conString))WriteErrorLogDataInteraction(conString,"连接字符串获取失败!");
                    //第一个链接字符串是ConfigurationManager.ConnectionStrings[0].Name LocalSqlServer不知道是谁,所以要从第二个取
                    //如果连接字符串的数量和当前索引+1相同 则从第一个索引开始取
                    NameValueCollection connStrs = new NameValueCollection();
                    int j = 0;
                    for (int i = 0; i < ConfigurationManager.ConnectionStrings.Count; i++)
                    {
                        if (ConfigurationManager.ConnectionStrings[i].Name.StartsWith("QueryDB"))
                        {
                            connStrs.Add(j.ToString(), ConfigurationManager.ConnectionStrings[i].ToString());
                            j++;
                        }
                    }
                    // 加锁
                    lock (sign)
                    {
                        if (connStrs.Count > 0)
                        {
                            if (connStrs.Count >= ConnIndex)
                            {
                                ConnIndex = 0;
                            }
                            queryConString = connStrs[ConnIndex].ToString();
                            ConnIndex++;
                        }
                        else
                        {
                            queryConString = conString;
                        }
                    }
                }
                else
                {
                    conString = connStr;
                    queryConString = connStr;
                }
    
                DBMapping = new SqlDatabase(conString);
                QueryDBMapping = new SqlDatabase(queryConString);
    
            }
  • 相关阅读:
    Linux中的DHCP服务
    写出发帖数最多的前几条记录
    nginx和php-fpm调用方式
    redi集群测试
    Redis 3.2.1集群搭建
    linux系统centOS7下搭建redis集群中ruby版本过低问题的解决方法
    nginx与php-fpm通信的两种方式
    Linux安装mongodb总结
    php高并发
    thinkphp5报错
  • 原文地址:https://www.cnblogs.com/honghong75042/p/5773955.html
Copyright © 2011-2022 走看看