问题描述
我的服务出现连接池问题(已达到最大值),在我尝试打开连接的任何地方,我都将它包装在 using
语句中以正确处理它,但我认为有些事情不允许它上班。我认为这是因为我使用的方法需要 sqlCommand
作为参数,这是一个例子:
private void QueryDB(string sConnString,sqlCommand oComm)
{
using (sqlConnection connection = new sqlConnection(sConnString))
{
try
{
connection.open();
oComm.Connection = connection;
oComm.CommandTimeout = 2;
oComm.ExecuteNonQuery();
}
catch (sqlException e)
{
//log exception
}
catch (Exception e)
{
//log exception
}
}
}
之所以这样做是因为我需要在该方法之外组装参数,如下所示:
public void Example1()
{
using (sqlCommand command = new sqlCommand())
{
command.CommandText = "SELECT TOP 1 FROM Table ORDER BY column1 DESC";
QueryDB(_connString,command));
}
}
public void Example2()
{
sqlCommand command= new sqlCommand();
command.CommandText = "UPDATE Table set column1 = @value where column2 = @number";
command.Parameters.Add(new sqlParameter { ParameterName = "@value",Value = "someValue",sqlDbType = sqlDbType.VarChar });
command.Parameters.Add(new sqlParameter { ParameterName = "@number",Value = 3,sqlDbType = sqlDbType.Int });
QueryDB(_connString,command));
}
在 Example1
中,我尝试处理 sqlCommand
,但我不知道它是否像那样工作。另一件要考虑的事情是我每秒都在运行一个执行 Example1
或 Example2
的计时器,我不知道这是否与问题有关,发生了 Max pool size 错误有时,不是每天,它会延迟其他查询。我可以做些什么来改善这种行为?谢谢
解决方法
我真的不知道这是否会解决您在连接池问题方面的问题,但是,扩展@Jack A 对您的问题的评论,也许,构建代码的更好方法是更改您的 { {1}} 方法采用委托更新 QueryDB
变量的必要信息,然后,您可以确保您的 SqlCommand
和 SqlConnection
并在其中正确处理方法。
SqlCommand
然后您可以在代码中通过以下任一方式使用它:
private void QueryDB(string sConnString,Action<SqlCommand> commandDelegate)
{
using (SqlConnection oCon = new SqlConnection(sConnString))
using(SqlCommand oComm = new SqlCommand())
{
try
{
oCon.Open();
oComm.Connection = oCon;
oComm.CommandTimeout = 2;
commandDelegate(oComm);
oComm.ExecuteNonQuery();
}
catch (SqlException e)
{
//log exception
}
catch (Exception e)
{
//log exception
}
}
}
同样,我不确定这是否会解决您的池化问题,但它至少可以确保所有内容都整齐地包装在您的 public void Uses()
{
QueryDB(_connString,(oComm) => oComm.CommandText = "SELECT TOP 1 FROM Table ORDER BY column1 DESC");
QueryDB(_connString,longerDelegate);
}
private void longerDelegate(SqlCommand oComm)
{
oComm.CommandText = "UPDATE Table set column1 = @value where column2 = @number";
oComm.Parameters.Add(new SqlParameter { ParameterName = "@value",Value = "someValue",SqlDbType = SqlDbType.VarChar });
oComm.Parameters.Add(new SqlParameter { ParameterName = "@number",Value = 3,SqlDbType = SqlDbType.Int });
}
方法中。
我要感谢大家的回复!在做了大量的研究和修改之后,我实施了@Jack A 和@Jhon Busto 的建议。但是你说得对,约翰它没有解决连接池问题,事实证明真正的问题是计时器,我没有注意到它一直在执行 Example1
和 Example2
但不是每个其次,它是每 50 毫秒或更短时间,所以我认为它在池中创建了很多连接。我正在更改计时器的 Timer.Interval
属性,但我不知道这一点:
如果 Enabled 和 AutoReset 都设置为 false,并且之前已启用计时器,则设置 Interval 属性会导致 Elapsed 事件引发一次,就好像 Enabled 属性已设置为 true。要设置间隔而不引发事件,您可以暂时将 Enabled 属性设置为 true,将 Interval 属性设置为所需的时间间隔,然后立即将 Enabled 属性设置回 false。
来源:https://docs.microsoft.com/en-us/dotnet/api/system.timers.timer.interval?view=netframework-4.7.2
因此,如果我需要更改 Timer.Interval
,我遵循了 Microsoft 的文档,我再次测试了所有内容,并且成功了。小心使用定时器!呵呵:)