我的编程空间,编程开发者的网络收藏夹
学习永远不晚

Asp.net如何通过SignalR2进行实时聊天

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

Asp.net如何通过SignalR2进行实时聊天

本篇内容主要讲解“Asp.net如何通过SignalR2进行实时聊天”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Asp.net如何通过SignalR2进行实时聊天”吧!

    一:什么是signalR

    Asp.net SignalR是微软为实现实时通信的一个类库。

    一般情况下,signalR会使用JavaScript的长轮询(long polling)的方式来实现客户端和服务器通信,随着Html5中WebSockets出现,SignalR也支持WebSockets通信。

    另外SignalR开发的程序不仅仅限制于宿主在IIS中,也可以宿主在任何应用程序,包括控制台,客户端程序和Windows服务等,另外还支持Mono,这意味着它可以实现跨平台部署在Linux环境下。

    SignalR将整个信息的交换封装起来,客户端和服务器都是使用JSON来沟通的,在服务端声明的所有Hub信息,都会生成JavaScript输出到客户端,.NET则依赖Proxy来生成代理对象,而Proxy的内部则是将JSON转换成对象。

    客户端和服务端的具体交互情况如下图所示:

    Asp.net如何通过SignalR2进行实时聊天

    1、SignalR传输方式

    1、HTML5 传输

    这种传输方式当然是需要对HTML5兼容支持。如果客户端不支持HTML5 标准,那么你可以使用其他方式。

    • WebSocket: (前提是服务器和客户端都可以支持WebSocket )。WebSocket 是唯一的能够支持服务器和客户端建立真正持久的双向连接的传输方式,但是就是WebSocket要求的条件比较苛刻。 
      WebSocket真正能够支持只是在最新的IE 浏览器、Chrome、Firefox和一些其他的浏览器比如Opera 和 Safari。 

    • Server Sent Events (SSE)服务端发送事件 :就是我们常说的EventSource (除了IE的其他浏览器都支持支持服务器发送事件)。

    2、Comet 传输

    下面的传输方式都是建立在Comet Web应用模型上。这种传输方式会在浏览器或者其他客户端保持一个长连接的HTTP请求,服务器可以利用这个请求将数据推送到客户端,而不用等客户端单独去请求数据。

    • Forever Frame:(只有IE浏览器支持)Forever Frame 会创建一个隐藏的IFrame ,这个IFrame 会向服务器发起一个端点请求,但是这个请求不会结束。服务器会不停的发送脚本到客户端马上执行,提供一个从服务器端到客户端的单向实时连接。服务端到客户端和客户端到服务端分别是两个不同的连接,就像一个标准的HTTP请求,一旦有数据需要发送就会创建一个新的连接。

    • Ajax Long Polling长轮询:长轮询不会创建一个持久的连接,它是会保持一个客户端与服务器的连接,直到服务器做出应答就会立即关闭,然后创建一个新的连接。当连接重置的时候这会导致一些延迟。

    2、SignalR连接模式

    • Http Persisten Connection(持久连接)对象:用来解决长时间连接的功能。 
      还可以由客户端主动向服务器要求数据,而服务器端不需要实现太多细节,只需要处理PersistentConnection 内所提供的五个事件:OnConnected, OnReconnected, OnReceived, OnError 和 OnDisconnect 即可。

    • Hub(集线器)对象:用来解决实时(realtime)信息交换的功能,服务端可以利用URL来注册一个或多个Hub,只要连接到这个Hub,就能与所有的客户端共享发送到服务器上的信息,同时服务端可以调用客户端的脚本。 
      SignalR将整个信息的交换封装起来,客户端和服务器都是使用JSON来沟通的,在服务端声明的所有Hub信息,都会生成JavaScript输出到客户端,.NET则依赖Proxy来生成代理对象,而Proxy的内部则是将JSON转换成对象。

    下面的图展示了Hub和持久连接的关系,让你对底层的传输技术一目了然。

    Asp.net如何通过SignalR2进行实时聊天

    二、服务端

    原文参考:教程:通过 SignalR 2 进行实时聊天

    使用vs2012创建一个新的ASP.NET Web Application项目。

    Asp.net如何通过SignalR2进行实时聊天

    1、添加服务端Hub

    解决方案中添加SignalR Hub类选项,然后创建文件ChatHub.cs。此步骤将创建ChatHub.cs类文件并添加一组脚本文件和 SignalR 支持到项目的程序集引用。

    注意:可以使用NuGet命令 install-package Microsoft.AspNet.SignalR 来引用SignalR到项目中

    Asp.net如何通过SignalR2进行实时聊天

    然后在ChatHub类中输入下面这段代码。

    using Microsoft.AspNet.SignalR;namespace WebApplication2{    public class ChatHub : Hub    {        //定义可以被网页脚本访问的公共方法        public void Send(string name, string message) //在客户端可以使用hub.server.send()方法调用。        {            // 客户端通过调用broadcastMessage来获取服务端数据            Clients.All.broadcastMessage(name, message);//在客户端通过hub.client.broadcastMessage=function(){…}定义这个回调函数。        }    }}

    ChatHub类中,可以看到它继承自Microsoft.AspNet.SignalR.Hub类。从Hub类派生出类是构建SignalR应用程序的有用方式。在这个类(ChatHub)中定义的公共方法可以被网页内的脚本访问。

    在这段代码中(ChatHub类),客户端通过调用ChatHub.Send方法,并把名称和消息内容做为参数传递给ChatHub。而ChatHub则通过Clients.All.broadcastMessage方法把该消息广播给所有客户端。

    Send方法演示了几个Hub概念:

    • 在hub上声明一些公共方法,以便客户端可以调用它们。

    • 使用Microsoft.AspNet.SignalR.Hub。客户端动态属性用于与连接到此中心的所有客户端进行通信。

    • 调用客户机上的函数(如broadcastMessage函数)来更新客户机。

    2、添加OWIN 启动类

    Solution Explorer中,右击项目,然后添加一个名为StartupOWIN 启动类,然后输入下面这段代码。

    using Microsoft.Owin;using Owin;[assembly: OwinStartup(typeof(WebApplication2.Startup))]namespace WebApplication2{    public class Startup    {        public void Configuration(IAppBuilder app)        {            app.MapSignalR();        }    }}

    三、客户端

    在项目中添加一个静态网页文件,并命名为index.html,然后右击该网页文件,并选择Set As Start Page,在Index.html中输入下面的代码,注意引用正确的文件名。

    <!DOCTYPE html><html><head>    <title>SignalR Simple Chat</title>    <style type="text/css">        .container {            background-color: #99CCFF;            border: thick solid #808080;            padding: 20px;            margin: 20px;        }    </style></head><body>    <div class="container">        <input type="text" id="message" />        <input type="button" id="sendmessage" value="Send" />        <input type="hidden" id="displayname" />        <ul id="discussion"></ul>    </div>    Reference the jQuery library.     <script class="lazy" data-src="Scripts/jquery-1.12.4.js"></script>    Reference the SignalR library.     <script class="lazy" data-src="Scripts/jquery.signalR-2.4.1.js"></script>    Reference the autogenerated SignalR hub script.     <script class="lazy" data-src="signalr/hubs"></script>    Add script to update the page and send messages.    <script type="text/javascript">        $(function () {            // 1、声明一个代理,用于引用服务端hub            var chat = $.connection.chatHub;            // 2、创建一个回调函数,让Hub调用它来广播消息。            chat.client.broadcastMessage = function (name, message) {                // Html编码形式显示名称和消息                var encodedName = $('').text(name).html();                var encodedMsg = $('').text(message).html();;                // 将消息添加到页面。                $('#discussion').append('' + encodedName                    + ':  ' + encodedMsg + '');            };            // 获取用户名            $('#displayname').val(prompt('Enter your name:', ''));            // 将初始焦点设置为消息输入框。            $('#message').focus();            // 3、开始连接和发送消息            $.connection.hub.start().done(function () {                $('#sendmessage').click(function () {                    // 在Hub上调用Send方法.                    chat.server.send($('#displayname').val(), $('#message').val());                    // 清除文本框并为下一个注释重置焦点。                    $('#message').val('').focus();                });            });        });    </script></body></html>

    客户端通过jquery.signalR.jssignalr/hubs来与服务器进行通信,首先它要声明一个代理来引用集线器。

    var chat = $.connection.chatHub

    请注意:在JavaScript中,对服务器类及其成员的引用必须是camelCase形式。本例中将C#服务端的ChatHub类在JavaScript中的引用为chatHub。

    然后它要再定义一个回调函数,这个回调函数主要是为了让服务器进行调用,从而将数据推送到客户端。

    chat.client.broadcastMessage = function (name, message) {    //TODO:接收服务器推送的消息};

    而下面的代码则是为了确保在将消息发送到服务器之前已经与服务器建立了连接。.done 函数表示连接成功后为发送的按钮绑定一个单击事件。

    // 与服务器建立连接后才能发送消息到服务器$.connection.hub.start().done(function () {    $('#sendmessage').click(function () {        // 调用服务器端的ChatHub.Send方法,把消息发送到服务器        chat.server.send("name", "message");    });});

    保存项目,并按F5运行,就可以实现B/S模式下的即时通讯。

    四、运行结果

    项目运行起来后,同时用多个浏览器打开的,输入各自的姓名之后,就能够实现即时通讯了。回到我们的vs,还能够看到自动生成的hubs脚本文件,如下图所示。

    Asp.net如何通过SignalR2进行实时聊天

    Asp.net如何通过SignalR2进行实时聊天

    三个不同的浏览器中的运行方式。 当 Tom、 Anand 和 Susan 发送消息时,所有浏览器实时更新:

    Asp.net如何通过SignalR2进行实时聊天

    在ServerHub重写一个 OnConnected 方法来监控客户端的连接情况,程序运行的时候web页面就使用$.connection.hub.start() 与signalR服务开始建立连接了,在调试的时候可以在输入中看到 "客户端连接成功!"

    public override Task OnConnected(){    System.Diagnostics.Trace.WriteLine("客户端连接成功!");    return base.OnConnected();}

    Asp.net如何通过SignalR2进行实时聊天

    五、一对一聊天实例

    Clients.Client(connectionId).addMessage() 此方法的作用就是客户端注册addMessage方法,向指定连接Id的客户端发送消息。一对一的聊天发送的消息也必须回发给自己,所以连接的Id可以通过Context.ConnectionId来获取。当然不用Client.Client(Context.ConnectionId) ,也可以使用Client.Caller()方法直接发送。

    Client.Clients(IList connectionIds) 这个方法的意思就是想一组string 的几个ConnectionId发送消息。类似于QQ上@好友的那种功能。 

    using Microsoft.AspNet.SignalR;using Microsoft.AspNet.SignalR.Hubs;using Newtonsoft.Json;using System;using System.Collections.Generic;using System.ComponentModel.DataAnnotations;using System.Linq;using System.Threading.Tasks;namespace WebApplication2{    [HubName("UserHub")]    public class UserHub : Hub    {        #region 字段        public static List users = new List();        #endregion 字段        #region 方法        //获取所有用户在线列表        private void GetUsers()        {            var list = users.Select(s => new { s.Name, s.ConnectionID }).ToList();            string jsonList = JsonConvert.SerializeObject(list);            Clients.All.getUsers(jsonList);        }        //登记名字        public void LoginIn(string name)        {            //查询用户            var user = users.SingleOrDefault(u => u.ConnectionID == Context.ConnectionId);            if (user != null)            {                user.Name = name;//登记名字                Clients.Client(Context.ConnectionId).showId(Context.ConnectionId);            }            GetUsers();        }        //发送消息        [HubMethodName("sendMessage")]        public void SendMessage(string connectionId, string message)        {            Clients.All.hello();            var user = users.Where(s => s.ConnectionID == connectionId).FirstOrDefault();            if (user != null)            {                Clients.Client(connectionId).addMessage(message + "" + DateTime.Now, Context.ConnectionId);                //给自己发送,把用户的ID传给自己                Clients.Client(Context.ConnectionId).addMessage(message + "" + DateTime.Now, connectionId);            }            else            {                Clients.Client(Context.ConnectionId).showMessage("该用户已离线");            }        }        ///         /// 重写连接事件        ///         ///         public override Task OnConnected()        {            //查询用户            var user = users.Where(w => w.ConnectionID == Context.ConnectionId).SingleOrDefault();            //判断用户是否存在,否则添加集合            if (user == null)            {                user = new User("", Context.ConnectionId);                users.Add(user);            }            return base.OnConnected();        }        public override Task OnDisconnected(bool stopCalled)        {            var user = users.Where(p => p.ConnectionID == Context.ConnectionId).FirstOrDefault();            //判断用户是否存在,存在则删除            if (user != null)            {                //删除用户                users.Remove(user);            }            GetUsers();//获取所有用户的列表            return base.OnDisconnected(stopCalled);        }        #endregion 方法    }    public class User    {        #region 构造函数        public User(string name, string connectionId)        {            this.Name = name;            this.ConnectionID = connectionId;        }        #endregion 构造函数        #region 属性        [Key]        public string ConnectionID { get; set; }        public string Name { get; set; }        #endregion 属性    }}

    到此,相信大家对“Asp.net如何通过SignalR2进行实时聊天”有了更深的了解,不妨来实际操作一番吧!这里是编程网网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

    免责声明:

    ① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

    ② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

    Asp.net如何通过SignalR2进行实时聊天

    下载Word文档到电脑,方便收藏和打印~

    下载Word文档

    猜你喜欢

    Asp.net如何通过SignalR2进行实时聊天

    本篇内容主要讲解“Asp.net如何通过SignalR2进行实时聊天”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Asp.net如何通过SignalR2进行实时聊天”吧!一:什么是signalR
    2023-06-30

    go语言如何实现即时通讯聊天室

    本文小编为大家详细介绍“go语言如何实现即时通讯聊天室”,内容详细,步骤清晰,细节处理妥当,希望这篇“go语言如何实现即时通讯聊天室”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。实现的功能:公聊,私聊,修改用户名
    2023-06-30

    如何通过实现ThreadFactory来对线程进行命名

    这篇文章主要介绍如何通过实现ThreadFactory来对线程进行命名,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!本文记录@Async的基本使用以及通过实现ThreadFactory来实现对线程的命名。@Async
    2023-06-15

    Python如何通过ARIMA模型进行时间序列分析预测

    本文介绍了如何在Python中使用ARIMA模型进行时间序列分析预测。它提供了逐步指南,包括导入库、加载数据、确定模型参数、拟合模型、预测和评估预测。此外,还讨论了高级功能,如季节性ARIMA模型、外生变量和状态空间模型。
    Python如何通过ARIMA模型进行时间序列分析预测
    2024-04-02

    如何通过宝塔面板进行虚拟机实例的管理

    要使用宝塔面板进行虚拟机实例的管理,需要按照以下步骤进行操作:1. 登录宝塔面板:在浏览器中输入服务器的IP地址或域名,然后输入用户名和密码进行登录。2. 添加虚拟机实例:在宝塔面板中,点击左侧导航栏的“虚拟机”选项,然后点击右上方的“添加
    2023-10-10

    如何通过iLO进行Zabbix监控实现针对HP服务器集成

    这篇文章将为大家详细讲解有关如何通过iLO进行Zabbix监控实现针对HP服务器集成,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。 iLO 全名是 Integrated Lights-out,它
    2023-06-04

    Nginx与Docker Kubernetes的集成部署实践(Nginx如何通过Kubernetes在Docker中进行部署?)

    将Nginx与DockerKubernetes集成可实现Web服务器的高效部署和管理。使用Docker容器化Nginx并使用Kubernetes编排。部署流程涉及配置Nginx、构建镜像、推送到Docker仓库和应用Kubernetes配置。集成的好处包括自动化部署、可扩展性、安全性、CI/CD和可移植性。最佳实践包括使用适当的镜像、优化配置、使用YAML文件、监控和定期更新。
    Nginx与Docker Kubernetes的集成部署实践(Nginx如何通过Kubernetes在Docker中进行部署?)
    2024-04-02

    Python中如何对MySQL数据库进行备份和恢复操作?(通过Python如何实现MySQL数据库的备份与恢复?)

    本文介绍了如何使用PythonMySQLdb库对MySQL数据库进行备份和恢复。备份涉及导出数据库到文件,而恢复涉及从文件导入数据库。自动化过程可以使用调度器(如cron)来安排定期备份和恢复。本文提供了详细的步骤和代码示例,使读者能够轻松地实施这些操作,确保数据的安全性和完整性。
    Python中如何对MySQL数据库进行备份和恢复操作?(通过Python如何实现MySQL数据库的备份与恢复?)
    2024-04-02

    钉钉宜搭低代码教程如何定位省份 简介本文将详细解释如何使用钉钉宜搭进行低代码开发,通过定位省份来实现特定功能。

    在低代码开发中,我们经常需要处理地理位置信息,比如获取用户所在的城市或省份。钉钉宜搭提供了强大的地理信息处理能力,通过定位省份,我们可以轻松实现各种功能。下面,我们将详细解释如何在钉钉宜搭中定位省份。一、创建项目首先,我们需要在钉钉宜搭中创建一个新的项目。打开宜搭后,点击左上角的“+”号,选择“新建项目”,然后填写项目
    钉钉宜搭低代码教程如何定位省份 简介本文将详细解释如何使用钉钉宜搭进行低代码开发,通过定位省份来实现特定功能。
    2023-11-22

    编程热搜

    • Python 学习之路 - Python
      一、安装Python34Windows在Python官网(https://www.python.org/downloads/)下载安装包并安装。Python的默认安装路径是:C:\Python34配置环境变量:【右键计算机】--》【属性】-
      Python 学习之路 - Python
    • chatgpt的中文全称是什么
      chatgpt的中文全称是生成型预训练变换模型。ChatGPT是什么ChatGPT是美国人工智能研究实验室OpenAI开发的一种全新聊天机器人模型,它能够通过学习和理解人类的语言来进行对话,还能根据聊天的上下文进行互动,并协助人类完成一系列
      chatgpt的中文全称是什么
    • C/C++中extern函数使用详解
    • C/C++可变参数的使用
      可变参数的使用方法远远不止以下几种,不过在C,C++中使用可变参数时要小心,在使用printf()等函数时传入的参数个数一定不能比前面的格式化字符串中的’%’符号个数少,否则会产生访问越界,运气不好的话还会导致程序崩溃
      C/C++可变参数的使用
    • css样式文件该放在哪里
    • php中数组下标必须是连续的吗
    • Python 3 教程
      Python 3 教程 Python 的 3.0 版本,常被称为 Python 3000,或简称 Py3k。相对于 Python 的早期版本,这是一个较大的升级。为了不带入过多的累赘,Python 3.0 在设计的时候没有考虑向下兼容。 Python
      Python 3 教程
    • Python pip包管理
      一、前言    在Python中, 安装第三方模块是通过 setuptools 这个工具完成的。 Python有两个封装了 setuptools的包管理工具: easy_install  和  pip , 目前官方推荐使用 pip。    
      Python pip包管理
    • ubuntu如何重新编译内核
    • 改善Java代码之慎用java动态编译

    目录