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

C# - IPGlobalProperties를 이용해 netstat처럼 사용 중인 Socket 목록 구하는 방법

IPGlobalProperties를 이용하면,

IPGlobalProperties Class
; https://learn.microsoft.com/en-us/dotnet/api/system.net.networkinformation.ipglobalproperties

netstat를 이용한 출력 결과를 코드로 가져오는 것이 가능합니다.

예를 들어, "netstat -ano | findstr LISTEN"처럼 현재 열려 있는 TCP 서버 소켓을 다음과 같은 코드로 나열하는 것이 가능합니다.

{
    var props = IPGlobalProperties.GetIPGlobalProperties();
    var listeners = props.GetActiveTcpListeners(); // Listen 중인 TCP 소켓을 열거
    foreach (var item in listeners)
    {
        Console.WriteLine(item);
    }
}

이것을 이용하면, 특정 서비스로의 연결을 가지고 있는지 테스트하는 것도 가능합니다. 예를 들어, 현재 머신에서 SQL Server (1433)에 대한 연결이 있는지,

{
    var props = IPGlobalProperties.GetIPGlobalProperties();
    var listeners = props.GetActiveTcpConnections();
    foreach (var item in listeners)
    {
        if (item.RemoteEndPoint.Port == 1433)
        {
            Console.WriteLine($"{item.LocalEndPoint}-{item.RemoteEndPoint}");
        }
    }
}

/*
192.168.100.20:42621-192.168.100.50:1433
*/

저런 식으로 확인할 수도 있습니다.




IPGlobalProperties의 구현 코드는 윈도우의 경우 GetTcpTable Win32 API를 호출하게 됩니다.

GetTcpTable function (iphlpapi.h)
; https://learn.microsoft.com/en-us/windows/win32/api/iphlpapi/nf-iphlpapi-gettcptable

이 함수의 사용법은 아래의 글에서 잘 설명하고 있는데요,

Getting active TCP/UDP connections on a box
; https://www.codeproject.com/Articles/4298/Getting-active-TCP-UDP-connections-on-a-box

재미있는 것은, GetTcpTable은 해당 소켓이 속한 Process ID를 가져오지는 않습니다. 그런데 위의 글에 보면, 문서화되지 않은 AllocateAndGetTcpExTableFromStack API의 경우 Process ID를 가져올 수 있다고 하는데요, 현재 시점(2024-01-02)에는 다음과 같이 문서화된 상태입니다.

AllocateAndGetTcpExTableFromStack function (iphlpapi.h)
; https://learn.microsoft.com/en-us/windows/win32/api/iphlpapi/nf-iphlpapi-allocateandgettcpextablefromstack

단지, 도움말에도 나오지만 지원이 끊길 예정이고, 대신 GetExtendedTcpTable 함수를 사용하라고 나옵니다.

그런데 사실 닷넷에서도 IPv6 정보에 대해서는 GetExtendedTcpTable을 이용해 조회를 하고 있습니다.

/// 닷넷 소스 코드
/// Gets the active TCP connections. Uses the native GetTcpTable API.
private static unsafe List<SystemTcpConnectionInformation> GetAllTcpConnections()
{
    uint size = 0;
    uint result;
    List<SystemTcpConnectionInformation> tcpConnections = new List<SystemTcpConnectionInformation>();

    // Check if it supports IPv4 for IPv6 only modes.
    if (Socket.OSSupportsIPv4)
    {
        // ...[생략]...
        result = Interop.IpHlpApi.GetTcpTable(buffer, &size, order: true);
        // ...[생략]...
    }

    if (Socket.OSSupportsIPv6)
    {
        // ...[생략]...
        result = Interop.IpHlpApi.GetExtendedTcpTable(IntPtr.Zero, &size, order: true, (uint)AddressFamily.InterNetworkV6,
        // ...[생략]...
    }

    return tcpConnections;
}

따라서, IPv4에 대해서도 간단한 소스코드 변경만으로 GetExtendedTcpTable을 지원할 수 있었을 것이고, 자연스럽게 Process ID를 구할 수 있었을 텐데도 관련 코드는 누락이 된 상태입니다.




결국, 소켓에 대한 연관 프로세스를 알고 싶다면 netstat를 통해 우회하던가,

c:\temp> netstat -ano | findstr LISTEN
  TCP    0.0.0.0:80             0.0.0.0:0              LISTENING       4
  TCP    0.0.0.0:135            0.0.0.0:0              LISTENING       1824
  TCP    0.0.0.0:445            0.0.0.0:0              LISTENING       4
  TCP    0.0.0.0:1433           0.0.0.0:0              LISTENING       7884
...[생략]...

아니면 직접 GetExtendedTcpTable API를 사용하는 코드를 작성해야 합니다. 사실 이에 대한 포팅이 매우 쉬운데요, 닷넷 소스코드의 전체적인 구조를 그대로 베끼면서 GetExtendedTcpTable을 호출하도록 변경하는 정도만 신경 쓰면 되므로, 대충 다음과 같이 구현하는 것이 가능합니다.

static unsafe List<SystemTcpConnectionInformation> GetAllTcpConnections(AF_CLASS afClass, TCP_TABLE_CLASS tableClass)
{
    uint size = 0;
    uint result;
    List<SystemTcpConnectionInformation> tcpConnections = new List<SystemTcpConnectionInformation>();

    // Check if it supports IPv4 for IPv6 only modes.
    if (Socket.OSSupportsIPv4 && afClass == AF_CLASS.AF_INET)
    {
        // Get the buffer size needed.
        result = GetExtendedTcpTable(IntPtr.Zero, out size, true, afClass, tableClass, 0);

        while (result == ERROR_INSUFFICIENT_BUFFER)
        {
            // Allocate the buffer and get the TCP table.
            IntPtr buffer = Marshal.AllocHGlobal((int)size);
            try
            {
                result = GetExtendedTcpTable(buffer, out size, true, afClass, tableClass, 0);

                if (result == ERROR_SUCCESS)
                {
                    var span = new ReadOnlySpan<byte>((byte*)buffer, (int)size);

                    // The table info just gives us the number of rows.
                    ref readonly MibTcpTableOwnerPid tcpTableInfo = ref MemoryMarshal.AsRef<MibTcpTableOwnerPid>(span);

                    if (tcpTableInfo.numberOfEntries > 0)
                    {
                        // Skip over the tableinfo to get the inline rows.
                        span = span.Slice(sizeof(MibTcpTableOwnerPid));

                        for (int i = 0; i < tcpTableInfo.numberOfEntries - 1; i++)
                        {
                            SystemTcpConnectionInformation item = new SystemTcpConnectionInformation(in MemoryMarshal.AsRef<MibTcpRowOwnerPid>(span));
                            tcpConnections.Add(item);
                            span = span.Slice(sizeof(MibTcpRowOwnerPid));
                        }
                    }
                }
            }
            finally
            {
                Marshal.FreeHGlobal(buffer);
            }
        }

        // If we don't have any ipv4 interfaces detected, just continue.
        if (result != ERROR_SUCCESS && result != ERROR_NO_DATA)
        {
            throw new NetworkInformationException((int)result);
        }
    }

    if (Socket.OSSupportsIPv6 && afClass == AF_CLASS.AF_INET6)
    {
        // Get the buffer size needed.
        size = 0;
        result = GetExtendedTcpTable(IntPtr.Zero, out size, true, afClass, tableClass, 0);

        while (result == ERROR_INSUFFICIENT_BUFFER)
        {
            // Allocate the buffer and get the TCP table.
            IntPtr buffer = Marshal.AllocHGlobal((int)size);
            try
            {
                result = GetExtendedTcpTable(buffer, out size, true, afClass, tableClass, 0);
                if (result == ERROR_SUCCESS)
                {
                    var span = new ReadOnlySpan<byte>((byte*)buffer, (int)size);

                    // The table info just gives us the number of rows.
                    ref readonly MibTcp6TableOwnerPid tcpTable6OwnerPid = ref MemoryMarshal.AsRef<MibTcp6TableOwnerPid>(span);

                    if (tcpTable6OwnerPid.numberOfEntries > 0)
                    {
                        // Skip over the tableinfo to get the inline rows.
                        span = span.Slice(sizeof(MibTcp6TableOwnerPid));

                        for (int i = 0; i < tcpTable6OwnerPid.numberOfEntries; i++)
                        {
                            tcpConnections.Add(new SystemTcpConnectionInformation(in MemoryMarshal.AsRef<MibTcp6RowOwnerPid>(span)));
                            // We increment the pointer to the next row.
                            span = span.Slice(sizeof(MibTcp6RowOwnerPid));
                        }
                    }
                }
            }
            finally
            {
                Marshal.FreeHGlobal(buffer);
            }
        }

        // If we don't have any ipv6 interfaces detected, just continue.
        if (result != ERROR_SUCCESS && result != ERROR_NO_DATA)
        {
            throw new NetworkInformationException((int)result);
        }
    }

    return tcpConnections;
}

그다음 이렇게 사용해 주면,

{
    var props = IPGlobalPropertiesExtension.GetTcpIPv4Listeners();
    foreach (var item in props)
    {
        Console.WriteLine(item);
    }
}

{
    var props = IPGlobalPropertiesExtension.GetTcpIPv6Listeners();
    foreach (var item in props)
    {
        Console.WriteLine(item);
    }
}

다음과 같은 출력 결과를 얻을 수 있습니다.

0.0.0.0:80 Listen (pid:4)
0.0.0.0:135 Listen (pid:1824)
0.0.0.0:445 Listen (pid:4)
0.0.0.0:1433 Listen (pid:7884)
...[생략]...
[::]:80 Listen (pid:4)
[::]:135 Listen (pid:1824)
[::]:445 Listen (pid:4)
[::]:1433 Listen (pid:7884)
...[생략]...

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




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







[최초 등록일: ]
[최종 수정일: 2/15/2024]

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)
13718정성태8/27/20247431오류 유형: 921. Visual C++ - error C1083: Cannot open include file: 'float.h': No such file or directory [2]
13717정성태8/26/20247023VS.NET IDE: 192. Visual Studio 2022 - Windows XP / 2003용 C/C++ 프로젝트 빌드
13716정성태8/21/20246757C/C++: 167. Visual C++ - 윈도우 환경에서 _execv 동작 [1]
13715정성태8/19/20247362Linux: 78. 리눅스 C/C++ - 특정 버전의 glibc 빌드 (docker-glibc-builder)
13714정성태8/19/20246757닷넷: 2295. C# 12 - 기본 생성자(Primary constructors) (책 오타 수정) [3]
13713정성태8/16/20247466개발 환경 구성: 721. WSL 2에서의 Hyper-V Socket 연동
13712정성태8/14/20247223개발 환경 구성: 720. Synology NAS - docker 원격 제어를 위한 TCP 바인딩 추가
13711정성태8/13/20248063Linux: 77. C# / Linux - zombie process (defunct process) [1]파일 다운로드1
13710정성태8/8/20247996닷넷: 2294. C# 13 - (6) iterator 또는 비동기 메서드에서 ref와 unsafe 사용을 부분적으로 허용파일 다운로드1
13709정성태8/7/20247752닷넷: 2293. C# - safe/unsafe 문맥에 대한 C# 13의 (하위 호환을 깨는) 변화파일 다운로드1
13708정성태8/7/20247546개발 환경 구성: 719. ffmpeg / YoutubeExplode - mp4 동영상 파일로부터 Audio 파일 추출
13707정성태8/6/20247775닷넷: 2292. C# - 자식 프로세스의 출력이 4,096보다 많은 경우 Process.WaitForExit 호출 시 hang 현상파일 다운로드1
13706정성태8/5/20247895개발 환경 구성: 718. Hyper-V - 리눅스 VM에 새로운 디스크 추가
13705정성태8/4/20248165닷넷: 2291. C# 13 - (5) params 인자 타입으로 컬렉션 허용 [2]파일 다운로드1
13704정성태8/2/20248110닷넷: 2290. C# - 간이 dotnet-dump 프로그램 만들기파일 다운로드1
13703정성태8/1/20247437닷넷: 2289. "dotnet-dump ps" 명령어가 닷넷 프로세스를 찾는 방법
13702정성태7/31/20247845닷넷: 2288. Collection 식을 지원하는 사용자 정의 타입을 CollectionBuilder 특성으로 성능 보완파일 다운로드1
13701정성태7/30/20248111닷넷: 2287. C# 13 - (4) Indexer를 이용한 개체 초기화 구문에서 System.Index 연산자 허용파일 다운로드1
13700정성태7/29/20247726디버깅 기술: 200. DLL Export/Import의 Hint 의미
13699정성태7/27/20248238닷넷: 2286. C# 13 - (3) Monitor를 대체할 Lock 타입파일 다운로드1
13698정성태7/27/20248206닷넷: 2285. C# - async 메서드에서의 System.Threading.Lock 잠금 처리파일 다운로드1
13697정성태7/26/20247921닷넷: 2284. C# - async 메서드에서의 lock/Monitor.Enter/Exit 잠금 처리파일 다운로드1
13696정성태7/26/20247454오류 유형: 920. dotnet publish - error NETSDK1047: Assets file '...\obj\project.assets.json' doesn't have a target for '...'
13695정성태7/25/20247438닷넷: 2283. C# - Lock / Wait 상태에서도 STA COM 메서드 호출 처리파일 다운로드1
13694정성태7/25/20247906닷넷: 2282. C# - ASP.NET Core Web App의 Request 용량 상한값 (Kestrel, IIS)
13693정성태7/24/20247233개발 환경 구성: 717. Visual Studio - C# 프로젝트에서 레지스트리에 등록하지 않은 COM 개체 참조 및 사용 방법파일 다운로드1
1  2  3  4  5  6  7  8  [9]  10  11  12  13  14  15  ...