在ASP.NET Core下使用SignalR技术

一、前言

  上次我们讲到过如何在ASP.NET Core中使用WebSocket,没有阅读过的朋友请参考 WebSocket in ASP.NET Core 文章 。这次的主角是SignalR它为我们提供了简化操作WebSocket的框架。

  ASP .NET SignalR 是一个ASP.NET 下的类库,可以在ASP.NET 的Web项目中实现实时通信。什么是实时通信的Web呢?就是让客户端(Web页面)和服务器端可以互相通知消息及调用方法,当然这是实时操作的。WebSockets是HTML5提供的新的API,可以在Web网页与服务器端间建立Socket连接,当WebSockets可用时(即浏览器支持Html5)SignalR使用WebSockets,当不支持时SignalR将使用其它技术来保证达到相同效果。SignalR当然也提供了非常简单易用的高阶API,使服务器端可以单个或批量调用客户端上的JavaScript函数,并且非常 方便地进行连接管理,例如客户端连接到服务器端,或断开连接,客户端分组,以及客户端授权,使用SignalR都非常容易实现。


二、SignalR目前情况

  我们知道在ASP.NET Core 1.0.x 版本中并没有包含SignalR,但是SignalR技术计划集成在ASP.NET Core 1.2版本中,并且它的开发团队还要使用TypeScript对它的javascript客户端进行重写,服务端方面也会贴近ASP.NET Core的开发方式,比如会集成到ASP.NET Core依赖注入框架中。

  目前的情况就是在1.0中无法使用SignalR技术,本文实现的Demo都是在1.1下进行的。


三、集成SignalR

  当然ASP.NET Core 1.2离正式发布还有一段时间,目前想集成SignalR都不是现成的方案,我们要通过手动的方式集成SignalR。

  要在ASP.NET Core中使用SignalR,要先引用Microsoft.AspNetCore.SignalR.Server 、 Microsoft.AspNetCore.WebSockets 的NuGet Package包。

  当然上面也说过目前没有ASP.NET Core没有集成SignalR,所以NUGET上也找不到SignalR的程序包,想添加引用我们就得去MyGet上去找找。

  1.添加NuGet源

  在程序根目录新建一个命为NuGet.Config的文件内容如下:

        
  1. <?xml version="1.0" encoding="utf-8"?>

  2. <configuration>

  3.    <packageSources>

  4.        <clear/>

  5.            <add key="aspnetcidev" value="https://dotnet.myget.org/F/aspnetcore-ci-dev/api/v3/index.json"/>

  6.            <add key="api.nuget.org" value="https://api.nuget.org/v3/index.json"/>

  7.    </packageSources>

  8. </configuration>

 

  当然我们也可以通过在Visual Studio中设置 NuGet Packages的源,来引用这个程序集。

  2.在project.json添加引用

        
  1. "Microsoft.AspNetCore.SignalR.Server": "0.2.0-*",

  2. "Microsoft.AspNetCore.WebSockets": "1.0.0-*"

  可以注意到SignalR的版本是0.2.0的alpha版本,所以后续版本可能变化也会比较大! 听说是好重写的。

  值得注意的是,SignalR目前只能在ASP.NET Core 1.1以上版本上使用,在这个文章中我使用的.NET Core SDK版本为 1.0.0-preview2-003131 所以引用有问题的同学可以尝试把CoreApp版本改为1.1,所有AspNetCore的程序集也都改变为1.1的版本

  3.添加配置代码

  我们需要在Startup类中的 ConfigureServices方法中添加如下代码:

        
  1. public void ConfigureServices(IServiceCollection services)

  2. {

  3.     services.AddSignalR(options =>

  4.     {

  5.         options.Hubs.EnableDetailedErrors = true;

  6.      });

  7. }

  在Startup类中的Configure方法中添加如下代码:

        
  1. app.UseWebSockets();

  2. app.UseSignalR();

  4.添加一个HUB类

  这里我们只实现一个小Demo,一个简单的聊天室,多个人进入可以看到各自发送的信息:

        
  1. public class ChatHub : Hub

  2. {

  3.        public static List<string> ConnectedUsers;

  4.        public void Send(string originatorUser, string message)

  5.        {

  6.            Clients.All.messageReceived(originatorUser, message);

  7.        }

  8.        public void Connect(string newUser)

  9.        {

  10.            if (ConnectedUsers == null)

  11.                ConnectedUsers = new List<string>();

  12.            ConnectedUsers.Add(newUser);

  13.            Clients.Caller.getConnectedUsers(ConnectedUsers);

  14.            Clients.Others.newUserAdded(newUser);

  15.        }

  16. }

  5.客户端支持

  在wwwroot目录下创建一个名为chat.html的Html静态文件,内容如下:

        
  1. <!DOCTYPE html>

  2. <html>

  3. <head>

  4.    <title>Awesome Chat Application</title>

  5.    <meta charset="utf-8" />

  6. </head>

  7. <body>

  8.    <style type="text/css">

  9.        .userListDiv{ float: right; }

  10.    </style>

  11.    <ul id="messages"></ul>

  12.    <input type="text" id="messageBox" />

  13.    <input type="button" id="sendMessage" value="Send Message!" />

  14.    <div class="userListDiv">

  15.        <ul id="userList"> </ul>

  16.    </div>

  17.  

  18.    <script src="http://ajax.aspnetcdn.com/ajax/jQuery/jquery-3.1.0.min.js"></script>

  19.    <script src="http://ajax.aspnetcdn.com/ajax/signalr/jquery.signalr-2.2.1.min.js"></script>

  20.    <script src="signalr/hubs"></script>

  21.    <script src="chat.js"></script>

  22. </body>

  23. </html>

  同目录下建立一个chat.js添加要实现功能的脚本:

        
  1. var userName = prompt("Enter your name: ");

  2. var chat = $.connection.chatHub;

  3. chat.client.messageReceived = function (originatorUser, message) {

  4.    $("#messages").append('<li><strong>' + originatorUser + '</strong>: ' + message);

  5. };

  6. chat.client.getConnectedUsers = function (userList) {

  7.    for (var i = 0; i < userList.length; i++)

  8.        addUser(userList[i]);

  9. };

  10. chat.client.newUserAdded = function (newUser) {

  11.    addUser(newUser);

  12. }

  13. $("#messageBox").focus();

  14. $("#sendMessage").click(function () {

  15.    chat.server.send(userName, $("#messageBox").val());

  16.    $("#messageBox").val("");

  17.    $("#messageBox").focus();

  18. });

  19. $("#messageBox").keyup(function (event) {

  20.    if (event.keyCode == 13)

  21.        $("#sendMessage").click();

  22. });

  23. function addUser(user){

  24.    $("#userList").append('<li>' + user + '</li>');

  25. }

  26. $.connection.hub.logging = true;

  27. $.connection.hub.start().done(function () {

  28.    chat.server.connect(userName);

  29. });

  最后我们来运行它吧:

 

四、最后

  附上一个可用的Demo:https://github.com/maxzhang1985/AspNetCore.SignalRDemo 

  GitHub:https://github.com/maxzhang1985/YOYOFx  如果觉还可以请Star下, 欢迎一起交流。 

  .NET Core 开源学习群: 214741894  

相关文章: 

  • 基于.NET SingalR,LayIM2.0实现的web聊天室

  • Signalr系列之虚拟目录详解与应用中的CDN加速实战

  • ASP.NET SignalR 2.0入门指南

  • SignalR SelfHost实时消息,集成到web中,实现服务器消息推送

  • ASP.NET SignalR 高可用设计

  • WebSocket in ASP.NET Core

  • SignalR的性能监测与服务器的负载测试

原文地址:http://www.cnblogs.com/maxzhang1985/p/6364588.html


.NET社区新闻,深度好文,微信中搜索dotNET跨平台或扫描二维码关注

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/327003.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ClassLoader 详解及用途

转载自 ClassLoader 详解及用途 ClassLoader主要对类的请求提供服务&#xff0c;当JVM需要某类时&#xff0c;它根据名称向ClassLoader要求这个类&#xff0c;然后由ClassLoader返回这个类的class对象。 1.1 几个相关概念ClassLoader负责载入系统的所有Resources&#xff08;…

mybatis简单案例源码详细【注释全面】——前期准备

mybatis 是个什么东西&#xff0c;这里就不必说了&#xff0c;大家去网上搜搜看就行了&#xff0c;在这里我主要是分享一下最基本的增删改查案例以及配置信息&#xff0c;测试信息。 首先我们创建个数据库&#xff1a; /* SQLyog 企业版 - MySQL GUI v8.14 MySQL - 5.5.40 : …

用数组模拟队列的实现

package com.atguigu.queue;import jdk.nashorn.internal.ir.ReturnNode;import java.util.Scanner;/*** 创建人 wdl* 创建时间 2021/3/17* 描述*/ public class ArrayQueueDemo {public static void main(String[] args) {//测试一把//创建一个队列ArrayQueue queue new Arra…

时间格式转换2020-04-09T23:00:00.000+08:00

时间格式转换2020-04-09T23:00:00.00008:00 /*** 日期格式转换yyyy-MM-ddTHH:mm:ss.SSSXXX (yyyy-MM-ddTHH:mm:ss.SSSZ) TO yyyy-MM-dd HH:mm:ss* 2020-04-09T23:00:00.00008:00 TO 2020-04-09 23:00:00* throws ParseException*/public static String dealDateFormat(String…

云计算设计模式(三)——补偿交易模式

撤消由一系列步骤&#xff0c;它们共同限定了最终一致性操作中&#xff0c;如果一个或多个步骤失败执行的工作。按照最终一致性模型&#xff0c;业务实现复杂的业务流程和工作流的云托管的应用程序中很常见。 背景和问题 在云中运行的应用程序频繁修改数据。此数据可跨在各种地…

java反射 修改静态方法的值 setAccessible

转载自 java反射 修改静态方法的值 setAccessible 这几天闲来无事。在网上看了一个题目&#xff0c;相信大家都知道这个题目 static void change(String str){str"welcome";}public static void main(String[] args) {String str "123";change(str);Syste…

mybatis简单案例源码详细【注释全面】——实体层(User.java)

/** * Title: Users.java * Package org.entity * Description: TODO该方法的主要作用&#xff1a; * author A18ccms A18ccms_gmail_com * date 2017-10-5 下午6:53:06 * version V1.0 */ package org.entity;import java.util.Date;/** * * 项目名称&#xff1a;s…

API网关Ocelot 使用Polly 处理部分失败问题

在实现API Gateway过程中&#xff0c;另外一个需要考虑的问题就是部分失败。这个问题发生在分布式系统中当一个服务调用另外一个服务超时或者不可用的情况。API Gateway不应该被阻断并处于无限期等待下游服务的状态。但是&#xff0c;如何处理这种失败依赖于特定的场景和具体服…

数组模拟环形队列

思路分析 代码实现 package com.atguigu.queue;import java.util.Calendar; import java.util.Scanner;/*** 创建人 wdl* 创建时间 2021/3/17* 描述*/ public class CircleArrayQueueDemo {public static void main(String[] args) {//测试一把System.out.println("测试数…

Error:(1, 10) java: 需要class, interface或enum

https://blog.csdn.net/zf18234031156/article/details/103047649 反复做这一步&#xff0c;30多个文件一个一个弄&#xff0c;有乱码用txt打开&#xff0c;黏贴覆盖&#xff0c; 目录 1.前言 2.原因(UTF-8BOM造成) 3.如何解决 3.11使用Notepad&#xff0c;选择“格式--以…

彻底理解ThreadLocal

转载自 彻底理解ThreadLocal 先总述&#xff0c;后分析 深挖过threadLocal之后&#xff0c;一句话概括&#xff1a;Synchronized用于线程间的数据共享&#xff0c;而ThreadLocal则用于线程间的数据隔离。所以ThreadLocal的应用场合&#xff0c;最适合的是按线程多实例&#xff…

mybatis简单案例源码详细【注释全面】——实体层(Role.java)

package org.entity;import java.util.Date; /*** * * 项目名称&#xff1a;ssm_chop2 * 类名称&#xff1a;Role * 类描述&#xff1a; 角色表的实体类 * 创建人&#xff1a;Mu Xiongxiong * 创建时间&#xff1a;2017-10-7 上午10:01:31 * 修改人&#xff…

IDEA导入Eclipse项目

https://blog.csdn.net/zeal9s/article/details/90690524 背景&#xff1a;用习惯了idea再去用eclipse实在用的不习惯&#xff0c;于是将老的eclipse项目导入到eclipse&#xff0c;网上有很多教程&#xff0c;看了很多博客都不行&#xff0c;一直报错&#xff0c;各种报错&…

云计算设计模式(四)——消费者的竞争模式

允许多个并发用户处理在同一个通讯通道接收的消息。这种模式使系统能够同时处理多个邮件&#xff0c;以优化吞吐量&#xff0c;提高可扩展性和可用性&#xff0c;以及平衡工作负载。 背景和问题 在云中运行的应用程序&#xff0c;可以预计&#xff0c;以处理大量的请求。而不是…

带头单链表有序版

package com.atguigu.linkedlist;/*** 创建人 wdl* 创建时间 2021/3/17* 描述*/ public class SingleLinkedListDemo {public static void main(String[] args) {//进行测试//先创建节点HeroNode hearo1 new HeroNode(1, "宋江", "及时雨");HeroNode hear…

mybatis简单案例源码详细【注释全面】——Dao层接口(UserMapper.java)

/** * Title: IUserDao.java * Package org.dao * Description: TODO该方法的主要作用&#xff1a; * author A18ccms A18ccms_gmail_com * date 2017-10-5 下午8:59:34 * version V1.0 */ package org.dao;import java.util.Date; import java.util.List; import java.u…

java笔记--关于线程同步(7种同步方式)

转载自 java笔记--关于线程同步&#xff08;7种同步方式&#xff09; 为何要使用同步&#xff1f; java允许多线程并发控制&#xff0c;当多个线程同时操作一个可共享的资源变量时&#xff08;如数据的增删改查&#xff09;&#xff0c; 将会导致数据不准确&#xf…

前后端分离趋势谈

最近已经不止一个人和我提起过vue了&#xff0c;在我的前端印象中&#xff0c;我还停留在smarty渲染模版&#xff0c;jquery做js处理。学了一晚上&#xff0c;对现在这种工程化webpack打包生成html&#xff0c;js&#xff0c;css的生产方式越来越有兴趣了。工作年限摆在这里的好…

mybatis简单案例源码详细【注释全面】——Dao层映射文件(UserMapper.xml)【重要】

<?xml version"1.0" encoding"UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace"org.dao.UserMapper"><…