C# BS消息推送 SignalR Hubs环境搭建与开发（二）

时间：2022-09-26 10:21:53

1. 前言

本文是根据网上前人的总结得出的。

环境： SignalR2.x，VS2015，Win10

2. 开始开发

1）新建一个MVC项目，叫做SignalRDemo

C# BS消息推送 SignalR Hubs环境搭建与开发（二）

2）安装SignalR包

Install-Package Microsoft.AspNet.SignalR

Install-Package Microsoft.AspNet.SignalR.Client

安装完包后会有相应的引用和js文件

C# BS消息推送 SignalR Hubs环境搭建与开发（二）

C# BS消息推送 SignalR Hubs环境搭建与开发（二）

3）新建startup文件，用来启动SignalR

C# BS消息推送 SignalR Hubs环境搭建与开发（二）

代码如下：

using System;

using System.Threading.Tasks;

using Microsoft.Owin;

using Owin;

[assembly: OwinStartup(typeof(SignalRDemo.SignalR.StartupSignalR))]

namespace SignalRDemo.SignalR

{

    public class StartupSignalR

    {

        public void Configuration(IAppBuilder app)

        {

            // 有关如何配置应用程序的详细信息，请访问 http://go.microsoft.com/fwlink/?LinkID=316888

            app.MapSignalR();//启动SignalR

        }

    }

}

4）新建Hub类，MyHub。此类的作用是用来与客户端的连接。

可以看到[HubName("myHub")]的注解，是用来与前端JS做绑定

using System;

using System.Collections.Generic;

using System.Linq;

using System.Threading.Tasks;

using System.Web;

using Microsoft.AspNet.SignalR;

using Microsoft.AspNet.SignalR.Hubs;

namespace SignalRDemo.SignalR

{

    [HubName("myHub")]

    public class MyHub : Hub

    {

        //当连接hub实例时被调用

        public override Task OnConnected()

        {

            string connId = Context.ConnectionId;

            return base.OnConnected();

        }

        //当失去连接或链接超时时被调用

        public override Task OnDisconnected(bool stopCalled)

        {

            //stopCalled=true时，客户端关闭连接

            //stopCalled=false时，出现链接超时

            return base.OnDisconnected(stopCalled);

        }

        //重新连接时被调用

        public override Task OnReconnected()

        {

            return base.OnReconnected();

        }

    }

}

上面已经新建了与前端连接类。下面我们开始不同的调用方式

至此，我们创建环境已经结束。

3. 不同调用方式

1）前端调用后端

前端html：

myHub是HubName注解属性。2个js一定要引用：Jquery、SignalR。scripts中有src='/SignalR/hubs'，其中SignalR是我们服务器端的文件夹，hubs是不存在的文件夹。

<!DOCTYPE html>

<html>

<head>

<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>

    <title></title>

    <meta charset="utf-8"/>

    <script src="/scripts/jquery-1.10.2.min.js"></script>

    <!--Reference the SignalR library. -->

    <script src="/scripts/jquery.signalR-2.2.1.js"></script>

    <!--Reference the autogenerated SignalR hub script. -->

    <script src='/SignalR/hubs'></script>

    <!--Add script to update the page and send messages.-->

    <script type='text/javascript'>

        $(function () {

            //引用自动生成的代理，myHub是HubName注解属性

            var myHub = $.connection.myHub;

            //开始连接

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

                //客户端发送信息到服务器

                myHub.server.Send($.connection.hub.id);

            });

        });

    </script>

</head>

<body>

</body>

</html>

后端MyHub类中，添加方法：

       //客户端发送信息到服务器

        public void Send(string message)

       {

       }

访问html，就能直接调用Send方法了。

至此，前端调用后端，结束。

2）后端主动调用前端

前端代码，增加了后端调用前端JS

<!DOCTYPE html>

<html>

<head>

<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>

    <title></title>

    <meta charset="utf-8"/>

    <script src="/scripts/jquery-1.10.2.min.js"></script>

    <!--Reference the SignalR library. -->

    <script src="/scripts/jquery.signalR-2.2.1.js"></script>

    <!--Reference the autogenerated SignalR hub script. -->

    <script src='/SignalR/hubs'></script>

    <!--Add script to update the page and send messages.-->

    <script type='text/javascript'>

        $(function () {

            //引用自动生成的代理，myHub是HubName注解属性

            var myHub = $.connection.myHub;

            //后端调用前端

            myHub.client.serverSend2Client = function (message) {

                console.log("serverSend2Client message=" + message);

            };

            //开始连接

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

                //客户端发送信息到服务器

                myHub.server.send($.connection.hub.id);

                console.log("connection.hub.id=" + $.connection.hub.id);

            });

        });

    </script>

</head>

<body>

</body>

</html>

后端代码：

我们新建一个Notifier的静态类，好处是让其他类可以灵活地调用，你也可以把方法写在Hub类中

serverSend2Client方法是与前端绑定的JS方法，可以看到前端也有此方法。

    public static class Notifier

    {

        private static readonly IHubContext Context = GlobalHost.ConnectionManager.GetHubContext<MyHub>();

        public static void ServerSend2ClientMethod(string connectionId, string message)

        {

            //注册后端与前端的方法serverSend2Client。connectionId是判断发送给哪个前端

            Context.Clients.Client(connectionId).serverSend2Client(message);

        }

    }

我们在Controller中，添加代码，达到，后端主动调用前端的目的。

注意，connectionId在后端与前端后可以获取。

using System;

using System.Collections.Generic;

using System.Linq;

using System.Web;

using System.Web.Mvc;

using SignalRDemo.SignalR;

namespace SignalRDemo.Controllers

{

    public class DefaultController : Controller

    {

        // GET: Default

        public ActionResult Index()

        {

            //接收connId，connId是前端与后端连通的唯一标识

            string connId = Request["connId"] ?? "";

            //调用 后端主动调用前端的方法

            Notifier.ServerSend2ClientMethod(connId, Math.Round(1000.0) + "");

            return View();

        }

    }

}

至此，后端主动调用前端代码结束。

代码下载地址GitHub  https://github.com/cjt321/SignalRDemo

如果你的部署是负载均衡，多台服务器，可以查看Redis与SignalR的配置。C# BS消息推送 负载均衡-SignalR&Redis的配置（三）

可以关注本人的公众号，多年经验的原创文章共享给大家。

C# BS消息推送 SignalR Hubs环境搭建与开发（二）

C# BS消息推送 SignalR Hubs环境搭建与开发（二）的更多相关文章

  1. C&num; BS消息推送 SignalR介绍（一）

    1. 前言 本文是根据网上前人的总结得出的. 环境: SignalR2.x,VS2015,Win10 介绍 1)SignalR能用来持久客户端与服务端的连接,让我们便于开发一些实时的应用,例如聊天室在 ...

  2. 消息推送SignalR简单实例

    消息推送SignalR:一个ASP .NET 下的类库,可以在ASP .NET 的Web项目中实现实时通信. 功能:当所连接的客户端变得可用时服务器代码可以立即向其推送内容,而不是让服务器等待客户端请 ...

  3. iOS 10 消息推送（UserNotifications）秘籍总结（二）

    背景 上一篇博客iOS 10 消息推送(UserNotifications)秘籍总结(一)发布后被 简书编辑推荐至首页,这着实让我受宠若惊啊.可是好事不长,后面发生了让我伤心欲绝的事,我的女朋友不要我 ...

  4. Android 基于Netty的消息推送方案之概念和工作原理&lpar;二&rpar;

    上一篇文章中我讲述了关于消息推送的方案以及一个基于Netty实现的一个简单的Hello World,为了更好的理解Hello World中的代码,今天我来讲解一下关于Netty中一些概念和工作原理的内 ...

  5. 用 centrifugo 搭建 消息推送服务器 docker &plus; rancher 搭建

    关于消息推送服务器 目前有很多第三方的开放成熟的推送服务.鉴于项目需要 我们项目需要自己搭建 自己的推送服务. 我们的推送应用场景 聊天消息 项目内部消息提醒 移动设备接受消息 应用到的相关软件工具知 ...

  6. 消息推送SignalR

    一.什么是 SignalR ASP.NET SignalR is a library for ASP.NET developers that simplifies the process of add ...

  7. C&num; BS消息推送 负载均衡-SignalR&amp&semi;Redis的配置（三）

    1. 前言 本文是根据网上前人的总结得出的. 环境: SignalR2.x,VS2015,Win10 2. 负载均衡配置 配置很简单,只要在startup类中添加Redis的连接就OK. 1)首先,引 ...

  8. 细说 iOS 消息推送

    APNS的推送机制 与Android上我们自己实现的推送服务不一样,Apple对设备的控制很严格.消息推送的流程必需要经过APNs: 这里 Provider 是指某个应用的Developer,当然假设 ...

  9. MPush开源消息推送系统：简洁、安全、支持集群

    引言由于之前自己团队需要一个消息推送系统来替换JPUSH,一直找了很久基本没有真正可用的开源系统所有就直接造了个*,造*的时候就奔着开源做打算的,只是后来创业项目失败一直没时间整理这一套代码,最近 ...

随机推荐

  1. winform只允许一个应用程序运行 2014-12-08 09&colon;51 31人阅读 评论&lpar;0&rpar; 收藏

    使用互斥体Mutex类型 导入命名空间 using System.Threading; //声明互斥体 Mutex mutex = new Mutex(false, "ThisShouldO ...

  2. C&num;使用ICSharpCode&period;SharpZipLib&period;dll压缩多个文件

    首先通过NuGet管理安装ICSharpCode.SharpZipLib.dll 以下是压缩的通用方法: using System; using System.IO; using System.Web ...

  3. Android 网络图片加载之cude 框架

    偶然发现了这个框架,阿里图片加载用的这个框架.非常简单操作步骤. 1.首先下载软件包,直接搜Cube ImageLoader 这个. 2.加入jar文件 3.使用前的配置: public class ...

  4. 今日报错Cannot access java&period;lang&period;String

    public java.long.Long getId() { return id; } public void setId(java.lang.Long id) { this.id = id;} 手 ...

  5. Oracle lag&lpar;&rpar;&sol;lead&lpar;&rpar; over&lpar;&rpar;分析函数

    with tmp as(select '1' id ,'aa' name ,'22' age from dual union allselect '2' id ,'bb' name ,'20' age ...

  6. 栈长这里是生成了一个 Maven 示例项目。

    Spring Cloud 的注册中心可以由 Eureka.Consul.Zookeeper.ETCD 等来实现,这里推荐使用 Spring Cloud Eureka 来实现注册中心,它基于 Netfl ...

  7. &lbrack;基础知识&rsqb;PeopleSoft应用服务器上的进程含义

    1.PSAPPSRV PSAPPSRV作用是用来构建和报错HTML页面,运行peoplecode,处理消息和处理用户机器的sql请求.他还在用户机器最初登陆时候执行用户身份验证的任务. 2.PSSAM ...

  8. dubbo源码解析-spi&lpar;3&rpar;

    前言 在上一篇的末尾,我们提到了dubbo的spi中增加了IoC和AOP的功能.那么本篇就讲一下这个增加的IoC,spi部分预计会有四篇,因为这东西实在是太重要了.温故而知新,我们先来回顾一下,我们之 ...

  9. 【Streaming】30分钟概览Spark Streaming 实时计算

    本文主要介绍四个问题: 什么是Spark Streaming实时计算? Spark实时计算原理流程是什么? Spark 2.X下一代实时计算框架Structured Streaming Spark S ...

  10. Linux下强大的查找命令find 用法和常见用例

    Linux系统下find是较为常用的指令,find命令在目录结构中搜索文件,并执行指定的操作,掌握它的形式与用法对我们很有用处. 因为Linux下面一切皆文件,经常需要搜索某些文件来编写,所以对于Li ...

相关文章