利用Socket.io 实现消息实时推送功能

项目背景介绍

最近在写的项目中存在着社交模块，需要实现这样的一个功能：当发生了用户被点赞、评论、关注等操作时，需要由服务器向用户实时地推送一条消息。最终完成的项目地址为：https://GitHub.com/noiron/Socket-message-push，这里将介绍一下实现的思路及部分代码。

项目的流程中存在着这样的几个对象：

• 用 Java 实现的后端服务器
• 用 node.js 实现的消息推送服务器
• 用户进行操作的客户端

事件处理的流程如下：

• 用户进行点赞操作时，后端服务器会进行处理，并向 node.js 消息推送服务器发送一条消息
• Node.js 消息推送服务器接收到后端发送的消息后，处理数据，并确定向哪个用户进行推送
• 用户的客户端接收到由 Node.js 服务器推送来的消息后，即可进行通知的显示。
• 上面的流程中，Java 后端服务器是如何实现的不在此篇文章的讨论范围内，本文将主要介绍如何使用 Node.js 来实现这个消息推送服务器。

考虑消息推送服务器上必须记录下当前在线用户的信息，这样才能向特定的用户推送消息。所以当用户登录时，必须将自身的用户信息发到 Node.js 服务器上。为了达到这种双向的实时消息传递，很明显地考虑用 websocket 来实现。既然我们在消息推送服务器上使用了 Node.js，我们就有了一个很方便的选项：socket.io。

Socket.io 介绍

Socket.io是一个用 javascript 实现的实时双向通信的库，利用它来实现我们的功能会很简单。

socket.io 包含两个部分：

• 服务器端（server）：运行在 Node.js 服务器上
• 客户端（client）：运行在浏览器中

可以看看如下的 socket.io 的示例代码，它给出了 socket.io 发出及监听事件的基本用法：

io.on('connection', function(socket){ socket.emit('request', ); // emit an event to the socket io.emit('broadcast', ); // emit an event to all connected sockets socket.on('reply', function(){  }); // listen to the event});