npm install --save express@4.10.2
npm install --save socket.io

{
 "name": "socket-test",
 "version": "0.0.1",
 "description": "my first socket.io app",
 "dependencies": {
  "express": "^4.10.2",
  "socket.io": "^1.7.2"
 }
}

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var fs = require('fs');
#默認(rèn)打開文件
app.get('/', function(req, res){
  res.sendfile('index.html');
});
#用于存儲(chǔ)所有socket以廣播數(shù)據(jù)
var iolist = [];
#定義socket on connection（連入）事件行為
io.on('connection', function(socket){
  #將連入socket加入列表
  iolist.push(socket); 
  #記錄index，在disconnect（斷開連接）發(fā)生時(shí)將對(duì)應(yīng)的socket刪除
  var sockex = iolist.indexOf(socket); 
  #定義on disconnect事件行為
  socket.on('disconnect', function(){
    #將斷開連接的socket從廣播列表里刪除
    iolist.splice(sockex, 1);
  });
});
# 數(shù)據(jù)廣播進(jìn)程:每1秒鐘廣播一次
setInterval(function() {
  # 如果沒有正在連接的socket，直接返回；
  if (iolist.length <= 0) return;
  var trends = fs.readFileSync('./data/trends.json','utf-8');#trends數(shù)據(jù)
  var coins = fs.readFileSync('./data/coins.json','utf-8');#coins數(shù)據(jù)
  #向所有socket連接發(fā)送數(shù)據(jù)
  for (i in iolist) {
    # 向客戶端發(fā)送trends數(shù)據(jù)
    iolist[i].emit('trends', trends);
    # 向客戶端發(fā)送coins數(shù)據(jù)
    iolist[i].emit('coins', coins);
  }
}, 1000);
# 服務(wù)器偵聽在sockettest.com的3000端口上
http.listen(3000, function(){
  # 輸出到標(biāo)準(zhǔn)輸出
  console.log('listening on sockettest.com:3000');
});

<!--引入必要的js文件-->
<script type="text/javascript" src="http://sockettest:3000/socket.io/socket.io.js"></script>
<script type="text/javascript">
    //新建socket
    var socket = io('http://sockettest.com:3000');
    socketdata(socket);
    function socketdata() {
      #定義接收到coins類型數(shù)據(jù)時(shí)的行為
      socket.on('coins', function(msg){
        console.log(msg);
      }
      #定義接收到trends類型數(shù)據(jù)時(shí)的行為
      socket.on('trends', function(msg){
        console.log(msg);
      }
    }
</script>

node ./trends.js