setInterval(function() {
    $.get('/get/data-list', function(data, status) {
        console.log(data)
    })
}, 5000)

function poll() {
    setTimeout(function() {
        $.get('/get/data-list', function(data, status) {
            console.log(data)
            poll()
        })
    }, 5000)
}

// 實例化 EventSource 參數(shù)是服務(wù)端監(jiān)聽的路由
var source = new EventSource('/EventSource-test')
source.onopen = function (event) { // 與服務(wù)器連接成功回調(diào)
  console.log('成功與服務(wù)器連接')
}
// 監(jiān)聽從服務(wù)器發(fā)送來的所有沒有指定事件類型的消息(沒有event字段的消息)
source.onmessage = function (event) { // 監(jiān)聽未命名事件
  console.log('未命名事件', event.data)
}
source.onerror = function (error) { // 監(jiān)聽錯誤
  console.log('錯誤')
}
// 監(jiān)聽指定類型的事件（可以監(jiān)聽多個）
source.addEventListener("myEve", function (event) {
  console.log("myEve", event.data)
})

const fs = require('fs')
const express = require('express') // npm install express
const app = express()
 
// 啟動一個簡易的本地server返回index.html
app.get('/', (req, res) => {
  fs.stat('./index.html', (err, stats) => {
    if (!err && stats.isFile()) {
      res.writeHead(200)
      fs.createReadStream('./index.html').pipe(res)
    } else {
      res.writeHead(404)
      res.end('404 Not Found')
    }
  })
})
 
// 監(jiān)聽EventSource-test路由服務(wù)端返回事件流
app.get('/EventSource-test', (ewq, res) => {
  // 根據(jù) EventSource 規(guī)范設(shè)置報頭
  res.writeHead(200, {
    "Content-Type": "text/event-stream", // 規(guī)定把報頭設(shè)置為 text/event-stream
    "Cache-Control": "no-cache" // 設(shè)置不對頁面進行緩存
  })
  // 用write返回事件流，事件流僅僅是一個簡單的文本數(shù)據(jù)流，每條消息以一個空行(\n)作為分割。
  res.write(':注釋' + '\n\n')  // 注釋行
  res.write('data:' + '消息內(nèi)容1' + '\n\n') // 未命名事件
 
  res.write(  // 命名事件
    'event: myEve' + '\n' +
    'data:' + '消息內(nèi)容2' + '\n' +
    'retry:' + '2000' + '\n' +
    'id:' + '12345' + '\n\n'
  )
 
  setInterval(() => { // 定時事件
    res.write('data:' + '定時消息' + '\n\n')
  }, 2000)
})
 
// 監(jiān)聽 6788
app.listen(6788, () => {
  console.log(`server runing on port 6788 ...`)
})

// WebSocket 對象作為一個構(gòu)造函數(shù)，用于新建 WebSocket 實例
var ws = new WebSocket('ws://localhost:8080')

// 用于指定連接成功后的回調(diào)函數(shù)
ws.onopen = function(){}

// 用于指定連接關(guān)閉后的回調(diào)函數(shù)
ws.onclose = function(){}

// 用于指定收到服務(wù)器數(shù)據(jù)后的回調(diào)函數(shù)
ws.onmessage = function(){}

// 實例對象的send()方法用于向服務(wù)器發(fā)送數(shù)據(jù)
ws.send('data')

// 用于指定報錯時的回調(diào)函數(shù)
socket.onerror = function(){}

<button id="closeSocket">斷開連接</button>
<button id="openSocket">恢復(fù)連接</button>
<script src="/socket.io/socket.io.js"></script>
<script>
// 建立連接 默認指向 window.location
let socket = io('http://127.0.0.1:6788')
 
openSocket.onclick = () => {
  socket.open()  // 手動打開socket 也可以重新連接
}
closeSocket.onclick = () => {
  socket.close() // 手動關(guān)閉客戶端對服務(wù)器的鏈接
}
 
socket.on('connect', () => { // 連接成功
  // socket.id是唯一標(biāo)識，在客戶端連接到服務(wù)器后被設(shè)置。
  console.log(socket.id)
})
 
socket.on('connect_error', (error) => {
  console.log('連接錯誤')
})
socket.on('disconnect', (timeout) => {
  console.log('斷開連接')
})
socket.on('reconnect', (timeout) => {
  console.log('成功重連')
})
socket.on('reconnecting', (timeout) => {
  console.log('開始重連')
})
socket.on('reconnect_error', (timeout) => {
  console.log('重連錯誤')
})
 
// 監(jiān)聽服務(wù)端返回事件
socket.on('serverEve', (data) => {
  console.log('serverEve', data)
})
 
let num = 0
setInterval(() => {
  // 向服務(wù)端發(fā)送事件
  socket.emit('feEve', ++num)
}, 1000)
 

const app = require('express')()
const server = require('http').Server(app)
const io = require('socket.io')(server, {})
 
// 啟動一個簡易的本地server返回index.html
app.get('/', (req, res) => {
  res.sendfile(__dirname + '/index.html')
})
 
// 監(jiān)聽 6788
server.listen(6788, () => {
  console.log(`server runing on port 6788 ...`)
})
 
// 服務(wù)器監(jiān)聽所有客戶端 并返回該新連接對象
// 每個客戶端socket連接時都會觸發(fā) connection 事件
let num = 0
io.on('connection', (socket) => {
 
  socket.on('disconnect', (reason) => {
    console.log('斷開連接')
  })
  socket.on('error', (error) => {
    console.log('發(fā)生錯誤')
  })
  socket.on('disconnecting', (reason) => {
    console.log('客戶端斷開連接但尚未離開')
  })
 
  console.log(socket.id) // 獲取當(dāng)前連接進入的客戶端的id
  io.clients((error, ids) => {
    console.log(ids)  // 獲取已連接的全部客戶機的ID
  })
 
  // 監(jiān)聽客戶端發(fā)送的事件
  socket.on('feEve', (data) => {
    console.log('feEve', data)
  })
  // 給客戶端發(fā)送事件
  setInterval(() => {
    socket.emit('serverEve', ++num)
  }, 1000)
})
 
/*
  io.close()  // 關(guān)閉所有連接
*/

let num = 0
let ws = new WebSocket('ws://127.0.0.1:6788')
ws.onopen = (evt) => {
  console.log('連接成功')
  setInterval(() => {
    ws.send(++ num)  // 向服務(wù)器發(fā)送數(shù)據(jù)
  }, 1000)
}
ws.onmessage = (evt) => {
  console.log('收到服務(wù)端數(shù)據(jù)', evt.data)
}
ws.onclose = (evt) => {
  console.log('關(guān)閉')
}
ws.onerror = (evt) => {
  console.log('錯誤')
}
closeSocket.onclick = () => {
  ws.close()  // 斷開連接
}

const fs = require('fs')
const express = require('express')
const app = express()
 
// 啟動一個簡易的本地server返回index.html
const httpServer = app.get('/', (req, res) => {
  res.writeHead(200)
  fs.createReadStream('./index.html').pipe(res)
}).listen(6788, () => {
  console.log(`server runing on port 6788 ...`)
})
 
// ws
const WebSocketServer = require('ws').Server
const wssOptions = {  
  server: httpServer,
  // port: 6789,
  // path: '/test'
}
const wss = new WebSocketServer(wssOptions, () => {
  console.log(`server runing on port ws 6789 ...`)
})
 
let num = 1
wss.on('connection', (wsocket) => {
  console.log('連接成功')
 
  wsocket.on('message', (message) => {
    console.log('收到消息', message)
  })
  wsocket.on('close', (message) => {
    console.log('斷開了')
  })
  wsocket.on('error', (message) => {
    console.log('發(fā)生錯誤')
  })
  wsocket.on('open', (message) => {
    console.log('建立連接')
  })
 
  setInterval(() => {
    wsocket.send( ++num )
  }, 1000)
})