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

(시리즈 글이 3개 있습니다.)
.NET Framework: 830. C# - 비동기 호출을 취소하는 CancellationToken의 간단한 예제 코드
; https://www.sysnet.pe.kr/2/0/11888

닷넷: 2218. C# - (예를 들어, Socket) 비동기 I/O에 대한 await 호출 시 CancellationToken을 이용한 취소
; https://www.sysnet.pe.kr/2/0/13561

닷넷: 2231. C# - ReceiveTimeout, SendTimeout이 적용되지 않는 Socket await 비동기 호출
; https://www.sysnet.pe.kr/2/0/13580




C# - ReceiveTimeout, SendTimeout이 적용되지 않는 Socket await 비동기 호출

예전 글에서,

C# - (예를 들어, Socket) 비동기 I/O에 대한 await 호출 시 CancellationToken을 이용한 취소
; https://www.sysnet.pe.kr/2/0/13561

.NET Framework 환경의 NetworkStream.WriteAsync 비동기 메서드가 CancellationToken에 반응하지 않는다고 했는데요, 이 문제는 NetworkStream.ReadAsync 메서드에서도 그대로 나타납니다.

Socket clntSocket = socket.Accept();
NetworkStream ns = new NetworkStream(clntSocket);
while (true)
{
    byte [] buffer = new byte[1024];
    Console.WriteLine("Receive [before]");
    CancellationTokenSource cts = new CancellationTokenSource(3000);
    int received = await ns.ReadAsync(buffer, 0, buffer.Length, cts.Token);
    Console.WriteLine("Receive [after]");
}

위와 같이 실행하면, (클라이언트가 데이터를 전송하지 않는다고 가정하고) ns.ReadAsync는 3초 후에도 작업을 취소하지 못하고 await 콜백을 영원히 이어나가지 못합니다.




이 외에도 NetworkStream은 Socket.ReceiveTimeout, Socket.SendTimeout에도 영향을 받지 않습니다. 이전 글"에서 (.NET Framework에서 구현한) NetworkStream의 ...Async 메서드는 내부적으로 APM(Begin/End...) 비동기 메서드 호출을 사용한다고 했는데요, 이로 인해 Socket의 timeout 설정들이 적용되지 않는 것입니다.

그러니까 그냥 .NET Framework 환경에서 NetworkStream으로 비동기를 호출했을 때 timeout을 지정하는 것은 그냥 포기해야 합니다. (대신 우회 방법으로.)

또한 Socket 타입에서도 SendAsync, ReceiveAsync가 제공되는데 이것 역시 SendTimeout, ReceiveTimeout에 영향을 받지 않습니다.

clntSocket.ReceiveTimeout = 3000;

byte[] buffer = new byte[1024];
ArraySegment<byte> seg = new ArraySegment<byte>(buffer);

await clntSocket.ReceiveAsync(seg, SocketFlags.None); // 3초 지나도 await 이후의 콜백으로 진행하지 못함
            // 참고로, (.NET Framework에서 구현한) Socket 타입의 SendAsync, ReceiveAsync는 CancellationToken 인자를 아예 받지 않습니다.

사실 마이크로소프트의 문서에서도 이에 대해 명시를 하고 있습니다.

Socket.ReceiveTimeout Property
; https://learn.microsoft.com/ko-kr/dotnet/api/system.net.sockets.socket.receivetimeout

Gets or sets a value that specifies the amount of time after which a synchronous Receive call will time out.

Socket.SendTimeout Property
; https://learn.microsoft.com/ko-kr/dotnet/api/system.net.sockets.socket.sendtimeout

Gets or sets a value that specifies the amount of time after which a synchronous Send call will time out.





그렇다면 .NET Core/5+ 환경은 어떨까요? 마찬가지로 Socket 타입의 경우 SendAsync, ReceiveAsync는 SendTimeout, ReceiveTimeout에 영향을 받지 않습니다.

clntSocket.ReceiveTimeout = 3000;

byte[] buffer = new byte[1024];
ArraySegment<byte> seg = new ArraySegment<byte>(buffer);

await clntSocket.ReceiveAsync(seg, SocketFlags.None); // 3초 지나도 await 이후의 콜백으로 진행하지 못함

하지만, .NET Framework과는 달리 CancellationToken을 받는 메서드를 제공하고 있으며,

Memory<byte> seg = new Memory<byte>(buffer);
CancellationTokenSource cts = new CancellationTokenSource(3000);

await clntSocket.ReceiveAsync(seg, cts.Token); // 3초 후에 "System.OperationCanceledException: The operation was canceled." 예외 발생

Memory<byte> seg = new Memory<byte>(buffer);
CancellationTokenSource cts = new CancellationTokenSource(3000);

await clntSocket.SendAsync(seg, cts.Token); // 3초 후에 "System.OperationCanceledException: The operation was canceled." 예외 발생

Cancel 동작이 잘 수행됩니다. 그러니까 .NET Core/5+는 비동기 환경의 경우 (NetworkStream에서와 동일하게) CancellationToken으로 일관성있게 timeout 처리를 제공하고 있는 것입니다.




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







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

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

비밀번호

댓글 작성자
 




... [31]  32  33  34  35  36  37  38  39  40  41  42  43  44  45  ...
NoWriterDateCnt.TitleFile(s)
12872정성태12/12/20217816개발 환경 구성: 615. GoLang과 Python 빌드가 모두 가능한 docker 이미지 만들기
12871정성태12/12/20217848오류 유형: 771. docker: Error response from daemon: OCI runtime create failed
12870정성태12/9/20216402개발 환경 구성: 614. 파이썬 - PyPI 패키지 만들기 (4) package_data 옵션
12869정성태12/8/20218722개발 환경 구성: 613. git clone 실행 시 fingerprint 묻는 단계를 생략하는 방법
12868정성태12/7/20217314오류 유형: 770. twine 업로드 시 "HTTPError: 400 Bad Request ..." 오류 [1]
12867정성태12/7/20216970개발 환경 구성: 612. 파이썬 - PyPI 패키지 만들기 (3) entry_points 옵션
12866정성태12/7/202114372오류 유형: 769. "docker build ..." 시 "failed to solve with frontend dockerfile.v0: failed to read dockerfile ..." 오류
12865정성태12/6/20217090개발 환경 구성: 611. 파이썬 - PyPI 패키지 만들기 (2) long_description, cmdclass 옵션
12864정성태12/6/20215517Linux: 46. WSL 환경에서 find 명령을 사용해 파일을 찾는 방법
12863정성태12/4/20217451개발 환경 구성: 610. 파이썬 - PyPI 패키지 만들기
12862정성태12/3/20216141오류 유형: 768. Golang - 빌드 시 "cmd/go: unsupported GOOS/GOARCH pair linux /amd64" 오류
12861정성태12/3/20218394개발 환경 구성: 609. 파이썬 - "Windows embeddable package"로 개발 환경 구성하는 방법
12860정성태12/1/20216448오류 유형: 767. SQL Server - 127.0.0.1로 접속하는 경우 "Access is denied"가 발생한다면?
12859정성태12/1/202112651개발 환경 구성: 608. Hyper-V 가상 머신에 Console 모드로 로그인하는 방법
12858정성태11/30/20219908개발 환경 구성: 607. 로컬의 USB 장치를 원격 머신에 제공하는 방법 - usbip-win
12857정성태11/24/20217270개발 환경 구성: 606. WSL Ubuntu 20.04에서 파이썬을 위한 uwsgi 설치 방법
12856정성태11/23/20219148.NET Framework: 1121. C# - 동일한 IP:Port로 바인딩 가능한 서버 소켓 [2]
12855정성태11/13/20216378개발 환경 구성: 605. Azure App Service - Kudu SSH 환경에서 FTP를 이용한 파일 전송
12854정성태11/13/20218055개발 환경 구성: 604. Azure - 윈도우 VM에서 FTP 여는 방법
12853정성태11/10/20216343오류 유형: 766. Azure App Service - JBoss 호스팅 생성 시 "This region has quota of 0 PremiumV3 instances for your subscription. Try selecting different region or SKU."
12851정성태11/1/20217835스크립트: 34. 파이썬 - MySQLdb 기본 예제 코드
12850정성태10/27/20218991오류 유형: 765. 우분투에서 pip install mysqlclient 실행 시 "OSError: mysql_config not found" 오류
12849정성태10/17/20218081스크립트: 33. JavaScript와 C#의 시간 변환 [1]
12848정성태10/17/20219025스크립트: 32. 파이썬 - sqlite3 기본 예제 코드 [1]
12847정성태10/14/20218883스크립트: 31. 파이썬 gunicorn - WORKER TIMEOUT 오류 발생
12846정성태10/7/20218608스크립트: 30. 파이썬 __debug__ 플래그 변수에 따른 코드 실행 제어
... [31]  32  33  34  35  36  37  38  39  40  41  42  43  44  45  ...