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

비밀번호

댓글 작성자
 




... 46  [47]  48  49  50  51  52  53  54  55  56  57  58  59  60  ...
NoWriterDateCnt.TitleFile(s)
12471정성태1/1/202110253.NET Framework: 992. C# - .NET Core 3.0 이상부터 제공하는 runtimeOptions의 rollForward 옵션 [1]
12470정성태12/30/202010438.NET Framework: 991. .NET 5 응용 프로그램에서 WinRT API 호출 [1]파일 다운로드1
12469정성태12/30/202014023.NET Framework: 990. C# - SendInput Win32 API를 이용한 가상 키보드/마우스 [1]파일 다운로드1
12468정성태12/30/202010605Windows: 186. CMD Shell의 "Defaults"와 "Properties"에서 폰트 정보가 다른 문제 [1]
12467정성태12/29/202010731.NET Framework: 989. HttpContextAccessor를 통해 이해하는 AsyncLocal<T> [1]파일 다운로드1
12466정성태12/29/20208556.NET Framework: 988. C# - 지연 실행이 꼭 필요한 상황이 아니라면 singleton 패턴에서 DCLP보다는 static 초기화를 권장파일 다운로드1
12465정성태12/29/202011754.NET Framework: 987. .NET Profiler - FunctionID와 연관된 ClassID를 구할 수 없는 문제
12464정성태12/29/202010562.NET Framework: 986. pptfont.exe - PPT 파일에 숨겨진 폰트 설정을 일괄 삭제
12463정성태12/29/20209612개발 환경 구성: 520. RDP(mstsc.exe)의 다중 모니터 옵션 /multimon, /span
12462정성태12/27/202011188디버깅 기술: 177. windbg - (ASP.NET 환경에서 유용한) netext 확장
12461정성태12/21/202011981.NET Framework: 985. .NET 코드 리뷰 팁 [3]
12460정성태12/18/20209837기타: 78. 도서 소개 - C#으로 배우는 암호학
12459정성태12/16/202010159Linux: 35. C# - 리눅스 환경에서 클라이언트 소켓의 ephemeral port 재사용파일 다운로드1
12458정성태12/16/20209568오류 유형: 694. C# - Task.Start 메서드 호출 시 "System.InvalidOperationException: 'Start may not be called on a task that has completed.'" 예외 발생 [1]
12457정성태12/15/20209115Windows: 185. C# - Windows 10/2019부터 추가된 SIO_TCP_INFO파일 다운로드1
12456정성태12/15/20209428VS.NET IDE: 156. Visual Studio - "Migrate packages.config to PackageReference"
12455정성태12/15/20208944오류 유형: 693. DLL 로딩 시 0x800704ec - This Program is Blocked by Group Policy
12454정성태12/15/20209560Windows: 184. Windows - AppLocker의 "DLL Rules"를 이용해 임의 경로에 설치한 DLL의 로딩을 막는 방법 [1]
12453정성태12/14/202010508.NET Framework: 984. C# - bool / BOOL / VARIANT_BOOL에 대한 Interop [1]파일 다운로드1
12452정성태12/14/202010790Windows: 183. 설정은 가능하지만 구할 수는 없는 TcpTimedWaitDelay 값
12451정성태12/14/20209912Windows: 182. WMI Namespace를 열거하고, 그 안에 정의된 클래스를 열거하는 방법 [5]
12450정성태12/13/202010712.NET Framework: 983. C# - TIME_WAIT과 ephemeral port 재사용파일 다운로드1
12449정성태12/11/202010993.NET Framework: 982. C# - HttpClient에서의 ephemeral port 재사용 [2]파일 다운로드1
12448정성태12/11/202012609.NET Framework: 981. C# - HttpWebRequest, WebClient와 ephemeral port 재사용파일 다운로드1
12447정성태12/10/202010775.NET Framework: 980. C# - CopyFileEx API 사용 예제 코드파일 다운로드1
12446정성태12/10/202011495.NET Framework: 979. C# - CoCreateInstanceEx 사용 예제 코드파일 다운로드1
... 46  [47]  48  49  50  51  52  53  54  55  56  57  58  59  60  ...