Microsoft MVP성태의 닷넷 이야기
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 1개 있습니다.)
(시리즈 글이 4개 있습니다.)
닷넷: 2188. C# - ASP.NET Core SignalR로 구현하는 채팅 서비스 예제
; https://www.sysnet.pe.kr/2/0/13504

닷넷: 2189. C# - WebSocket 클라이언트를 닷넷으로 구현하는 예제 (System.Net.WebSockets)
; https://www.sysnet.pe.kr/2/0/13505

닷넷: 2197. C# - ClientWebSocket의 Ping, Pong 처리
; https://www.sysnet.pe.kr/2/0/13518

닷넷: 2198. C# - Reflection을 이용한 ClientWebSocket의 Ping 호출
; https://www.sysnet.pe.kr/2/0/13519




C# - WebSocket 클라이언트를 닷넷으로 구현하는 예제 (System.Net.WebSockets)

지난 글에서,

C# - ASP.NET Core SignalR로 구현하는 채팅 서비스 예제
; https://www.sysnet.pe.kr/2/0/13504

SignalR로 채팅 서비스를 구현하면서 대충 WebSocket에 대한 맛보기를 했으니 어떤 기술인지 감은 잡았을 것입니다. 물론 SignalR 서비스가 구현이 매우 용이해서 좋긴 한데, 때로는 기존의 nodejs 등으로 구현한 WebSocket과 통신할 경우도 발생할 수 있으니 이에 대해서도 마저 알아보겠습니다.

그런 경우, RFC 문서를 보며 직접 구현하는 것도 가능한데 ^^ 그래도 적절한 WebSocket 클라이언트 라이브러리를 활용하는 것도 좋은 선택입니다. 검색해 보면 Websocket.Client 등도 나오지만,

Your First C# Websocket Client
; https://medium.com/nerd-for-tech/your-first-c-websocket-client-5e7acc30681d

이 글에서는 닷넷 자체에 이미 내장돼 있는 System.Net.WebSockets를 사용해 보겠습니다. 그렇긴 한데, 사실 이것도 다음과 같은 글에서 너무 자세하세 잘 소개하고 있어서,

WebSockets support in ASP.NET Core
; https://learn.microsoft.com/en-us/aspnet/core/fundamentals/websockets

WebSocket in .NET - Real-Time, Two-Way Communication Over TCP/IP
; https://medium.com/@kova98/websockets-in-net-59f1fc69bdcb

C# WebSocket
; https://zetcode.com/csharp/websocket/

저는 그냥 베끼는 수준으로만 정리해 보겠습니다. ^^;




예를 들어, nodejs로 다음과 같은 식의 WebSocket 서버를 만들어 볼까요?

var { WebSocketServer } = require('ws')

const sockserver = new WebSocketServer({ port: 18000 })

sockserver.on('connection', ws => {
    console.log('New client connected!')

    ws.send('connection established')

    ws.on('close', () => console.log('Client has disconnected!'))

    ws.on('message', data => {
        sockserver.clients.forEach(client => {
            console.log(`distributing message: ${data}`)
            client.send(`${data}`)
        })
    })

    ws.onerror = function () {
        console.log('websocket error')
    }
})

SignalR 서버를 작성해 봤다면, 구조가 묘하게 닮아 있어 닷넷 개발 경험만 있어도 위의 소스코드가 눈에 잘 들어올 것입니다. 게다가 Socket 서버 경험까지 있다면, socketserver 인스턴스를 서버 소켓으로, 이후 socketserver.on('connection', ws => {...}) 코드의 ws를 Accept로 받은 자식 소켓으로 쉽게 매칭이 될 것입니다.

자, 그럼 위의 소스 코드와 통신하는 WebSocket 클라이언트를 C#으로 다음과 같이 작성할 수 있습니다.

using System.Net.WebSockets;
using System.Text;

namespace WebSocketClient;

internal class Program
{
    static async Task Main(string[] args)
    {
        Console.WriteLine("Press any key to start");
        Console.ReadLine();

        string url = "ws://localhost:18000/";

        var connectTimeout = new CancellationTokenSource();
        connectTimeout.CancelAfter(2000);

        System.Net.WebSockets.ClientWebSocket ws = new System.Net.WebSockets.ClientWebSocket();
        await ws.ConnectAsync(new Uri(url), connectTimeout.Token);

        if (ws.State != System.Net.WebSockets.WebSocketState.Open)
        {
            Console.WriteLine($"Failed to connect: {url}");
            return;
        }

        Console.WriteLine($"Received: {await Read(ws)}");

        await ws.SendAsync(Encoding.UTF8.GetBytes("Hello"), WebSocketMessageType.Text, true, CancellationToken.None);

        Console.WriteLine($"Received: {await Read(ws)}");

        await ws.CloseAsync(WebSocketCloseStatus.NormalClosure, null, CancellationToken.None);
    }

    private static async Task<string> Read(ClientWebSocket ws)
    {
        var buffer = new byte[1024];
        var result = await ws.ReceiveAsync(buffer, CancellationToken.None);
        return Encoding.UTF8.GetString(buffer, 0, result.Count);
    }
}

단지 비동기 구문만 살짝 더 곁들여져서 복잡한 듯하지만, 기존의 TCP 소켓과 사용법이 거의 유사해서 딱히 더 설명할 것이 없을 정도군요. ^^;

암튼, 그냥 어렵지 않으니 언제든 쉽게 적용할 수 있다는 정도였다는 것만 알고 넘어가도 되겠습니다.

(첨부 파일은 이 글의 예제 코드를 포함합니다.)




참고로, WebSocket을 아예 TCP Socket 레벨에서 다루고 싶다면 아래의 글이 도움이 될 것입니다.

Writing a WebSocket server in C#
; https://developer.mozilla.org/en-US/docs/Web/API/WebSockets_API/Writing_WebSocket_server

C# WebSocket 서버 구현
; https://hgarchive.tistory.com/4

Golang으로 직접 WebSocket 통신 구현해보기
; https://docs.google.com/document/d/e/2PACX-1vRrf1SD1k4FyXv1G-DPlDbX9F3KsNMnKogF4SrUNqkA9X5P8F-w2yTGzgDunctdpfHIfmoQZaFZ3jm4/pub

거의 RFC 6455 규약대로 구현을 하고 있기 때문에 Web Socket에 대한 이해를 높일 수 있을 것입니다. 엄밀히 말해서, 단순한 TCP 통신의 한 사례일 뿐, 어쩌면 JavaScript가 이런 정도로까지 대중화하지 않았다면 나오지 않았을 기술입니다.




만약 이런 오류가 발생한다면?

System.Net.WebSockets.WebSocketException
  HResult=0x80004005
  Message=Unable to connect to the remote server
  Source=System.Net.WebSockets.Client
  StackTrace:
   at System.Net.WebSockets.WebSocketHandle.<ConnectAsync>d__22.MoveNext() in /_/src/libraries/System.Net.WebSockets.Client/src/System/Net/WebSockets/WebSocketHandle.Managed.cs:line 221

  This exception was originally thrown at this call stack:
    System.Net.Security.SslStream.GetFrameSize(System.ReadOnlySpan<byte>) in SslStream.IO.cs
    System.Net.Security.SslStream.EnsureFullTlsFrameAsync<TIOAdapter>(System.Threading.CancellationToken, int) in SslStream.IO.cs
    System.Runtime.CompilerServices.PoolingAsyncValueTaskMethodBuilder<TResult>.StateMachineBox<TStateMachine>.System.Threading.Tasks.Sources.IValueTaskSource<TResult>.GetResult(short) in PoolingAsyncValueTaskMethodBuilderT.cs
    System.Net.Security.SslStream.ReceiveHandshakeFrameAsync<TIOAdapter>(System.Threading.CancellationToken) in SslStream.IO.cs
    System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable<TResult>.ConfiguredValueTaskAwaiter.GetResult() in ConfiguredValueTaskAwaitable.cs
    System.Net.Security.SslStream.ForceAuthenticationAsync<TIOAdapter>(bool, byte[], System.Threading.CancellationToken) in SslStream.IO.cs
    System.Net.Security.SslStream.ProcessAuthenticationWithTelemetryAsync(bool, System.Threading.CancellationToken) in SslStream.IO.cs
    System.Net.Http.ConnectHelper.EstablishSslConnectionAsync(System.Net.Security.SslClientAuthenticationOptions, System.Net.Http.HttpRequestMessage, bool, System.IO.Stream, System.Threading.CancellationToken) in ConnectHelper.cs

Inner Exception 1:
HttpRequestException: The SSL connection could not be established, see inner exception.

Inner Exception 2:
AuthenticationException: Cannot determine the frame size or a corrupted frame was received.

SSL 통신으로 열어놓지 않은 WebSocket에 wss 프로토콜로 접근했기 때문입니다.

System.Net.WebSockets.ClientWebSocket ws = new System.Net.WebSockets.ClientWebSocket();
await ws.ConnectAsync(new Uri("wss://localhost:18000/"), CancellationToken.None);

HTTP와 HTTPS의 관계처럼, WS와 WSS는 Secure Socket 통신의 여부를 결정합니다.




이런 오류가 발생한다면?

System.Net.WebSockets.WebSocketException
  HResult=0x80004005
  Message=The server returned status code '200' when status code '101' was expected.
  Source=System.Net.WebSockets.Client
  StackTrace:
   at System.Net.WebSockets.WebSocketHandle.ValidateResponse(HttpResponseMessage response, String secValue) in /_/src/libraries/System.Net.WebSockets.Client/src/System/Net/WebSockets/WebSocketHandle.Managed.cs:line 454

접속하려는 WebSocket 주소가 올바른지 확인해 볼 필요가 있습니다. 즉, HTTP 웹 서비스가 반응하는 경우 저런 오류가 발생하게 됩니다.




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

[연관 글]






[최초 등록일: ]
[최종 수정일: 4/5/2024]

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

비밀번호

댓글 작성자
 




... 61  62  63  [64]  65  66  67  68  69  70  71  72  73  74  75  ...
NoWriterDateCnt.TitleFile(s)
12340정성태9/23/202016943.NET Framework: 943. WPF - WindowsFormsHost를 담은 윈도우 생성 시 메모리 누수
12339정성태9/21/202017163오류 유형: 655. 코어 모드의 윈도우는 GUI 모드의 윈도우로 교체가 안 됩니다.
12338정성태9/21/202017166오류 유형: 654. 우분투 설치 시 "CHS: Error 2001 reading sector ..." 오류 발생
12337정성태9/21/202018258오류 유형: 653. Windows - Time zone 설정을 바꿔도 반영이 안 되는 경우
12336정성태9/21/202021649.NET Framework: 942. C# - WOL(Wake On Lan) 구현
12335정성태9/21/202030847Linux: 31. 우분투 20.04 초기 설정 - 고정 IP 및 SSH 설치
12334정성태9/21/202015424오류 유형: 652. windbg - !py 확장 명령어 실행 시 "failed to find python interpreter"
12333정성태9/20/202015776.NET Framework: 941. C# - 전위/후위 증감 연산자에 대한 오버로딩 구현 (2)
12332정성태9/18/202018747.NET Framework: 940. C# - Windows Forms ListView와 DataGridView의 예제 코드파일 다운로드1
12331정성태9/18/202017663오류 유형: 651. repadmin /syncall - 0x80090322 The target principal name is incorrect.
12330정성태9/18/202018837.NET Framework: 939. C# - 전위/후위 증감 연산자에 대한 오버로딩 구현 [2]파일 다운로드1
12329정성태9/16/202021143오류 유형: 650. ASUS 메인보드 관련 소프트웨어 설치 후 ArmouryCrate.UserSessionHelper.exe 프로세스 무한 종료 현상
12328정성태9/16/202020046VS.NET IDE: 150. TFS의 이력에서 "Get This Version"과 같은 기능을 Git으로 처리한다면?
12327정성태9/12/202018214.NET Framework: 938. C# - ICS(Internet Connection Sharing) 제어파일 다운로드1
12326정성태9/12/202017594개발 환경 구성: 516. Azure VM의 Network Adapter를 실수로 비활성화한 경우
12325정성태9/12/202016794개발 환경 구성: 515. OpenVPN - 재부팅 후 ICS(Internet Connection Sharing) 기능이 동작 안하는 문제
12324정성태9/11/202017626개발 환경 구성: 514. smigdeploy.exe를 이용한 Windows Server 2016에서 2019로 마이그레이션 방법
12323정성태9/11/202016890오류 유형: 649. Copy Database Wizard - The job failed. Check the event log on the destination server for details.
12322정성태9/11/202020244개발 환경 구성: 513. Azure VM의 RDP 접속 위치 제한 [1]
12321정성태9/11/202015961오류 유형: 648. netsh http add urlacl - Error: 183 Cannot create a file when that file already exists.
12320정성태9/11/202018114개발 환경 구성: 512. RDP(원격 데스크톱) 접속 시 비밀 번호를 한 번 더 입력해야 하는 경우
12319정성태9/10/202017393오류 유형: 647. smigdeploy.exe를 Windows Server 2016에서 실행할 때 .NET Framework 미설치 오류 발생
12318정성태9/9/202016376오류 유형: 646. OpenVPN - "TAP-Windows Adapter V9" 어댑터의 "Network cable unplugged" 현상
12317정성태9/9/202019706개발 환경 구성: 511. Beats용 Kibana 기본 대시 보드 구성 방법
12316정성태9/8/202017564디버깅 기술: 170. WinDbg Preview 버전부터 닷넷 코어 3.0 이후의 메모리 덤프에 대해 sos.dll 자동 로드
12315정성태9/7/202019845개발 환경 구성: 510. Logstash - FileBeat을 이용한 IIS 로그 처리 [2]
... 61  62  63  [64]  65  66  67  68  69  70  71  72  73  74  75  ...