我心中的核心组件（可插拔的AOP）~第六回消息组件~续-白红宇

上一回写已经是很久之前的事了，这一次准备把消息组件后续的东西说一下，事实上，第一篇文章主要讲的是发消息，而这一讲最要讲的是收消息，简单的说，就是消息到了服务器之后，如何从服务器实时的发到指定客户端，当然，你可以使用ＪＳ的轮询，但由于种种原因，它并不被我推荐，呵呵．

准备知识：

干实事

当客户端与服务器建立一个connection后，通过websocket技术，可以告诉服务器你的连接ＩＤ，这时，当然服务器检查到有你的消息时，直接为你的connectionID去发请求，调你的客户端方法，实现消息的显示就可以了，呵呵．这一切来的是那么容易，事实上，它内容的技术远不指这些，如果我们自己开发websocket，那除非你是个协议高手＋ＪＳ高手，否则没戏！所有，我们就只好用人家写好的东西了，而微软的SignalR就是这样一个东西，当你的浏览器支持html5时，它会与websocket方式进行与服务器端的通讯，不支持ＨＴＭＬ５，它与会使用其它手段来实现这个通讯的目的．

下面我复制之前写过的signalR文章中的部分代码：

第一　首先是服务器需要发布一个ＵＲＩ，来让客户端去访问

[HubName("MessagePush ")]    public class MessagePush : Hub    {　　　　//实现消息推送的逻辑　　｝

第二　一个集合，用来存储正处于登陆的用户，对于持久化的方式你可以使用内存，nosql等技术，这里没有所谓，呵呵，它是一个服务器端的方法，可以被客户端ＪＳ去调用

static List
     
       ConnectedUsers = new List
      
       ();        public void Connect(string url)        {            var id = Context.ConnectionId;            var userID = (HttpContext.Current.Session == null ? "" : HttpContext.Current.Session["UserID"] ?? "").ToString();            if (ConnectedUsers.Count(x => x.ConnectionId == id) == 0)            {                ConnectedUsers.Add(new CurrentUser                {                    ConnectionId = id,                    UserID = userID,                });                Clients.Caller.onConnected(id, userID, url);            　 　Clients.Client(id).onNewUserConnected(id, userID);            }                  }

第三　服务器调用客户端的方法

Clients.AllExcept(id).onNewUserConnected(id, userID);　//向所有客户端推送，除了自己之外  Clients.Client(id).onNewUserConnected(id, userID);//向自己去推送  Clients.All.onNewUserConnected(id, userID);//向所有客户端推送

第四　客户端代码，ＪＳ方法

第五　测试http://localhost:8080/MessagePush

第六　总结：事实上，实现的过程很简单，首先客户端通过登陆告诉服务器我来了，然后用户向服务端发消息，告诉服务器我要给某某某发消息了，其次，服务器收到消息之后，进行分发消息，由于用户登陆后已经在服务器上登记了，所以，很容易的找到了＂消息的接受者＂，最后，服务端调用指定客户端的ＪＳ方法，去显示和提醒用户：您老人家有新消息了，呵呵！

本文转自博客园张占岭（仓储大叔）的博客，原文链接：，如需转载请自行联系原博主。