Microsoft MVP성태의 닷넷 이야기
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

C# - Oracle.ManagedDataAccess의 Pool 및 그것의 연결 개체 수를 알아내는 방법

이것을 알아내는 방법은, 공식적으로는 성능 카운터를 이용하는 방법이 있습니다.

C# - (.NET Framework를 위한) Oracle.ManagedDataAccess 패키지의 성능 카운터 설정 방법
; https://www.sysnet.pe.kr/2/0/13003

C# - Oracle.ManagedDataAccess.Core의 성능 카운터 설정 방법
; https://www.sysnet.pe.kr/2/0/13000

하지만, 아쉽게도 좀 번거롭다는 단점이 있습니다. 그냥 저런 설정 없이 알아낼 수 있다면 좋을 텐데요, 다행히 리플렉션을 이용하면 그런대로 원하는 목적을 이룰 수 있습니다.




그럼, 어디서 시작해볼까요? ^^

우선, OracleConnection.ClearAllPools 메서드가 있는데요,

public static void ClearAllPools()
{
    // ...[생략]...
    OracleConnectionDispenser<OraclePoolManager, OraclePool, OracleConnectionImpl>.ClearAllPools();
    // ...[생략]...
}

여기서 다시 OracleConnectionDispenser`3.ClearAllPools를 들어가면,

internal static void ClearAllPools()
{
    // ...[생략]...

    List<PM> list = OracleConnectionDispenser<PM, CP, PR>.m_listPM.GetList();
    for (int index = 0; index < list.Count; ++index)
        list[index].ClearAllPools(default (PR), false);
    }

    // ...[생략]...
}

OracleConnectionDispenser`3 제네릭 클래스의 m_listPM 정적 필드에 Pool 개체들이 담겨 있음을 짐작게 합니다. 해당 제네릭 타입은 3개의 타입 인자를 받아들이므로,

OracleConnectionDispenser<OraclePoolManager, OraclePool, OracleConnectionImpl>

이전에 설명한 방법을 사용해 일단 이렇게 m_listPM 목록을 구할 수 있습니다.

using Oracle.ManagedDataAccess.Client;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;

internal class Program
{
    static void Main(string[] args)
    {
        Assembly asm = typeof(OracleConnection).Assembly;
        Dictionary<string, Type> typeArgs = new Dictionary<string, Type>()
        {
            ["OracleInternal.ConnectionPool.OraclePoolManager"] = null,
            ["OracleInternal.ConnectionPool.OraclePool"] = null,
            ["OracleInternal.ServiceObjects.OracleConnectionImpl"] = null,
        };

        Type poolType = null;

        foreach (Type type in asm.GetTypes())
        {
            string name = type.FullName;

            if (typeArgs.ContainsKey(type.FullName) == true)
            {
                typeArgs[type.FullName] = type;
                continue;
            }

            if (name.IndexOf("OracleConnectionDispenser") == -1)
            {
                continue;
            }

            poolType = type;
        }

        bool resolvedAll = typeArgs.All((e) => e.Value != null);
        if (resolvedAll == false)
        {
            return;
        }

        Type[] genericArgs = new Type[]
        {
                typeArgs["OracleInternal.ConnectionPool.OraclePoolManager"],
                typeArgs["OracleInternal.ConnectionPool.OraclePool"],
                typeArgs["OracleInternal.ServiceObjects.OracleConnectionImpl"]
        };

        Type poolGenericType = poolType.MakeGenericType(genericArgs);

        {
            FieldInfo fi = poolGenericType.GetField("m_listPM", BindingFlags.Static | BindingFlags.Public);
            object syncQList = fi.GetValue(null);

            Console.WriteLine(syncQList);
        }

    }
}

그다음, syncQList에는 개체 풀을 유지하는 목록이 들어 있을 텐데요, 해당 타입을 보면,

using System.Collections.Generic;

namespace OracleInternal.Common
{
  internal class SyncQueueList<T>
  {
    internal List<T> m_list;
    internal object m_sync;
    internal int m_max;
    internal bool m_bMaxExplicitlySet;

    // ...[생략]...
  }
}

다시 내부의 리스트로 보관하고 있습니다. 어쩔 수 없이 그 필드를 구하는,

{
    FieldInfo fi = poolGenericType.GetField("m_listPM", BindingFlags.Static | BindingFlags.Public);
    object syncQList = fi.GetValue(null);

    object poolList = GetInstanceFieldValue(syncQList, "m_list", BindingFlags.NonPublic | BindingFlags.Instance);

    int numberOfPool = 0;

    foreach (var pool in poolList as IEnumerable)
    {
        numberOfPool++;
    }

    Console.WriteLine(numberOfPool);
}

private static object GetInstanceFieldValue(object objInstance, string fieldName, BindingFlags flags)
{
    return objInstance.GetType().GetField(fieldName, flags).GetValue(objInstance);
}

위의 코드를 실행하면, 현재 풀이 만들어진 적이 없으므로 numberOfPool 값은 0이 나옵니다. 이 상태에서 다음의 예제 코드를 한번 실행시켜 두면,


string oradb = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=XE)));User Id=hr;Password=hr2;";

DoOracleManagedCall(oradb, 0);

protected static void DoOracleManagedCall(string oradb, int delay)
{
    using (OracleConnection oraConnection = new OracleConnection(oradb))
    {
        oraConnection.Open();

        if (delay > 0)
        {
            Thread.Sleep(delay);
        }
    }
}

이제 리플렉션 코드는 numberOfPool의 개수로 1을 반환합니다.




자, 그럼 저 m_list는 OraclePoolManager의 목록을 가지고 있게 되는데요, (OraclePoolManager가 상속받은) PoolManager.ClearAllPools의 메서드를 보면,

public virtual void ClearAllPools(PR pr, bool isHAEvnt = false)
{
    // ...[생략]...
    List<CP> list = this.m_pmListCP.GetList();
    for (int index = 0; index < list.Count; ++index)
        list[index].ClearPool(pr, isHAEvnt);
    }
    // ...[생략]...
}
System.Collections.Generic.List`1[OracleInternal.ConnectionPool.OraclePoolManager] m_list

다시, 내부에서 구성한 List를 열거하면서 ClearPool 메서드를 호출하고 있습니다. 여기서 잘 이해가 안 됩니다. 일반적으로 다중 Pool이 제공되고 각각의 Pool에서 다시 연결 개체를 소유하는 것으로 알고 있었는데, Pool 목록에서 다시 개별 요소들이 Pool을 가지고 있는 유형으로 나옵니다.

어쨌든, m_pmListCP도 SyncQueueList`1 타입이므로 최종적으로 다음과 같이 열거할 수 있습니다.

// ...[생략]...
int numberOfPool = 0;

foreach (var pool in poolList as IEnumerable)
{
    numberOfPool++;

    object pmListCP = GetInstanceFieldValue(pool, "m_pmListCP", BindingFlags.Public | BindingFlags.Instance);
    object pmListCPList = GetInstanceFieldValue(pmListCP, "m_list", BindingFlags.NonPublic | BindingFlags.Instance);

    foreach (var pmCP in pmListCPList as IEnumerable)
    {
        Console.WriteLine(pmCP); // OracleInternal.ConnectionPool.OraclePool
    }
}

Console.WriteLine(numberOfPool);

ClearAllPools 메서드에서는 결국 저렇게 얻은 OracleInternal.ConnectionPool.OraclePool 개체의 ClearPool 메서드를 호출하는 건데요,

public void ClearPool(PR prToRetain, bool isHAEvnt = false)
{
    // ...[생략]...
    List<PR> list = this.m_cpListPR.GetList();
    for (int index = 0; index < list.Count; ++index)
    {
        // ...[생략]...
        PR pr = list[index];
        if ((object) pr != null)
        {
            // ...[생략]...
            pr.m_pm.Close(pr, (OracleConnection) null);
            // ...[생략]...
        }
        // ...[생략]...
    }
    // ...[생략]...
}

보는 바와 같이 m_cpListPR이라는 목록을 연결 개체가 보관하는 듯하고, Close 메서드를 호출함으로써 연결을 정리하고 있습니다. 그래서 대략 다음과 같은 식으로 코드를 완성할 수 있습니다.

int numberOfPool = 0;
int numberOfCount = 0;

foreach (var pool in poolList as IEnumerable)
{
    numberOfPool++;

    object pmListCP = GetInstanceFieldValue(pool, "m_pmListCP", BindingFlags.Public | BindingFlags.Instance);
    object pmListCPList = GetInstanceFieldValue(pmListCP, "m_list", BindingFlags.NonPublic | BindingFlags.Instance);

    foreach (var pmCP in pmListCPList as IEnumerable)
    {
        // OracleInternal.Common.SyncQueueList`1[OracleInternal.ServiceObjects.OracleConnectionImpl]
        object cpListPR = GetInstanceFieldValue(pmCP, "m_cpListPR", BindingFlags.Public | BindingFlags.Instance);

        object cpListPRList = GetInstanceFieldValue(cpListPR, "m_list", BindingFlags.NonPublic | BindingFlags.Instance);

        int cpListSize = (int)GetInstanceFieldValue(cpListPRList, "_size", BindingFlags.NonPublic | BindingFlags.Instance);
        numberOfCount += cpListSize;
    }
}

Console.WriteLine($"# of pools: {numberOfPool}");
Console.WriteLine($"# of connections: {numberOfCount}");




실제로 저 코드를 WriteCount라는 메서드로 분리해서 다음과 같이 실행해 보면,

string oradb1 = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=XE)));User Id=hr;Password=hr2;Min Pool Size=15;";
string oradb2 = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=XE)));User Id=hr;Password=hr2;Min Pool Size=10;";
string oradb3 = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=XE)));User Id=hr;Password=hr2;";

do
{
    Type poolGenericType = poolType.MakeGenericType(genericArgs);
    WriteCount(poolGenericType);

    for (int i = 0; i < 17; i++)
    {
        DoOracleManagedCall(oradb1, 1000);
    }

    WriteCount(poolGenericType);
    Thread.Sleep(1000);

    for (int i = 0; i < 17; i++)
    {
        DoOracleManagedCall(oradb2, 1000);
    }

    WriteCount(poolGenericType);
    Thread.Sleep(1000);

    for (int i = 0; i < 17; i++)
    {
        DoOracleManagedCall(oradb3, 1000);
    }

    WriteCount(poolGenericType);

    Console.WriteLine("---------------------------------------------------------------");
} while (true);

서로 다른 연결 개체를 3개 사용했으므로, 3개의 연결 개체 풀이 생성될 것이고, 각각의 풀에는 17개의 연결 개체가 들어 있을 것입니다. 운이 좋은 경우 정확히 3 * 17 = 51개가 나오는 경우도 있지만, 대개의 경우 풀 내부의 정책으로 더 있을 수 있습니다.

실제로 이를 성능 모니터링 도구와 함께 확인해 보면 다음과 같이 나옵니다.

oracle_pool_status_1.png

보시면, 3개의 풀이 있고, 각각의 풀에는 21개, 17개, 17개까지 총 55개의 연결 개체가 생성돼 있는 것을 볼 수 있습니다. 그리고 그 값은 정확하게 성능 모니터링 도구의 "NumberOfPooledConnections" 수와 일치합니다.

(첨부 파일은 이 글의 예제 코드를 포함합니다.)




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]







[최초 등록일: ]
[최종 수정일: 3/18/2022]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




1  2  3  4  5  6  7  8  9  [10]  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
13693정성태7/24/20247245개발 환경 구성: 717. Visual Studio - C# 프로젝트에서 레지스트리에 등록하지 않은 COM 개체 참조 및 사용 방법파일 다운로드1
13692정성태7/24/20248026디버깅 기술: 199. Windbg - 리눅스에서 뜬 닷넷 응용 프로그램 덤프 파일에 포함된 DLL의 Export Directory 탐색
13691정성태7/23/20247386디버깅 기술: 198. Windbg - 스레드의 Win32 Message Queue 정보 조회
13690정성태7/23/20247020오류 유형: 919. Visual C++ 리눅스 프로젝트 - error : ‘u8’ was not declared in this scope
13689정성태7/22/20248530디버깅 기술: 197. Windbg - PE 포맷의 Export Directory 탐색
13688정성태7/21/20247630닷넷: 2281. C# - Lock / Wait 상태에서도 일부 Win32 메시지 처리파일 다운로드1
13687정성태7/19/20248060닷넷: 2280. C# - PostThreadMessage로 보낸 메시지를 Windows Forms에서 수신하는 방법파일 다운로드1
13686정성태7/19/20247855오류 유형: 918. Visual Studio - ATL Simple Object 추가 시 error C2065: 'IDR_...': undeclared identifier
13685정성태7/19/20248002스크립트: 66. Windows 디렉터리 경로를 WSL의 /mnt 포맷으로 구하는 방법 - 두 번째 이야기
13684정성태7/19/20248184닷넷: 2279. C# - 문자열 보간식 사례 (예: 조건 연산자 사용)
13683정성태7/18/20247652오류 유형: 917. ClrMD - Linux 환경의 .NET 5 덤프 분석 시 hang 현상
13682정성태7/18/20247869닷넷: 2278. WPF - 스레드에 종속되는 DependencyObject파일 다운로드1
13681정성태7/17/20247473닷넷: 2277. C# 13 - (2) 메서드 그룹의 자연 타입 개선 (메서드 추론 개선)파일 다운로드1
13680정성태7/16/20247861닷넷: 2276. C# - Method Group, Natural Type, function_type파일 다운로드1
13679정성태7/16/20246936Linux: 76. Linux - C++ (getaddrinfo 등을 담고 있는) libnss 정적 링크
13678정성태7/15/20247067VS.NET IDE: 191. Visual Studio 2022 - .NET 5 프로젝트를 Docker Support로 실행했을 때 오류
13677정성태7/15/20247158오류 유형: 916. MSBuild - CheckEolTargetFramework (warning NETSDK1138)
13676정성태7/14/20247329Linux: 75. gdb에서 glibc의 함수에 Breakpoint 걸기
13675정성태7/13/20249127C/C++: 166. C/C++ - DLL에서 template 함수를 export하는 방법 [1]파일 다운로드1
13674정성태7/13/20248006오류 유형: 915. Unhandled Exception: Microsoft.Diagnostics.NETCore.Client.ServerNotAvailableException: Unable to connect to Process
13673정성태7/11/20248446닷넷: 2275. C# 13 - (1) 신규 이스케이프 시퀀스 '\e'파일 다운로드1
13672정성태7/10/20247154닷넷: 2274. IIS - (프로세스 종료 없는) AppDomain Recycle
13671정성태7/10/20247267오류 유형: 914. Package ca-certificates is not installed.
13669정성태7/9/20247381오류 유형: 913. C# - AOT StaticExecutable 정적 링킹 시 빌드 오류
13668정성태7/8/20247399개발 환경 구성: 716. Hyper-V - Ubuntu 22.04 Generation 2 유형의 VM 설치
13667정성태7/7/20246623닷넷: 2273. C# - 리눅스 환경에서의 Hyper-V Socket 연동 (AF_VSOCK)파일 다운로드1
1  2  3  4  5  6  7  8  9  [10]  11  12  13  14  15  ...