{"id":666,"date":"2019-09-26T15:01:38","date_gmt":"2019-09-26T06:01:38","guid":{"rendered":"http:\/\/csharp.ihavenomoney.co.kr\/?p=666"},"modified":"2019-09-26T15:01:57","modified_gmt":"2019-09-26T06:01:57","slug":"666","status":"publish","type":"post","link":"https:\/\/csharp.ihavenomoney.co.kr\/?p=666","title":{"rendered":"web-sockets"},"content":{"rendered":"\n
using Microsoft.AspNetCore.Hosting; \/\/IWebHostBuilder\r\nusing Microsoft.AspNetCore.Builder; \/\/IApplicationBuilder\r\nusing Microsoft.AspNetCore.Http; \/\/WriteAsync\r\n\/\/using 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\n\r\nnamespace WebApplication1\r\n{\r\n\r\n    public class Startup\r\n    {\r\n\r\n        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory logger)\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[1024 * 4];\r\n                var receiveBuffer = new ArraySegment<byte>(bufferSize);\r\n                var result = await socket.ReceiveAsync(receiveBuffer, CancellationToken.None);\r\n\r\n                while (!result.CloseStatus.HasValue)\r\n                {\r\n                    if (result.MessageType == WebSocketMessageType.Text)\r\n                    {\r\n                        var clientRequest = Encoding.UTF8.GetString(receiveBuffer.Array, receiveBuffer.Offset, receiveBuffer.Count);\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                        receiveBuffer = new ArraySegment<byte>(bufferSize);\r\n                        result = await socket.ReceiveAsync(receiveBuffer, CancellationToken.None);\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 :
\nEcho 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; namespace WebApplication1 { public class Startup { public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory logger) { app.UseWebSockets(); app.Use(async (context, next) => { if (!context.WebSockets.IsWebSocketRequest) { \/\/ Not a web socket request await\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-666","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\/666","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=666"}],"version-history":[{"count":2,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/posts\/666\/revisions"}],"predecessor-version":[{"id":668,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=\/wp\/v2\/posts\/666\/revisions\/668"}],"wp:attachment":[{"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=666"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=666"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/csharp.ihavenomoney.co.kr\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=666"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}