Microsoft MVP성태의 닷넷 이야기
.NET Framework: 572. .NET APM 비동기 호출의 Begin...과 End... 조합 [링크 복사], [링크+제목 복사],
조회: 16452
글쓴 사람
정성태 (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)
12201정성태3/18/202010840오류 유형: 611. git-credential-manager.exe: Using credentials for username "Personal Access Token". [1]
12200정성태3/18/202011291VS.NET IDE: 145. NuGet + Github 라이브러리 디버깅 관련 옵션 3가지 - "Enable Just My Code" / "Enable Source Link support" / "Suppress JIT optimization on module load (Managed only)"
12199정성태3/17/20209153오류 유형: 610. C# - CodeDomProvider 사용 시 Unhandled Exception: System.IO.DirectoryNotFoundException: Could not find a part of the path '...\f2_6uod0.tmp'.
12198정성태3/17/202011863오류 유형: 609. SQL 서버 접속 시 "Cannot open user default database. Login failed."
12197정성태3/17/202011003VS.NET IDE: 144. .NET Core 콘솔 응용 프로그램을 배포(publish) 시 docker image 자동 생성 - 두 번째 이야기 [1]
12196정성태3/17/20208922오류 유형: 608. The ServicedComponent being invoked is not correctly configured (Use regsvcs to re-register).
12195정성태3/16/202010656.NET Framework: 902. C# - 프로세스의 모든 핸들을 열람 - 세 번째 이야기
12194정성태3/16/202012986오류 유형: 607. PostgreSQL - Npgsql.NpgsqlException: sorry, too many clients already
12193정성태3/16/20209606개발 환경 구성: 485. docker - SAP Adaptive Server Enterprise 컨테이너 실행 [1]
12192정성태3/14/202012072개발 환경 구성: 484. docker - Sybase Anywhere 16 컨테이너 실행
12191정성태3/14/202012438개발 환경 구성: 483. docker - OracleXE 컨테이너 실행 [1]
12190정성태3/14/20208597오류 유형: 606. Docker Desktop 업그레이드 시 "The process cannot access the file 'C:\Program Files\Docker\Docker\resources\dockerd.exe' because it is being used by another process."
12189정성태3/13/202013442개발 환경 구성: 482. Facebook OAuth 처리 시 상태 정보 전달 방법과 "유효한 OAuth 리디렉션 URI" 설정 규칙
12188정성태3/13/202015644Windows: 169. 부팅 시점에 실행되는 chkdsk 결과를 확인하는 방법
12187정성태3/12/20208396오류 유형: 605. NtpClient was unable to set a manual peer to use as a time source because of duplicate error on '...'.
12186정성태3/12/20209472오류 유형: 604. The SysVol Permissions for one or more GPOs on this domain controller and not in sync with the permissions for the GPOs on the Baseline domain controller.
12185정성태3/11/202010129오류 유형: 603. The browser service was unable to retrieve a list of servers from the browser master...
12184정성태3/11/202011586오류 유형: 602. Automatic certificate enrollment for local system failed (0x800706ba) The RPC server is unavailable. [3]
12183정성태3/11/20209938오류 유형: 601. Warning: DsGetDcName returned information for \\[...], when we were trying to reach [...].
12182정성태3/11/202011144.NET Framework: 901. C# Windows Forms - Vista/7 이후의 Progress Bar 업데이트가 느린 문제파일 다운로드1
12181정성태3/11/202011957기타: 76. 재현 가능한 최소한의 예제 프로젝트란? - 두 번째 예제파일 다운로드1
12180정성태3/10/20208576오류 유형: 600. "Docker Desktop for Windows" - EXPOSE 포트가 LISTENING 되지 않는 문제
12179정성태3/10/202019978개발 환경 구성: 481. docker - PostgreSQL 컨테이너 실행
12178정성태3/10/202011465개발 환경 구성: 480. Linux 운영체제의 docker를 위한 tcp 바인딩 추가 [1]
12177정성태3/9/202011115개발 환경 구성: 479. docker - MySQL 컨테이너 실행
12176정성태3/9/202010529개발 환경 구성: 478. 파일의 (sha256 등의) 해시 값(checksum) 확인하는 방법
... 46  47  48  49  50  51  52  53  54  55  56  [57]  58  59  60  ...