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)
12656정성태6/1/202120229.NET Framework: 1061. 서버 유형의 COM+에 적용할 수 없는 Server GC
12655정성태6/1/202117665오류 유형: 722. windbg/sos - savemodule - Fail to read memory
12654정성태5/31/202119306오류 유형: 721. Hyper-V - Saved 상태의 VM을 시작 시 오류 발생
12653정성태5/31/202122447.NET Framework: 1060. 닷넷 GC에 새롭게 구현되는 DPAD(Dynamic Promotion And Demotion for GC)
12652정성태5/31/202119876VS.NET IDE: 164. Visual Studio - Web Deploy로 Publish 시 암호창이 매번 뜨는 문제
12651정성태5/31/202120633오류 유형: 720. PostgreSQL - ERROR: 22P02: malformed array literal: "..."
12650정성태5/17/202120267기타: 82. OpenTabletDriver의 버튼에 더블 클릭을 매핑 및 게임에서의 지원 방법
12649정성태5/16/202121688.NET Framework: 1059. 세대 별 GC(Garbage Collection) 방식에서 Card table의 사용 의미 [1]
12648정성태5/16/202121747사물인터넷: 66. PC -> FTDI -> NodeMCU v1 ESP8266 기기를 UART 핀을 연결해 직렬 통신하는 방법파일 다운로드1
12647정성태5/15/202119322.NET Framework: 1058. C# - C++과의 연동을 위한 구조체의 fixed 배열 필드 사용파일 다운로드1
12646정성태5/15/202118498사물인터넷: 65. C# - Arduino IDE의 Serial Monitor 기능 구현파일 다운로드1
12645정성태5/14/202118498사물인터넷: 64. NodeMCU v1 ESP8266 - LittleFS를 이용한 와이파이 접속 정보 업데이트파일 다운로드1
12644정성태5/14/202121311오류 유형: 719. 윈도우 - 제어판의 "프로그램 및 기능" / "Windows 기능 켜기/끄기" 오류 0x800736B3
12643정성태5/14/202121921오류 유형: 718. 서버 유형의 COM+ 사용 시 0x80080005(Server execution failed) 오류 발생
12642정성태5/14/202122644오류 유형: 717. The 'Microsoft.ACE.OLEDB.12.0' provider is not registered on the local machine.
12641정성태5/13/202121360디버깅 기술: 179. 윈도우용 .NET Core 3 이상에서 Windbg의 sos 사용법
12640정성태5/13/202126194오류 유형: 716. RDP 연결 - Because of a protocol error (code: 0x112f), the remote session will be disconnected. [1]
12639정성태5/12/202122128오류 유형: 715. Arduino: Open Serial Monitor - The module '...\detection.node' was compiled against a different Node.js version using NODE_MODULE_VERSION
12638정성태5/12/202120327사물인터넷: 63. NodeMCU v1 ESP8266 - 펌웨어 내 파일 시스템(SPIFFS, LittleFS) 및 EEPROM 활용
12637정성태5/10/202122195사물인터넷: 62. NodeMCU v1 ESP8266 보드의 A0 핀에 다중 아날로그 센서 연결 [1]
12636정성태5/10/202123068사물인터넷: 61. NodeMCU v1 ESP8266 보드의 A0 핀 사용법 - FSR-402 아날로그 압력 센서 연동파일 다운로드1
12635정성태5/9/202119389기타: 81. OpenTabletDriver를 (관리자 권한으로 실행하지 않고도) 관리자 권한의 프로그램에서 동작하게 만드는 방법
12634정성태5/9/202117211개발 환경 구성: 572. .NET에서의 필수 무결성 제어 - 외부 Manifest 파일을 두는 방법파일 다운로드1
12633정성태5/7/202122554개발 환경 구성: 571. UAC - 관리자 권한 없이 UIPI 제약을 없애는 방법
12632정성태5/7/202123131기타: 80. (WACOM도 지원하는) Tablet 공통 디바이스 드라이버 - OpenTabletDriver
12631정성태5/5/202121989사물인터넷: 60. ThingSpeak 사물인터넷 플랫폼에 ESP8266 NodeMCU v1 + 조도 센서 장비 연동파일 다운로드1
... 46  47  48  49  50  51  52  53  54  [55]  56  57  58  59  60  ...