(转)netcore原生websocket客户端写法(ClientWebSocket)

代码:

using System;

using System.Net.WebSockets;

using System.Text;

using System.Threading;

using System.Threading.Tasks;

namespace Demo

{

    class Program

    {

        async static Task Main(string[] args)

        {

            var client = new ClientWebSocket();

            client.ConnectAsync(new Uri("ws://echo.websocket.org"), CancellationToken.None).Wait();

            StartReceiving(client);

            string line;

            while ((line = Console.ReadLine()) != "exit")

            {

                var array = new ArraySegment<byte>(Encoding.UTF8.GetBytes(line));

                await client.SendAsync(array, WebSocketMessageType.Text, true, CancellationToken.None);

            }

        }

        static async void StartReceiving(ClientWebSocket client)

        {

            while (true)

            {

                var array = new byte[4096];

                var result = await client.ReceiveAsync(new ArraySegment<byte>(array), CancellationToken.None);

                if (result.MessageType == WebSocketMessageType.Text)

                {

                    string msg = Encoding.UTF8.GetString(array, 0, result.Count);

                    Console.ForegroundColor = ConsoleColor.DarkBlue;

                    Console.WriteLine("--> {0}", msg);

                    Console.ForegroundColor = ConsoleColor.DarkGray;

                }

            }

        }

    }

}

原文地址

巴特西

(转)netcore原生websocket客户端写法(ClientWebSocket)

最新文章

热门文章