7

我之前的问题中描述的应用程序本身。在我使用的 DAL 方面

Oracle.ManagedDataAccess, Version=4.121.1.0, Culture=neutral, PublicKeyToken=89b483f429c47342

这是连接字符串:

User id=usr;Password=pwd;Data Source=database1;Validate connection=True;Connection timeout=8;Pooling=false

奇怪的是,有时 ODP 会引发以下异常:

Oracle.ManagedDataAccess.Client.OracleException (0xFFFFFC18): Connection request timed out
   in OracleInternal.ConnectionPool.PoolManager`3.CreateNewPR(Int32 reqCount, Boolean bForPoolPopulation, ConnectionString csWithDiffOrNewPwd, String instanceName)
   in OracleInternal.ConnectionPool.PoolManager`3.Get(ConnectionString csWithDiffOrNewPwd, Boolean bGetForApp, String affinityInstanceName, Boolean bForceMatch)
   in OracleInternal.ConnectionPool.OraclePoolManager.Get(ConnectionString csWithNewPassword, Boolean bGetForApp, String affinityInstanceName, Boolean bForceMatch)
   in OracleInternal.ConnectionPool.OracleConnectionDispenser`3.Get(ConnectionString cs, PM conPM, ConnectionString pmCS, SecureString securedPassword, SecureString securedProxyPassword)
   in Oracle.ManagedDataAccess.Client.OracleConnection.Open()
   in MySyncApp.DBRepository.GetChangedDataDB(DateTime startPeriod) in D:\MySyncApp\MySyncApp\DB.cs:line 23
   in MySyncApp.Program.<>c__DisplayClass30.<>c__DisplayClass32.<Synchronize>b__2f(ID id) in D:\MySyncApp\MySyncApp\Program.cs:line 441

但是在这个异常之后,当我查看 Oracle 中的会话时,我发现实际上连接是活动的并且只是标记为INACTIVE!因此,此类连接将继续挂在服务器端,逐渐耗尽可用会话数。

我的代码没有什么特别之处,只是

public List<DataObj> GetChangedDataDB(DateTime startPeriod)
{
    List<DataObj> list = new List<DataObj>();
    using (OracleConnection conn = new OracleConnection(this._connstr))
    {
        conn.Open();

        using (OracleCommand comm = new OracleCommand("select data from table(usr.syncpackage.GetChanged(:pStart))", conn))
        {
            comm.CommandTimeout = 10;
            comm.Parameters.Add(":pStart", startPeriod);

            using (OracleDataReader reader = comm.ExecuteReader())
            {
                // ..omitted
            }
        }

    }
    return list;
}

此代码Parallel.ForEach循环运行,用于同时从大量数据库中提取数据。甚至可能是三个并行连接到同一个数据库(从模式的不同部分提取数据,例如,来自企业的三个不同部门)。

甲骨文是

Oracle Database 11g 企业版 11.2.0.3.0 - 64 位生产

同步过程本身会以 10 秒的间隔在计时器上触发。如果已经有正在运行的任务,则正在停止下一个任务:

    public static void Synchronize(object obj)
    {            
        // ... omitted
        log.Info("ITERATION_COMMON_START");

        if (Program.State == "Running")
        {
            log.Info("ITERATION_COMMON_END_BY_EXISTING");
            return;
        }

        lock (Program.StateLock)
        {
            Program.State = "Running";
        }                   

        Parallel.ForEach(Global.config.dbs, new ParallelOptions { MaxDegreeOfParallelism = -1 }, (l) =>
        {
            Console.WriteLine("Started synchronization for {0}", l.key);
            DBRepository db = new DBRepository(l.connectionString);

            Parallel.ForEach(l.departments, new ParallelOptions { MaxDegreeOfParallelism = -1 }, (department) =>
            {                       
                DateTime ChangesFromTS = GetPreviousIterationTS;
                List<DataObj> cdata = db.GetChangedDataDB(ChangesFromTS);
                // ... doing the work here
            }

        }

        // Finishing work

        GC.Collect();            

        lock (Program.StateLock)
        {
            Program.State = "";
        }

    }

这是用于定期调用同步任务的计时器:

Program.getModifiedDataTimer = new Timer(Program.Synchronize, null, (int)Global.config.syncModifiedInterval * 1000, (int)Global.config.syncModifiedInterval * 1000);

Global.config.syncModifiedInterval以秒为单位

当我打开池时,ODP 的行为方式相同。它创建的连接数超过Max pool size了连接字符串中的指令所允许的数量,但具有相同的异常。

请告诉我你对这些东西的想法和经验。


更新

这是引发异常时的一段 Oracle 跟踪:

(PUB) (ERR) OracleConnection.Open() (txnid=n/a) Oracle.ManagedDataAccess.Client.OracleException (0xFFFFFC18): Connection request timed out
   in OracleInternal.ConnectionPool.PoolManager`3.CreateNewPR(Int32 reqCount, Boolean bForPoolPopulation, ConnectionString csWithDiffOrNewPwd, String instanceName)
   in OracleInternal.ConnectionPool.PoolManager`3.Get(ConnectionString csWithDiffOrNewPwd, Boolean bGetForApp, String affinityInstanceName, Boolean bForceMatch)
   in OracleInternal.ConnectionPool.OraclePoolManager.Get(ConnectionString csWithNewPassword, Boolean bGetForApp, String affinityInstanceName, Boolean bForceMatch)
   in OracleInternal.ConnectionPool.OracleConnectionDispenser`3.Get(ConnectionString cs, PM conPM, ConnectionString pmCS, SecureString securedPassword, SecureString securedProxyPassword)
   in Oracle.ManagedDataAccess.Client.OracleConnection.Open()

更新#2

似乎由于延迟连接而显示此连接,例如发送建立 oracle 连接的请求但其响应被忽略。或者传输到/从服务器的数据在到达目的地时被损坏。

即使我关闭应用程序,连接也会一直挂在服务器的会话列表中。当我终止一个会话时,它会一直挂在带有“KILLED”标签的列表中。


更新#3

是产生相同问题的演示应用程序。正如我之前所说,它出现在连接不良的情况下,您可以使用WANem模拟器模拟这种连接。是我用于数据库连接的相同组件。希望得到您的帮助。

4

3 回答 3

4

您的连接超时非常低,一般为 8 秒,您发出的命令为 10 秒,尝试将其增加到可能一分钟,看看会发生什么。我不知道你的算法有多么繁重,但只要一个线程在不到 8 秒的时间内查询失败就足够了,你会得到那个异常。

此外,我找不到说明 ODP.net 不是线程安全的文档,但我也找不到任何说明它是线程安全的文档,所以如果没有其他帮助尝试此更改:

    Parallel.ForEach(Global.config.dbs, new ParallelOptions { MaxDegreeOfParallelism = -1 }, (l) =>
    {
        Console.WriteLine("Started synchronization for {0}", l.key);

        Parallel.ForEach(l.departments, new ParallelOptions { MaxDegreeOfParallelism = -1 }, (department) =>
        {                       
            // Now local to the executing thread.
            DBRepository db = new DBRepository(l.connectionString);

            DateTime ChangesFromTS = GetPreviousIterationTS;
            List<DataObj> cdata = db.GetChangedDataDB(ChangesFromTS);
            // ... doing the work here
        }

    }
于 2013-11-06T13:19:03.927 回答
2

我的 F# 代码也有同样的问题。它同时产生许多连接并且不使用任务并行库。我同意flindebergMotomoto Pink你自己的结论是,来自 Oracle 的连接确认响应是在连接请求超时异常之后出现的。

和其他人一样,我建议您增加连接请求超时。但是另外你可以考虑使用Min Pool Size参数设置为并行生成线程数的连接池,这些线程将打开连接。当部门数量很大时,使用连接池可以显着提高客户端和服务器端的性能。

于 2014-02-06T07:16:47.783 回答
0

您是否尝试增加命令超时(GetChangedDataDB 方法中的代码行)?像这样的东西

 comm.CommandTimeout = 360;

我创建了管理大量数据的项目,并且我也收到了像您一样的错误消息,因此我添加了越来越多的 CommandTimeout 值,然后它就可以工作了,但是我不确定您是否遇到与我相同的情况。

另一方面,我看到您在 Parallel.ForEach 范围中有 Parallel.ForEach 范围,我认为您可以尝试使用Task Parallel Library修改第二个范围。你可以在这里了解更多http://msdn.microsoft.com/en-us/library/dd537609.aspx

那么你的第二个 Parallel.ForEach 范围应该是这样的

Task task = new Task(() =>
Parallel.ForEach(l.departments, new ParallelOptions { MaxDegreeOfParallelism = -1 }, (department) =>
{
    // Now local to the executing thread.
    DBRepository db = new DBRepository(l.connectionString);

    DateTime ChangesFromTS = GetPreviousIterationTS;
    List<DataObj> cdata = db.GetChangedDataDB(ChangesFromTS);
    // ... doing the work here
}
)); //close lambda expression

task.Start();
于 2013-11-10T04:44:20.853 回答