Microsoft MVP성태의 닷넷 이야기
.NET Framework: 572. .NET APM 비동기 호출의 Begin...과 End... 조합 [링크 복사], [링크+제목 복사]
조회: 16336
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 3개 있습니다.)

.NET APM 비동기 호출의 Begin...과 End... 조합

.NET의 APM(Asynchronous Programming Model) 비동기 호출 패턴은 Begin과 End 쌍으로 이뤄집니다. 일반적으로, 이 쌍은 어떻게든지 맞춰주는 것이 좋습니다. 심지어, End 메서드의 호출 시에 예외가 발생한다고 해도 마찬가지입니다.

예를 하나 들어볼까요?

string host = "192.168.0.95";
int port = 25000;
int timeout = 500;

while (true)
{
    Socket _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

    IAsyncResult result = _socket.BeginConnect(host, port, (ar) =>
    {
    }, null);

    if (result.AsyncWaitHandle.WaitOne(TimeSpan.FromMilliseconds(timeout), false) == false)
    {
        continue;
    }

    _socket.EndConnect(result);
    break;
}

위의 코드는 서버에 연결이 될 때까지 재시도를 하는 코드입니다. 재미있는 것은 여기서 WaitOne이 지정된 Timeout이 지나 EndConnect를 호출하면 예외가 발생합니다. 왜냐하면 연결이 될 수 없는 상황이기 때문인데, 그로 인해 EndConnect를 호출하지 않고 다시 재시도를 하는 코드로 넘어가고 있습니다. 표면상으로 보면 문제가 없을 듯 싶은데 실제로 이 프로그램을 실행하고 "netstat -ano" 명령어를 통해 해당 프로세스에 속한 소켓 포트를 확인해 보면 약 40여개의 포트가 잠식되고 있는 것을 볼 수 있습니다.

 TCP    220.152.82.220:33382   192.168.0.95:25000      SYN_SENT        5636
 TCP    220.152.82.220:33383   192.168.0.95:25000      SYN_SENT        5636
...[생략]...
 TCP    220.152.82.220:33421   192.168.0.95:25000      SYN_SENT        5636
 TCP    220.152.82.220:33422   192.168.0.95:25000      SYN_SENT        5636
 TCP    220.152.82.220:33423   192.168.0.95:25000      SYN_SENT        5636
 

더욱 재미있는 것은, 지정된 IP(본문에서는 192.168.0.95)에 해당하는 컴퓨터가 있는 경우에는 (연결 포트로 대기하는 프로그램이 없어도) 2~3개의 소켓 포트만 살아 있는 것을 볼 수 있습니다.

반면, 예외가 발생한다고 해도 아래와 같이 EndConnect를 명시적으로 호출해주면 어떤 상황에서도 1개의 소켓 포트만 SYN_SENT 상태로 사용되는 것을 확인할 수 있습니다.

while (true)
{
    Socket _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

    IAsyncResult result = _socket.BeginConnect(host, port, (ar) =>
    {
    }, null);

    result.AsyncWaitHandle.WaitOne(TimeSpan.FromMilliseconds(timeout), false);

    try
    {
        _socket.EndConnect(result);
        break;
    }
    catch { }

    continue;
}

사실, Begin/End 쌍을 맞추라는 건 .NET APM 비동기 호출 패턴에서 명시하고 있는 내용이긴 합니다.

For each call to BeginOperationName, the application should also call EndOperationName to get the results of the operation. 

하지만 위의 내용만으로 보면, "to get the results of the opration"이라고 써 있으므로 결과가 필요없으면 호출하지 않아도 될 것같은 의미를 담지만, 결과는 물론이고 심지어 예외가 발생하는 명백한 상황일지라도 Begin/End 쌍을 반드시 맞춰주는 것이 좋습니다.

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




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

[연관 글]






[최초 등록일: ]
[최종 수정일: 7/17/2021]

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

비밀번호

댓글 작성자
 



2016-04-18 04시21분
[spowner] 중요한 정보 감사합니다
[guest]
2016-04-19 12시54분
[이성환] CLR via C# 2판에서는 APM 기법을 설명하면서 자세히 다루었던 내용 중 하나였죠. 4판에 오면서 APM 삭제되면서 내용이 없어지긴 했지만

"개발자는 EndXXX 메서드를 꼭 호출해야 한다. 그렇지 않으면 리소스가 누수되기 때문이다. 일부 개발자는 데이터 장치에 자료를 저장하기 위해서 BeginXXX를 호출하고, 이후의 결과 값이나 진행 상태에 관심이 없다면 EndXXX를 호출하지 않는 경우를 종종 봐왔다. 하지만 EndXXX를 호출해야 하는 이유는 두 가지가 있다.
 
첫째 CLR은 이 리소스들을 EndXXX 메서드가 호출될 때까지 유지시킨다. 그리고 EndXXX 메서드가 결국 호출되지 않는다면 이 리소스들은 계속 반환되지 않다가 프로세스가 종료될 때에 반환된다. 둘째, 비동기 작업을 초기화할 때 실제로 개발자는이 작업이 성공할 것인지 알지 못한다. 성공유무를 확실하게 확인하는 방법은 EndXXX 메서드를 호출하는 것이며, 이 메서드를 호출함으로써 결과 값이 정상적으로 반환되는지 아니면 예외가 발생하는지 알 수 있다."
- CLR via C#

이런 내용이 있긴했습니다.... 그 땐 그냥 그러려니 했는데 다시금 이렇게 짚어 주시니 잘못 사용했던 기억이 새록새록 나네요. =ㅂ=;;
좋은 글 감사합니다.
[guest]
2016-04-19 12시30분
@이성환 자세한 출처 감사드립니다. (^^ 저도 말씀해주신 내용을 읽어봤다는 정도로만 기억하고 있었는데, 전혀 기억이 안 나서 어쩔 수 없이 MSDN 도움말을 본문에서 인용하였습니다.)
정성태

... 46  47  48  49  50  51  52  53  54  55  56  57  [58]  59  60  ...
NoWriterDateCnt.TitleFile(s)
12171정성태3/6/202010818VS.NET IDE: 143. Visual Studio - ASP.NET Core Web Application의 "Enable Docker Support" 옵션으로 달라지는 점 [1]
12170정성태3/6/20209460오류 유형: 599. "Docker Desktop is switching..." 메시지와 DockerDesktopVM CPU 소비 현상
12169정성태3/5/202011492개발 환경 구성: 473. Windows nanoserver에 대한 docker pull의 태그 사용 [1]
12168정성태3/5/202012158개발 환경 구성: 472. 윈도우 환경에서의 dockerd.exe("Docker Engine" 서비스)가 Linux의 것과 다른 점
12167정성태3/5/202011409개발 환경 구성: 471. C# - 닷넷 응용 프로그램에서 DB2 Express-C 데이터베이스 사용 (3) - ibmcom/db2express-c 컨테이너 사용
12166정성태3/4/202011074개발 환경 구성: 470. Windows Server 컨테이너 - DockerMsftProvider 모듈을 이용한 docker 설치
12165정성태3/2/202010752.NET Framework: 900. 실행 시에 메서드 가로채기 - CLR Injection: Runtime Method Replacer 개선 - 네 번째 이야기(Monitor.Enter 후킹)파일 다운로드1
12164정성태2/29/202011610오류 유형: 598. Surface Pro 6 - Windows Hello Face Software Device가 인식이 안 되는 문제
12163정성태2/27/202010027.NET Framework: 899. 익명 함수를 가리키는 delegate 필드에 대한 직렬화 문제
12162정성태2/26/202012789디버깅 기술: 166. C#에서 만든 COM 객체를 C/C++로 P/Invoke Interop 시 메모리 누수(Memory Leak) 발생 [6]파일 다운로드2
12161정성태2/26/20209466오류 유형: 597. manifest - The value "x64" of attribute "processorArchitecture" in element "assemblyIdentity" is invalid.
12160정성태2/26/202010149개발 환경 구성: 469. Reg-free COM 개체 사용을 위한 manifest 파일 생성 도구 - COMRegFreeManifest
12159정성태2/26/20208357오류 유형: 596. Visual Studio - The project needs to include ATL support
12158정성태2/25/202010161디버깅 기술: 165. C# - Marshal.GetIUnknownForObject/GetIDispatchForObject 사용 시 메모리 누수(Memory Leak) 발생파일 다운로드1
12157정성태2/25/202010014디버깅 기술: 164. C# - Marshal.GetNativeVariantForObject 사용 시 메모리 누수(Memory Leak) 발생 및 해결 방법파일 다운로드1
12156정성태2/25/20209379오류 유형: 595. LINK : warning LNK4098: defaultlib 'nafxcw.lib' conflicts with use of other libs; use /NODEFAULTLIB:library
12155정성태2/25/20208677오류 유형: 594. Warning NU1701 - This package may not be fully compatible with your project
12154정성태2/25/20208555오류 유형: 593. warning LNK4070: /OUT:... directive in .EXP differs from output filename
12153정성태2/23/202011194.NET Framework: 898. Trampoline을 이용한 후킹의 한계파일 다운로드1
12152정성태2/23/202010932.NET Framework: 897. 실행 시에 메서드 가로채기 - CLR Injection: Runtime Method Replacer 개선 - 세 번째 이야기(Trampoline 후킹)파일 다운로드1
12151정성태2/22/202011501.NET Framework: 896. C# - Win32 API를 Trampoline 기법을 이용해 C# 메서드로 가로채는 방법 - 두 번째 이야기 (원본 함수 호출)파일 다운로드1
12150정성태2/21/202011328.NET Framework: 895. C# - Win32 API를 Trampoline 기법을 이용해 C# 메서드로 가로채는 방법 [1]파일 다운로드1
12149정성태2/20/202011079.NET Framework: 894. eBEST C# XingAPI 래퍼 - 연속 조회 처리 방법 [1]
12148정성태2/19/202012289디버깅 기술: 163. x64 환경에서 구현하는 다양한 Trampoline 기법 [1]
12147정성태2/19/202010925디버깅 기술: 162. x86/x64의 기계어 코드 최대 길이
12146정성태2/18/202011176.NET Framework: 893. eBEST C# XingAPI 래퍼 - 로그인 처리파일 다운로드1
... 46  47  48  49  50  51  52  53  54  55  56  57  [58]  59  60  ...