{"id":671,"date":"2019-09-26T15:44:54","date_gmt":"2019-09-26T06:44:54","guid":{"rendered":"http:\/\/csharp.ihavenomoney.co.kr\/?p=671"},"modified":"2019-09-27T17:38:23","modified_gmt":"2019-09-27T08:38:23","slug":"web-sockets-4","status":"publish","type":"post","link":"https:\/\/csharp.ihavenomoney.co.kr\/?p=671","title":{"rendered":"web-sockets-4"},"content":{"rendered":"\n
using Microsoft.AspNetCore.Hosting; \/\/IWebHostBuilder\r\nusing Microsoft.AspNetCore.Builder; \/\/IApplicationBuilder\r\nusing Microsoft.AspNetCore.Http; \/\/WriteAsync\r\nusing Microsoft.Extensions.DependencyInjection;\r\nusing Microsoft.Extensions.Logging;\r\nusing Microsoft.AspNetCore;\r\nusing System;\r\nusing System.Threading;\r\nusing System.Net.WebSockets;\r\nusing System.Text;\r\nusing System.IO;\r\nusing System.Collections.Concurrent;\r\nusing System.Linq;\r\nusing System.Threading.Tasks;\r\nusing System.Collections.Generic;\r\n\r\nnamespace WebApplication1\r\n{\r\n    public class ConnectionManager\r\n    {\r\n        ConcurrentDictionary<string, WebSocket> _sockets = new ConcurrentDictionary<string, WebSocket>();\r\n\r\n        public string AddSocket(WebSocket socket)\r\n        {\r\n            var id = Guid.NewGuid().ToString();\r\n\r\n            if (!_sockets.TryAdd(id, socket))\r\n                throw new Exception($\"Problem in adding socket with Id {id}\");\r\n\r\n            return id;\r\n        }\r\n\r\n        public List<(WebSocket socket, string id)> Other(string id) => _sockets.Where(x => x.Key != id).Select(x => (socket: x.Value, id: x.Key)).ToList();\r\n    }\r\n\r\n    public class Startup\r\n    {\r\n        async Task ReceiveAsync(ILogger log, WebSocket socket, string socketId, Func<string, Task> responseHandlerAsync)\r\n        {\r\n            var bufferSize = new byte[4]; \/\/This is especially small just to exercise the code that handles data that is larger than buffer\r\n            var receiveBuffer = new ArraySegment<byte>(bufferSize);\r\n            WebSocketReceiveResult result;\r\n\r\n            while (socket.State == WebSocketState.Open)\r\n            {\r\n                using (var ms = new MemoryStream())\r\n                {\r\n                    do\r\n                    {\r\n                        result = await socket.ReceiveAsync(receiveBuffer, CancellationToken.None);\r\n                        if (result.MessageType != WebSocketMessageType.Text)\r\n                            throw new Exception(\"Unexpected Message\");\r\n\r\n                        ms.Write(receiveBuffer.Array, receiveBuffer.Offset, result.Count);\r\n                    }\r\n\r\n                    while (!result.EndOfMessage && !result.CloseStatus.HasValue);\r\n\r\n                    ms.Seek(0, SeekOrigin.Begin);\r\n\r\n                    string clientRequest = string.Empty;\r\n                    using (var reader = new StreamReader(ms, Encoding.UTF8))\r\n                    {\r\n                        clientRequest = reader.ReadToEnd();\r\n                    }\r\n\r\n                    log.LogDebug($\"Socket Id {socketId} : Receive: {clientRequest}\");\r\n\r\n                    await responseHandlerAsync(clientRequest);\r\n\r\n                    if (result.CloseStatus.HasValue)\r\n                        break;\r\n                }\r\n            }\r\n        }\r\n\r\n        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory logger)\r\n        {\r\n            \/\/logger.AddConsole((str, level) => !str.Contains(\"Microsoft.AspNetCore\") && level >= LogLevel.Trace);\r\n\r\n            IServiceCollection serviceCollection = new ServiceCollection();\r\n            serviceCollection.AddLogging(builder => builder\r\n                .AddConsole()\r\n                .AddFilter(level => level >= LogLevel.Information)\r\n            );\r\n            var loggerFactory = serviceCollection.BuildServiceProvider().GetService<ILoggerFactory>();\r\n\r\n\r\n            var log = loggerFactory.CreateLogger(\"\");\r\n\r\n            app.UseWebSockets();\r\n\r\n            var cm = new ConnectionManager();\r\n\r\n            int count = 0;\r\n            app.Use(async (context, next) =>\r\n            {\r\n                if (!context.WebSockets.IsWebSocketRequest)\r\n                {\r\n                    await next();\r\n                    return;\r\n                }\r\n\r\n                var socket = await context.WebSockets.AcceptWebSocketAsync();\r\n                var socketId = cm.AddSocket(socket);\r\n\r\n                await ReceiveAsync(log, socket, socketId, async (clientRequest) =>\r\n                {\r\n                    var serverReply = Encoding.UTF8.GetBytes($\"Echo {++count} {clientRequest}\");\r\n                    var replyBuffer = new ArraySegment<byte>(serverReply);\r\n                    await socket.SendAsync(replyBuffer, WebSocketMessageType.Text, true, CancellationToken.None);\r\n\r\n                    var broadcastReply = Encoding.UTF8.GetBytes($\"Broadcast {count} {clientRequest}\");\r\n                    var broadcastBuffer = new ArraySegment<byte>(broadcastReply);\r\n\r\n                    var socketTasks = new List<Task>();\r\n\r\n                    foreach (var (s, sid) in cm.Other(socketId))\r\n                    {\r\n                        socketTasks.Add(s.SendAsync(broadcastBuffer, WebSocketMessageType.Text, true, CancellationToken.None));\r\n                        log.LogDebug($\"Broadcasting to : {sid}\");\r\n                    }\r\n\r\n                    await Task.WhenAll(socketTasks);\r\n                });\r\n            });\r\n\r\n            app.Run(async context =>\r\n            {\r\n                context.Response.Headers.Add(\"content-type\", \"text\/html\");\r\n                await context.Response.WriteAsync(@\"\r\n<html>                \r\n    <head>\r\n        <script src=\"\"https:\/\/code.jquery.com\/jquery-3.2.1.min.js\"\" integrity=\"\"sha256-hwg4gsxgFZhOsEEamdOYGBf13FyQuiTwlAQgxVSNgt4=\"\" crossorigin=\"\"anonymous\"\"><\/script>\r\n    <\/head>\r\n    <body>\r\n        <h1>Web Socket (please open this page at 2 tabs at least)<\/h1>\r\n        <input type=\"\"text\"\" length=\"\"50\"\" id=\"\"msg\"\" value=\"\"hello world\"\"\/> <button type=\"\"button\"\" id=\"\"send\"\">Send<\/button>\r\n        <br\/>\r\n        <ul id=\"\"responses\"\"><\/ul>\r\n        <script>\r\n            $(function(){\r\n                var url = \"\"wss:\/\/localhost:44323\/\"\";\r\n                var socket = new WebSocket(url);\r\n                var send = $(\"\"#send\"\");\r\n                var msg = $(\"\"#msg\"\");\r\n                var responses = $(\"\"#responses\"\");\r\n\r\n                socket.onopen = function(e){\r\n                    send.click(function(){\r\n                        socket.send(msg.val());                    \r\n                    });\r\n                };\r\n\r\n                socket.onmessage = function(e){\r\n                    var response = e.data;\r\n                    responses.append('<BR\/>');\r\n                    responses.append(response.trim());\r\n                };\r\n            });\r\n        <\/script>\r\n    <\/body>\r\n<\/html>\");\r\n            });\r\n        }\r\n    }\r\n\r\n    public class Program\r\n        {\r\n            public static void Main(string[] args)\r\n            {\r\n                CreateWebHostBuilder(args).Build().Run();\r\n            }\r\n\r\n        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>\r\n            WebHost.CreateDefaultBuilder(args)\r\n                .UseStartup<Startup>()\r\n                .UseEnvironment(\"Development\");\r\n        }\r\n}<\/pre>\n
\ucd9c\ub825 :
\nEcho 1 hello world
\nEcho 2 hello world
\nEcho 3 hello world<\/p>\n","protected":false},"excerpt":{"rendered":"
using Microsoft.AspNetCore.Hosting; \/\/IWebHostBuilder using Microsoft.AspNetCore.Builder; \/\/IApplicationBuilder using Microsoft.AspNetCore.Http; \/\/WriteAsync using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Logging; using Microsoft.AspNetCore; using System; using System.Threading; using System.Net.WebSockets; using System.Text; using System.IO; using System.Collections.Concurrent; using System.Linq; using System.Threading.Tasks; using System.Collections.Generic; namespace WebApplication1 { public class ConnectionManager { ConcurrentDictionary<string, WebSocket> _sockets = new ConcurrentDictionary<string, WebSocket>(); public string AddSocket(WebSocket socket) { var id =\u2026 Read More »<\/a><\/span><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[108],"tags":[],"class_list":["post-671","post","type-post","status-publish","format-standard","hentry","category-net-core"],"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/posts\/671","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=671"}],"version-history":[{"count":3,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/posts\/671\/revisions"}],"predecessor-version":[{"id":676,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/posts\/671\/revisions\/676"}],"wp:attachment":[{"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=671"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=671"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=671"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}