asp.net signalR 专题—— 第三篇如何从外部线程访问 PersistentConnection ...

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› ASP.NET›ASP.NET编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

在前面的两篇文章中，我们讲到的都是如何将消息从server推向client，又或者是client再推向server，貌似这样的逻辑没什么异常，但是放在真实

的环境中，你会很快发现有一个新需求，如何根据第三方系统的数据变化来即时的将新数据推送到各个客户端，比如下面这样：

ok，原理就是上面的这张图，如果我们Server中的“监控程序”发现有更新，这个时候，监控程序需要将更新的数据送给server程序，然后由server程序

推送到各个客户端，那下面我们该怎么做到呢？

一：GlobalHost 属性

首先我们简单的看一下它的解释，叫做“提供对默认主机信息的访问”，可以看到，这是一个所谓的全局设置，里面的5个属性，个个都非常重要，因为

对他们的设置，影响的都是全局性的，好了，作为这篇我们关注的就是其中之一ConnectionManager属性，如下图：

它呢，就是获取你当前的Connection连接，好了，废话不多说，我们来做一个例子看一看。

二：实例演示

1. 伪造“外部系统”

在这里我就Fake一个单独页面（mytest.aspx)，假装从外面获取到了"我是mytest.aspx"这条数据，如下：

在上图中，你也看到了GetConnectionContext方法是接受一个泛型的参数，而这个“泛型参数”，就是你的PersistentConnection实现类，这里也就

是MyConnection1，当然这里不光可以访问Persistent，还可以访问Hub类，这个我们放到后续和大家讲解。

2. 开启两个客户端

开启这两个就是为了连接到我们的server，假装多用户，也就是PersistentConnection类，如下：

<!DOCTYPE html>
<html>
<head>
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
    <title></title>
    <meta charset="utf-8" />
</head>
<body>
    <script src="/scripts/jquery-1.10.2.js"></script>
    <script src="/scripts/jquery.signalR-2.1.2.js"></script>
    <!--<script src="/signalr/js"></script>-->
    <script src="scripts/myjs.js"></script>
    <script type="text/javascript">
        var conn = $.connection("/myconnection");

        conn.start().done(function (data) {
            console.log(data.id);
        });

        conn.received(function (data) {
            console.log(data);
        });

    </script>
</body>
</html>

    public class MyConnection1 : PersistentConnection
    {
        protected override Task OnConnected(IRequest request, string connectionId)
        {
            Debug.WriteLine("OnConnected");
            return Connection.Send(connectionId, "Welcome!");
        }

        protected override Task OnReceived(IRequest request, string connectionId, string data)
        {
            Debug.WriteLine(data);
            return Connection.Send(connectionId, data);
        }

        protected override Task OnDisconnected(IRequest request, string connectionId, bool stopCalled)
        {
            Debug.WriteLine("OnDisconnected");
            return base.OnDisconnected(request, connectionId, stopCalled);
        }

        protected override Task OnReconnected(IRequest request, string connectionId)
        {
            Debug.WriteLine("OnReconnected");
            return base.OnReconnected(request, connectionId);
        }
    }