Asp.net core中的websocket-低调大师

Asp.net core中的websocket

2017-11-14 658

Websocket是html5后的产物，对于asp.net core中也得到了支持，首先在NuGet中添加Microsoft.AspNetCore.WebSockets的引用（现在是1.0.1版本，2017年3月7日发布的）。

首先在Configure中添加中间件

 
        //添加websocket中间件
       
        app.UseWebSockets();

接下来就要定义自己处理websocket的中间件了，代码如下：

 
        using 
        Microsoft.AspNetCore.Http; 
       
        using 
        System; 
       
        using 
        System.Net.WebSockets; 
       
        using 
        System.Threading; 
       
        using 
        System.Threading.Tasks; 
       
        namespace 
        Asp.NetCore_WebPage.Middleware 
       
        {
       
        /// <summary> 
       
        /// websocket中间件，客户端发送的信息显示在控件台上，客户端会定时收到服务端推送的时间 
       
        /// </summary> 
       
        public 
        class 
        WebSocketNotifyMiddleware 
       
        { 
       
        /// <summary> 
       
        /// 管道代理对象 
       
        /// </summary> 
       
        private 
        readonly 
        RequestDelegate _next; 
       
        /// <summary> 
       
        ///  
       
        /// </summary> 
       
        /// <param name="next"></param> 
       
        public 
        WebSocketNotifyMiddleware(RequestDelegate next) 
       
        { 
       
        _next = next; 
       
        } 
       
        /// <summary> 
       
        /// 中间件调用 
       
        /// </summary> 
       
        /// <param name="context"></param> 
       
        /// <returns></returns> 
       
        public 
        Task Invoke(HttpContext context) 
       
        { 
       
        //判断是否为websocket请求 
       
        if 
        (context.WebSockets.IsWebSocketRequest) 
       
        { 
       
        //接收客户端 
       
        var 
        webSocket = context.WebSockets.AcceptWebSocketAsync().Result; 
       
        //启用一个线程处理接收客户端数据 
       
        new 
        Thread(Accept).Start(webSocket); 
       
        while 
        (webSocket.State == WebSocketState.Open) 
       
        { 
       
        webSocket.SendAsync(
        new 
        ArraySegment<
        byte
        >(System.Text.Encoding.UTF8.GetBytes($
        "{DateTime.Now}"
        )), System.Net.WebSockets.WebSocketMessageType.Text, 
        true
        , CancellationToken.None); 
       
        Thread.Sleep(1000); 
       
        } 
       
        } 
       
        return 
        this
        ._next(context); 
       
        } 
       
        /// <summary> 
       
        /// 接收客户端数据方法，这里可以根据自己的需求切换功能代码 
       
        /// </summary> 
       
        /// <param name="obj"></param> 
       
        void 
        Accept(
        object 
        obj) 
       
        { 
       
        var 
        webSocket = obj 
        as 
        WebSocket; 
       
        while 
        (
        true
        ) 
       
        { 
       
        var 
        acceptArr = 
        new 
        byte
        [1024]; 
       
        var 
        result = webSocket.ReceiveAsync(
        new 
        ArraySegment<
        byte
        >(acceptArr), CancellationToken.None).Result; 
       
        var 
        acceptStr = System.Text.Encoding.UTF8.GetString(acceptArr).Trim(
        char
        .MinValue); 
       
        Console.WriteLine(
        "收到信息：" 
        + acceptStr); 
       
        } 
       
        } 
       
        } 
       
        }

添加中间件扩展

 
        using 
        Microsoft.AspNetCore.Builder; 
       
        using 
        Microsoft.AspNetCore.Http; 
       
        using 
        System; 
       
        using 
        System.Collections.Generic; 
       
        using 
        System.Linq; 
       
        using 
        System.Net.WebSockets; 
       
        using 
        System.Threading; 
       
        using 
        System.Threading.Tasks; 
       
        namespace 
        Asp.NetCore_WebPage.Middleware 
       
        {
       
        /// <summary> 
       
        /// websocket通知中间件扩展 
       
        /// </summary> 
       
        public 
        static 
        class 
        WebSocketNotifyMiddlewareExtensions 
       
        { 
       
        /// <summary> 
       
        /// 使用websocket通知 
       
        /// </summary> 
       
        /// <param name="builder"></param> 
       
        /// <returns></returns> 
       
        public 
        static 
        IApplicationBuilder UseWebSocketNotify( 
       
        this 
        IApplicationBuilder builder) 
       
        { 
       
        return 
        builder.UseMiddleware<WebSocketNotifyMiddleware>(); 
       
        } 
       
        } 
       
        }

这样，就可以在Startup.cs中的Configure中添加自己创建的中间件了，代码如下：

 
        //添加websocket中间件
       
        app.UseWebSockets(); 
       
        app.UseWebSocketNotify();

到此服务端创建完成，接下来看客户端：

 
        <div>
       
        当前在数据：<div id=
        "message"
        ></div> 
       
        <div id=
        "output"
        ></div> 
       
        <input class=
        "form-control" 
        type=
        "text" 
        id=
        "sendtxt" 
        value=
        "测试" 
        /> 
       
        <input type=
        "button" 
        onclick=
        "start()" 
        value=
        "开始" 
        /> 
       
        <input type=
        "button" 
        onclick=
        "send()" 
        value=
        "发送" 
        /> 
       
        </div>
       
        @section scripts{
       
        <script>
       
        var 
        socket; 
       
        var 
        uri = 
        "ws://localhost:5000/ws"
        ; 
       
        //初始化连接
       
        function 
        doConnect(open, accept, close, error) { 
       
        console.log(
        "doConnect"
        ) 
       
        //创建websocket,并定义事件回调
       
        socket = 
        new 
        WebSocket(uri); 
       
        socket.onopen = 
        function 
        (e) { open();}; 
       
        socket.onclose = 
        function 
        (e) { close(); }; 
       
        socket.onmessage = 
        function 
        (e) { 
       
        accept(e.data); 
       
        }; 
       
        socket.onerror = 
        function 
        (e) { error(e.data); }; 
       
        }
       
        //发送信息
       
        function 
        doSend(message) { 
       
        console.log(
        "doSend"
        ) 
       
        socket.send(message); 
       
        }
       
        //关闭socket
       
        function 
        doClose() { 
       
        console.log(
        "doClose"
        ) 
       
        socket.close(); 
       
        }        
       
        //打开连接回调
       
        function 
        open() { 
       
        console.log(
        "open"
        ) 
       
        document.getElementById(
        "message"
        ).innerText = 
        "连接打开"
        ; 
       
        } 
       
        //接收数据回调 
       
        function 
        accept(result) { 
       
        console.log(
        "accept"
        ) 
       
        document.getElementById(
        "output"
        ).innerText=result; 
       
        } 
       
        //关闭连接回调 
       
        function 
        close() { 
       
        console.log(
        "close"
        ) 
       
        document.getElementById(
        "message"
        ).innerText=
        "连接关闭"
        ; 
       
        }
        //错误回调 
       
        function 
        error(result) { 
       
        console.log(
        "error"
        ) 
       
        alert(
        "错误："
        +result); 
       
        } 
       
        //开始方法 
       
        function 
        start() { 
       
        console.log(
        "start"
        ) 
       
        doConnect(open, accept, close, error);          
       
        } 
       
        function 
        send() 
       
        { 
       
        console.log(
        "send"
        ) 
       
        doSend(document.getElementById(
        "sendtxt"
        ).value);  
       
        } 
       
        </script> 
       
        }

这里只是一个基本的例子，可以根据自己的业务来实现不同的功能。

本文转自桂素伟51CTO博客，原文链接：http://blog.51cto.com/axzxs/1909795 ，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/404919

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

浅谈千万级PV/IP规模高性能高并发网站架构

文章架构简图：高并发访问的核心原则其实就一句话“把所有的用户访问请求都尽量往前推”。如果把来访用户比作来犯的"敌人"，我们一定要把他们挡在800里地以外，即不能让他们的请求一下打到我们的指挥部（指挥部就是数据库及分布式存储）。如：能缓存在用户电脑本地的，就不要让他去访问CDN。能缓存CDN服务器上的，就不要让CDN去访问源（静态服务器）了。能访问静态服务器的，就不要去访问动态服务器。以此类推：能不访问数据库和存储就一定不要去访问数据库和存储。说起来很轻松，实际做起来却不容易，但只要稍加努力是可以做到的，Google的日独立IP过亿不也做到了么？我们这几千万的PV站比起Google不是小屋见大屋了。我们还是先从我们的小屋搭起吧！哈哈！下面内容的介绍起点是千万级别的PV站，也可以支持亿级PV的网站架构。高性能高并发高可扩展网站架构访问的几个层次：有人会问，我们老是说把用户对业务的访问往前推，到底怎么推啊？推到哪呢？下面，老男孩就为大家一一道来。第一层：首先在用户浏览器端，使用Apache的mod_deflate压缩传输，再比如：expires功能、deflate和expir...

2017-11-15

484

决定将本博客技术知识从VS.Net转型SuperMap产品动态与开发

一直都要做GIS方面的开发，所以准备将本博客从讲解VS.Net方面的知识转型到专门讲解GIS介绍与开发上。还望各位同仁仍同以往一样大力支持本博客。前些时候在使用ArcGIS产品做开发工作，虽然ArcGIS是一个很不错的产品，帮助我实现了很多GIS功能，但是还是有三点让我放弃了对ArcGIS的研究：1、ArcGIS是国外产品，非国内产品，本人还是希望能支持国内GIS软件事业的蓬勃发展；2、ArcGIS较为昂贵，所以使用的是盗版软件，帮助很差，开发进度很慢；3、因为本人英文不好，所以对于国外关于ArcGIS很好的帮助文章也是一知半解，同样非常影响开发进度。总体看来，我怀着兴奋和惋惜的心情离开了ArcGIS产品，从而转向了国内对GIS产品支持非常好的平台——SuperMap产品。 SuperMap产品其实我早就听说了，只是由于时间、空间、人为和所做的事情的约束，无缘与SuperMap产品相聚。通过接触，本人详细地了解了SuperMap产品，发现了很多优越的地方，提出来让大家共同研究探讨： 1、SuperMap产品系列也很全面 SuperMap产品系列都是由北京超图软件股份有限公司自主...

2017-11-15

468

发表评论

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。