{"id":669,"date":"2019-09-26T15:14:14","date_gmt":"2019-09-26T06:14:14","guid":{"rendered":"http:\/\/csharp.ihavenomoney.co.kr\/?p=669"},"modified":"2019-09-26T15:14:14","modified_gmt":"2019-09-26T06:14:14","slug":"web-sockets-2","status":"publish","type":"post","link":"https:\/\/csharp.ihavenomoney.co.kr\/?p=669","title":{"rendered":"web-sockets-2"},"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\n\r\nnamespace WebApplication1\r\n{\r\n\r\n    public class Startup\r\n    {\r\n        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory logger)\r\n        {\r\n            logger.AddConsole((str, level) =>\r\n            {\r\n                \/\/filter out framework log messages\r\n                return !str.Contains(\"Microsoft.AspNetCore\") && level >= LogLevel.Trace;\r\n            });\r\n\r\n            var log = logger.CreateLogger(\"\");\r\n\r\n            app.UseWebSockets();\r\n\r\n            app.Use(async (context, next) =>\r\n            {\r\n                if (!context.WebSockets.IsWebSocketRequest)\r\n                {\r\n                    \/\/ Not a web socket request\r\n                    await next();\r\n                    return;\r\n                }\r\n\r\n            var socket = await context.WebSockets.AcceptWebSocketAsync();\r\n            var bufferSize = new byte[4];\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                        int count = 0;\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                            receiveBuffer = new ArraySegment<byte>(bufferSize);\r\n                            log.LogDebug($\"Reading incoming data with buffer(size {bufferSize.Length}) {++count} times\");\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 = await reader.ReadToEndAsync();\r\n                        }\r\n\r\n                        log.LogDebug($\"Receive: {clientRequest}\");\r\n\r\n                        var serverReply = Encoding.UTF8.GetBytes(\"Echo \" + clientRequest);\r\n                        var replyBuffer = new ArraySegment<byte>(serverReply);\r\n                        await socket.SendAsync(replyBuffer, WebSocketMessageType.Text, true, CancellationToken.None);\r\n\r\n                        if (result.CloseStatus.HasValue)\r\n                            break;\r\n                    }\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<\/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                                <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\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                                            alert(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
\uacb0\uacfc : ??<\/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; namespace WebApplication1 { public class Startup { public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory logger) { logger.AddConsole((str, level) => { \/\/filter out framework log messages return !str.Contains(“Microsoft.AspNetCore”) && level >=\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-669","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\/669","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=669"}],"version-history":[{"count":1,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/posts\/669\/revisions"}],"predecessor-version":[{"id":670,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/posts\/669\/revisions\/670"}],"wp:attachment":[{"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=669"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=669"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=669"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}