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

비밀번호

댓글 작성자
 




... 16  17  18  19  20  21  22  23  24  25  [26]  27  28  29  30  ...
NoWriterDateCnt.TitleFile(s)
13002정성태3/14/20227435.NET Framework: 1178. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 http_multiclient.c 예제 포팅
13001정성태3/13/20227797.NET Framework: 1177. C# - 닷넷에서 허용하는 메서드의 매개변수와 호출 인자의 최대 수
13000정성태3/12/20227414.NET Framework: 1176. C# - Oracle.ManagedDataAccess.Core의 성능 카운터 설정 방법
12999정성태3/10/20226926.NET Framework: 1175. Visual Studio - 프로젝트 또는 솔루션의 Clean 작업 시 응용 프로그램에서 생성한 파일을 함께 삭제파일 다운로드1
12998정성태3/10/20226443.NET Framework: 1174. C# - ELEMENT_TYPE_FNPTR 유형의 사용 예
12997정성태3/10/202211059오류 유형: 799. Oracle.ManagedDataAccess - "ORA-01882: timezone region not found" 오류가 발생하는 이유
12996정성태3/9/202215983VS.NET IDE: 175. Visual Studio - 인텔리센스에서 오버로드 메서드를 키보드로 선택하는 방법
12995정성태3/8/20228376.NET Framework: 1173. .NET에서 Producer/Consumer를 구현한 BlockingCollection<T>
12994정성태3/8/20227639오류 유형: 798. WinDbg - Failed to load data access module, 0x80004002
12993정성태3/4/20227471.NET Framework: 1172. .NET에서 Producer/Consumer를 구현하는 기초 인터페이스 - IProducerConsumerCollection<T>
12992정성태3/3/20228996.NET Framework: 1171. C# - BouncyCastle을 사용한 암호화/복호화 예제파일 다운로드1
12991정성태3/2/20228072.NET Framework: 1170. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 transcode_aac.c 예제 포팅
12990정성태3/2/20227760오류 유형: 797. msbuild - The BaseOutputPath/OutputPath property is not set for project '[...].vcxproj'
12989정성태3/2/20227203오류 유형: 796. mstest.exe - System.IO.FileNotFoundException: Could not load file or assembly 'Microsoft.VisualStudio.QualityTools.Tips.WebLoadTest.Tip
12988정성태3/2/20226171오류 유형: 795. CI 환경에서 Docker build 시 csproj의 Link 파일에 대한 빌드 오류
12987정성태3/1/20227696.NET Framework: 1169. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 demuxing_decoding.c 예제 포팅
12986정성태2/28/20228515.NET Framework: 1168. C# -IIncrementalGenerator를 적용한 Version 2 Source Generator 실습 [1]
12985정성태2/28/20228437.NET Framework: 1167. C# -Version 1 Source Generator 실습
12984정성태2/24/20227484.NET Framework: 1166. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 filtering_video.c 예제 포팅
12983정성태2/24/20227563.NET Framework: 1165. .NET Core/5+ 빌드 시 runtimeconfig.json에 설정을 반영하는 방법
12982정성태2/24/20227510.NET Framework: 1164. HTTP Error 500.31 - ANCM Failed to Find Native Dependencies
12981정성태2/23/20227008VC++: 154. C/C++ 언어의 문자열 Literal에 인덱스 적용하는 구문 [1]
12980정성태2/23/20227873.NET Framework: 1163. C# - 윈도우 환경에서 usleep을 호출하는 방법 [2]
12979정성태2/22/202210422.NET Framework: 1162. C# - 인텔 CPU의 P-Core와 E-Core를 구분하는 방법 [1]파일 다운로드2
12978정성태2/21/20227716.NET Framework: 1161. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 resampling_audio.c 예제 포팅
12977정성태2/21/202211447.NET Framework: 1160. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 qsv 디코딩
... 16  17  18  19  20  21  22  23  24  25  [26]  27  28  29  30  ...