Web端即时通讯、消息推送的实现

admin

在浏览某些网页的时候，例如 WebQQ、京东在线客服服务、CSDN私信消息等类似的情况下，我们可以在网页上进行在线聊天，或者即时消息的收取与回复，可见，这种功能的需求由来已久，并且应用广泛。

网上关于这方面的文章也能搜到一大堆，不过基本上都是理论，真正能够运行的代码很少，原理性的东西我就不当搬运工了，本文主要是贴示例代码，最多在代码中穿插一点便于理解，本文主要的示例代码基于 javascript，服务端基于 nodejs 的 koa(1/2)框架实现。

---

模拟推送

Web端 常见的消息推送实际上大多数都是模拟推送，之所以是模拟推送，是因为这种实现并不是服务器主动推送，本质依旧是客户端发起请求，服务端返回数据，起主动作用的是客户端。

---

9 T/ P: ?5 R( c( S3 p5 @
短轮询

实现上最简单的一种模拟推送方法，原理就是客户端不断地向服务端发请求，如果服务端数据有更新，服务端就把数据发送回来，客户端就能接收到新数据了。

一种实现的示例如下：

1. const loadXMLDoc = (url, callback) => {
   / H. d  q- C8 v- v% l7 V
2.   let xmlhttp
   
3.   if(window.XMLHttpRequest) {
   # S( w* S: q4 a9 t$ `
4.     //  IE7+ Firefox Chrome Safari 等现代浏览器执行的代码
   
5.     xmlhttp = new XMLHttpRequest()
   
6.   } else {
   
7.     // IE5 IE6浏览器等老旧浏览器执行的代码
   ' |$ j& T. i" _
8.     xmlhttp = new ActiveXObject('Microsoft.XMLHTTP')
   7 I+ y) _$ C6 D. L# Y
9.   }
     o3 C3 Z% f$ Q3 A4 r  X
10. 
    ! X  H+ X. T' {: w* {! }* b0 c
11.   xmlhttp.onreadystatechange = () => {
    . y" O* n3 `$ F7 ^8 F& E7 m0 H
12.     if(xmlhttp.readyState === 4 && xmlhttp.status === 200) {
    ! k8 t" ?9 I% I  p; x8 @
13.       document.getElementById('box1').innerHTML = xmlhttp.responseText
    
14.       callback && callback()
    
15.     }
    
16.   }
    
17.   // 打开链接发送请求
    - \: u- h6 c; ~7 J
18.   xmlhttp.open('GET', 'http://127.0.0.1:3000/' + url, true)
    : E; u" `; A4 p8 _0 d
19.   xmlhttp.send()
    
20. }
    
21. 
    2 ^( f9 j4 |& y) ?
22. // 轮询
    % _  V' O* k" v+ O  |
23. setInterval(function() {
    5 [* H2 B' t. f" X
24.   loadXMLDoc('fetchMsg')
    
25. }, 2000)

复制代码

上述代码，设置定时任务，每隔 2s使用 ajax发起一次请求，客户端根据服务端返回的数据来进行决定执行对应的操作，除了发送 ajax，你还可以使用 fetch：

1. fetch('localhost:3000/fetchMsg', {
   3 K& @* i. W  B* D, d
2.     headers: {
   ' A) m  i6 r$ ~
3.         'Accept': 'application/json, text/plain, */*'
   ' S% b% C. D2 n% o) R- ?8 n( L- }
4.     }
   : T, u) l; Y- U
5. }

复制代码

1. 引申：fetch目前的浏览器支持度还很低，所以在实际生产环境中使用的时候，最好添加一些 polyfill，一种垫片使用顺序示例如下：
   3 N7 Y; N, U/ j. a1 j
2. - es5 的 polyfill — es5-shim
   
3. - Promise 的 polyfill — es6-promise - IE8+
   6 s- _  \) p6 ^+ R' @
4. - fetch 的 polyfill — fetch - IE10+

复制代码

如果你在使用某种框架，例如 vue 或者 angular，那么你同样可以使用这些框架自带的请求方法，总之基于页面的友好访问性，在发送请求的同时不要刷新页面就行了。

另外，如果不想在主程序的线程中做这种机械的轮询，可以尝试使用 Web Worker，下面是一个使用 Web Worker轮询的例子：

1. // 在主程序中创建 Web Worker
   
2. function createWorker(fn) {
   " f' G. P6 U8 q7 R3 e
3.   const blob = new Blob([fn.toString()])
   5 @8 k% r  f4 f) h
4.   const url = window.URL.createObjectURL(blob)
   : u6 b; n1 r# |$ n
5.   const worker = new Worker(url)
   % [7 Y+ l9 h) U+ F9 |: u4 b, V" T
6.   return worker
   1 o, R' x! ]) W' _7 c
7. }
   
8. 
   
9. // 轮询函数
   9 m9 ~0 E6 Y, ~2 q
10. const pollingWorker = createWorker(() => {
    3 z0 F7 A, v9 S9 u$ w5 t; \
11.   let cache = null
    
12.   // 如果这一个 worker只干这一件事，setInterval是不会受到干扰的
    ( h$ C+ Y9 X2 V& G1 [7 q* l4 ~
13.   setInterval(function() {
    * L: y" R' A) F/ C$ K& \2 ?& f3 P- L
14.     fetch('/my-api').then(res => {
    ( T, m  u$ O' p2 n( u
15.       const data = res.json()
    4 t2 C9 A/ b, \1 B! Z% s( z
16.       if (data !== cache) {
    ' T7 S" K8 N5 ^- T* T
17.         // 轮询的数据发生变化
    $ E0 x3 o% ~* b' L# K+ m
18.         cache = data
    
19.         // worker向主程序发送通知
    0 ~; B6 P, w/ M5 a1 J
20.         self.postMessage(data)
    % h+ \1 f4 o' Q( R, E, H. }, D
21.       }
    
22.     })
    $ k/ t$ Y) d+ q& i3 z9 s6 B' i; y* J
23.   }, 1000)
    
24. })
    1 Y& D! p2 t- ~
25. 
    
26. pollingWorker.onmessage = function() {
    
27.   // 主程序接收到 worker发来的通知
    ! _! L, R1 E' j- _! z
28.   // do something
    * G( o  V1 ]: a+ L1 d9 a; o
29. }

复制代码

优点：

1. 前后端程序都很容易编写，没什么技术难度

复制代码

缺点：

1. 这种方法因为需要对服务器进行持续不断的请求，就算你设置的请求间隔时间很长，但在用户访问量比较大的情况下，也很容易给服务器带来很大的压力，而且绝大部分情况下都是无效请求，浪费带宽和服务器资源，一般不会用于实际生产环境的，自己知道一下就行了。

复制代码

---

长轮询

相比于上一种实现，长轮询同样是客户端发起请求，服务端返回数据，只不过不同的是，在长轮询的情况下，服务器端在接到客户端请求之后，如果发现数据库中的数据并没有更新或者不符合要求，那么就不会立即响应客户端，而是 hold住这次请求，直到符合要求的数据到达或者因为超时等原因才会关闭连接，客户端在接收到新数据或者连接被关闭后，再次发起新的请求。

为了节约资源，一次长轮询的周期时间最好在 10s ~ 25s左右，长连接也是实际生产环境中，被广泛运用于实时通信的技术。

客户端代码如下：

1. function getData() {
   
2.   loadXMLDoc('holdFetchMsg', ()=>{
   
3.     getData()
   
4.   })
   2 g$ T# U) C6 i
5. }
   
6. getData()

复制代码

想要在连接断开或发生错误的时候，再次发起请求连接，实现也很简单，以下问使用 fetch 实现示例：

1. function getData() {
   ; q( _8 Z& J  f' e3 X' j) [' b
2.   let result = fetch('http://127.0.0.1:3000/holdFetchMsg', {
   % r* B/ r" o* m. x- p. }
3.     headers: {
   - g2 C% Z$ {2 h: Y
4.         'Accept': 'application/json, text/plain, */*'
   % [$ T$ t1 z% g$ w- ~
5.     }
   ; {7 }! K1 @4 V! R
6.   })
   
7.   result.then(res => {
   1 J0 m% I5 r* R  e  a
8.     return res.text()
   
9.   }).then(data => {
   
10.     document.getElementById('box1').innerHTML = data
    7 \% z* J, w' s0 [6 x* D: D; ?
11.   }).catch(e => {
    
12.     console.log('Catch Error:', e)
    
13.   }).then(() => {
    
14.     getData()
    
15.   })
    
16. }
    9 R& O' Q( P, g. ?3 `
17. getData()

复制代码

一种较为直观的服务器 hold住连接的实现如下：

1. router.get('/holdFetchMsg', (ctx, next)=> {
   5 ^9 H7 }( j" K6 p6 L3 m& E
2.   let i = 0
   
3.   while(true) {
   
4.     // 这里的条件在实际环境中可以换成是到数据库查询数据的操作
     d/ ^& _+ h' b4 [
5.     // 如果查询到了符合要求的数据，再 break
   
6.     // 不过这种可能会导致服务器进行例如疯狂查询数据库的操作，非常不友好
   5 C- c2 r( z6 M+ `- D& A2 r
7.     if(++i > 2222222222) {
   3 H+ @+ [4 q# y. K
8.       ctx.body = '做我的狗吧'
   ' h% v/ P3 T6 }  c1 Q
9.       break
   6 h2 ?! h( m$ Z$ j9 h8 N
10.     }
    
11.   }
    
12. })

复制代码

还有一种方法，不过这种纯粹是为了 hold住而 hold住，可以作为上一种方法的辅助，解决诸如服务端进行疯狂查询数据库的操作，类似于 Java中的 Thread.sleep()操作
) V, }. v5 g5 X3 R

1. let delay = 2000, i = 0
   
2. while(true) {
   
3.    let startTime = new Date().getTime()
   ' `+ M$ e9 u$ F" }& p5 N; A" y
4.    // 这里的条件在实际环境中可以换成是到数据库查询数据的操作
   / H0 @! S5 ?& y7 _5 r( y
5.    if(++i > 3) {
   - u: |6 |2 C2 H# T0 s/ a( d
6.      ctx.body = '做我的狗吧'
   + u* f7 B9 d4 g' I! {$ F, ~: S- c
7.      break
   . X  o1 ]& B& O( Z5 D2 S
8.    } else {
   ) D  o9 y4 H* e2 U! y5 ]) N
9.      // 休息会，别那么频繁地进行诸如查询数据库的操作
   
10.      // delay 为每次查询后 sleep的时间
    8 H0 x5 _: o' s: k% D% a
11.      while(new Date().getTime() < startTime + delay);
    
12.    }
    
13. }

复制代码

如果你现在的 Nodejs版本支持 ES6中的 Generator的话，那么还可以这样(koa1环境， Generator写法)：

1. app.use(function* (next){
   
2.   let i = 0
   
3.   const sleep = ms => {
   3 [4 C1 h1 {5 J# W  K5 R, D
4.     return new Promise(function timer(resolve){
   7 U5 f  Z) U( ~
5.       setTimeout(()=>{
   ! x& M' \6 R) D0 E9 P: ~
6.         if(++i > 3) {
   7 t/ E: C6 s. T! q' D
7.           resolve()
   . I7 s% M& a$ E( k: J5 F3 E2 H
8.         } else {
   7 ~" U, F0 i* L- q* t% c: ~
9.           timer(resolve)
   , {  H- N9 [; a8 t# ~8 r; I
10.         }
    ! X$ r) U/ V1 u% \, G, ~4 Y, A
11.       }, ms)
    
12.     })
    ) t. \) W6 K5 q  B; n- ^
13.   }
    
14.   yield sleep(2000)
    * T  a1 L8 i6 u' {. z
15.   this.body = '做我的狗吧'
    
16. })

复制代码

如果你现在的 Nodejs版本支持 ES7中的 async/await的话，，那么还有一种 hold住连接的方法可供选择(koa2环境)：
( g! N+ g8 x( [3 A+ }4 j

1. router.get('/holdFestchMsg', async(ctx, next) => {
   6 q& T4 \& Y* E' h" v9 a3 @
2.     let i = 0
   
3.     const sleep = ms => {
   , M/ {2 D5 l7 K7 ^
4.        return new Promise(function timer(resolve) {
   1 h: I& g8 W3 ^+ s
5.          setTimeout(async()=>{
   
6.            // 这里的条件在实际环境中可以换成是到数据库查询数据的操作
   : o$ ^# x: W( Q( J+ \7 R7 g
7.            if(++i > 3) {
   + x8 z+ S$ [* l( }# j3 p
8.              resolve()
   6 x: \. f$ f+ A( g4 A$ I
9.            } else {
   $ }; X3 s' }/ D- G0 @
10.              timer(resolve)
    ) u2 d9 u  v- A& ?1 |5 ?+ ?
11.            }
    5 x: A- g9 Z) E/ u2 x
12.          }, ms)
    
13.        })
    3 B, n) K3 e- {
14.      }
    " A+ A# M$ r0 J! C) H
15.      await sleep(2000)
    
16.      ctx.body = '做我的狗吧'
    - W7 N7 C: S0 m% e# z$ M+ D! I8 h* c
17. })

复制代码

优点：
0 Y& O+ p4 _: J. [6 `/ t- m

1. 尽管长轮询不可能做到每一次的响应都是有用的数据，因为服务器超时或者客户端网络环境的变化，以及服务端为了更好的分配资源而自动在一个心跳周期的末尾断掉连接等原因，而导致长轮询不可能一直存在，必须要不断地进行断开和连接操作，但无论如何，相比于短轮询来说，长轮询耗费资源明显小了很多

复制代码

缺点：

1. 服务器 hold连接依旧会消耗不少的资源，特别是当连接数很大的时候，返回数据顺序无保证，难于管理维护。

复制代码

---

长连接

这种是基于 iframe 或者 script实现的，主要原理大概就是在主页面中插入一个隐藏的 iframe(script)，然后这个 iframe(script)的 src属性指向服务端获取数据的接口，因为是iframe(script)是隐藏的，而且 iframe(script)的 刷新也不会导致 主页面刷新，所以可以为这个 iframe(script)设置一个定时器，让其每隔一段时间就朝服务器发送一次请求，这样就能获得服务端的最新数据了。

先说一下 利用 script的长连接：

前端实现：

1. <script>
   : p6 O$ s0 L3 G! n
2.   function callback(msg) {
   2 j9 x: _) \2 j0 L) S9 j1 i! N% R) \
3.     // 得到后端返回的数据
   / u* t/ M, p; ?4 u6 g$ W/ d
4.     console.log(msg);
   0 a5 P9 r6 W( e  c4 \" Q/ s2 W
5.   }
   * @* C7 K9 ~$ v
6.   function createScript() {
   
7.     let script = document.createElement('script')
   
8.     script.src = 'http://127.0.0.1:3000/fetchMsg'
   
9.     document.body.appendChild(script)
   
10.     document.body.removeChild(script)
    
11.   }
    
12. </script>
    
13. <script>
    
14.   window.onload = function() {
    $ \$ m% ^+ c. C' c) _
15.     setInterval(()=>{
    
16.       createScript()
    * z( w2 Y. ~  Q# A1 H* l) A# {. O$ A
17.     }, 3000)
    8 g- _7 Z/ p, C- x8 r5 `
18.   }
    
19. </script>

复制代码

后端实现：

1. router.get('/fetchMsg', (ctx, next)=> {
   
2.   ctx.body = 'callback("做我的狗吧")'
   
3. })

复制代码

主要是在前端，一共两条 script脚本，大致左右就是在一定的时间间隔内（示例为 3s）就动态地在页面中增删一个链接为用于请求后端数据的 script脚本。

后端则返回一段字符串，这段字符串在返回前端时，有一个 callback字段调用前端的代码，类似于 jsonp的请求。

1. 注意：修改一个已经执行过的 script脚本的 src属性是没什么卵用的，修改之后，最多在页面的 DOM上发生一些变化，而浏览器既不会发请求，也不会执行脚本，所以这里采用动态增删整个 script标签的做法。

复制代码

可以看到，这种方法其实与短轮询没什么区别，唯一的区别在于短轮询保证每次请求都能收到响应，但上述示例的长连接不一定每次都能得到响应，如果下一次长连接开始请求，上一次连接还没得到响应，则上一次连接将被终止。

当然，如果你想长连接每次也都能保证得到响应也是可以的，大致做法就是在页面中插入不止一条 script标签，每条标签对应一个请求，等到当前请求到达再决定是否移除当前 script标签。

如果想要得到有序的数据响应，则还可以将 setInterval换成递归调用，例如：

1. function createScript() {
   2 Z9 X7 @9 r! N! W
2.   let script = document.createElement('script')
   - x8 g- ?7 b' @  }  {
3.   script.src = 'http://127.0.0.1:3000/fetchMsg'
   
4.   document.body.appendChild(script)
   
5.   script.onload = ()=> {
   
6.     document.body.removeChild(script)
   
7.     // 约束轮询的频率
     Q3 @3 H5 C/ o1 |, b
8.     setTimeout(()=>{
   * x) L7 c9 W' N5 t
9.       createScript()
   $ k! E4 \! Z# I  V
10.     }, 2000)
    5 D8 e9 s4 g" g  O: I
11.   }
    ; C# W% u7 Z3 Z, P
12. }
    2 e( |. I, v( M, q5 i, N# {
13. 
    
14. window.onload = function() {
    
15. createScript()
    2 N% [& Q9 g) z- P8 U5 i
16. }

复制代码

使用 iframe的方式与此类似，就不赘述了，不过需要注意的是， iframe可能存在跨域的情况，可能会比 script方式麻烦一些。

---

0 w9 X5 _7 D# _9 |1 i: EWebSocket

WebSoket是 HTML5新增的 API，具体介绍如下（来源w3c菜鸟教程）

1. WebSocket是HTML5开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。
   
2. 
   & e+ I! |" I, j( a
3. 在WebSocket API中，浏览器和服务器只需要做一个握手的动作，然后，浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。
   3 r+ _! |6 W9 L  v3 I# w7 X7 ~# d
4. 
   
5. 浏览器通过 JavaScript 向服务器发出建立 WebSocket 连接的请求，连接建立以后，客户端和服务器端就可以通过 TCP 连接直接交换数据。
   
6. 
   
7. 当你获取 Web Socket 连接后，你可以通过 send() 方法来向服务器发送数据，并通过 onmessage 事件来接收服务器返回的数据。

复制代码

上面所提到的短轮询、长轮询、长连接，本质都是单向通信，客户端主动发起请求，服务端被动响应请求，但 WebSocket则已经是全双工通讯了，也就是说无论是客户端还是服务端都能主动向对方发起响应，服务器具备了真正的 推送能力。

一段简单的 客户端 WebSocket代码示例如下：

1. function myWebSocket() {
   9 `: F4 K2 x( e1 a, d# c" ]
2.   let ws = new WebSocket('ws://localhost:3000')
   6 G1 j$ N  }9 R0 s+ Y2 W5 p0 _% P. c9 f: Q
3.   ws.onopen = ()=> {
   
4.     console.log('send data')
   1 p0 H/ `# D, y
5.     ws.send('client send data')
   
6.   }
   ' O5 Q- e" J$ r$ d# K' Q& p9 B+ _' b
7. 
   
8.   ws.onmessage = (e)=> {
   : E4 i5 u7 T: L: x
9.     let receiveMsg = e.data
   $ s; B2 J! f( k2 X7 G* Z2 `/ T6 v( e2 M
10.     console.log('client get data')
    
11.   }
    9 U- r6 k: i% g4 M# j, i9 C
12. 
    
13.   ws.onerror = (e)=>{
    
14.     console.log('Catch Error:', e)
    
15.   }
    / G3 c, s4 c5 s. v& R% T% k$ l
16. 
    
17.   ws.onclose = ()=> {
    
18.     console.log('ws close')
    0 t7 |: M- R' M
19.   }
    
20. }

复制代码

想要让客户端的 WebSocket能够连接上服务器，服务端必须要具备能够响应 WebSocket类型的请求才行，一般的服务器是没有自带这种能力的，所以必须要对服务器端程序代码做出些改变。

自己封装服务器端响应 WebSocket的代码可能会涉及到很底层的东西，所以一般都是使用第三方封装好的库，基于nodejs的 WebSocket库有很多，ws 功能简单， API形式更贴近于原生，大名鼎鼎的 socket.io 是与 Nodejs联手开发，功能齐全，被广泛运用于游戏、实时通讯等应用。

以下给出一种基于 socket.io 实现 简单客户端和服务端通信的示例：

客户端：

1. // HTML
   - ]0 ^. Y" F. h5 |/ n
2. <body>
   
3.   <ul id="messages"></ul>
   % `4 H9 v' {: m$ Z. {6 K$ A
4.   <form action="" id="msgForm">
   
5.     <input id="m" autocomplete="off" /><input type="submit" class="submit" value="submit">
   
6.   </form>
   
7. </body>
   
8. 
   
9. // 引入 socket.io
   
10. <script src='/socket.io/socket.io.js'></script>
    
11. <script>
    ! s1 M  G+ Z: \" \+ l& z. ~
12.   function appendEle(parent, childValue, position = 'appendChild') {
    
13.     let child = document.createElement('li')
    
14.     child.innerHTML = childValue
    " R' h; u, R' q% I4 K
15.     parent[position](child)
    # d$ s7 {4 Z  m1 m4 n0 [
16.   }
    3 E" E. V; _, P( a" r/ w
17. 
    7 p6 X: y( u  g" W) r
18.   function socketIO(msgForm, msgBox, msgList) {
    . v0 J7 w0 t7 `8 _5 ~0 Y
19.     const socket = io()
    + c: u2 I. c* m% i5 t1 z
20.     msgForm.addEventListener('submit', (e)=>{
    " Q& V! O* [& Y7 h7 L, t
21.       e.preventDefault()
    
22.       socket.emit('chat message', msgBox.value)
    1 T' a: |. Z2 s: V$ G
23.       appendEle(msgList, '<b>Client: </b>' + msgBox.value)
    
24.       msgBox.value = ''
    . I& A2 N& v/ A5 x. {
25.     })
    
26. 
    + f. K! H* B5 a+ h  o6 [
27.     socket.on('chat message', (msg)=>{
    
28.       appendEle(msgList, msg)
    2 E! ]* \& `$ L+ o% q: G
29.     })
    
30.   }
    
31. 
    % T* b% p( v" W
32.   window.onload = ()=>{
    & O9 L3 s5 g, E
33.     let msgForm = document.querySelector('#msgForm')
    
34.     let msgBox = document.querySelector('#m')
    1 a) c' v: o1 j, O7 V$ z9 ?! ~
35.     let msgList = document.querySelector('#messages')
      d, W8 u" z3 u; X/ Y7 ?7 l. q* N
36.     socketIO(msgForm, msgBox, msgList)
    4 T9 h% B; R/ j
37.   }
      ]7 q, R0 X8 c3 p* _$ W9 [
38. </script>

复制代码

服务端实现：

1. const app = require('express')()
   
2. const http = require('http').Server(app)
   # A6 C2 j! a8 ]2 f; V5 o$ I: W
3. const io = require('socket.io')(http)
   4 B1 J5 }5 [' a, U7 H
4. 
   . F; I1 @' U# Q9 ^
5. app.get('/', (req, res)=> {
   
6.   res.sendFile(__dirname + '/index.html')
   2 e" E+ Z; W2 I* s
7. })
   $ e  v0 i6 J# P3 T0 P
8. 
   5 ~6 M# @7 Y1 O/ Q$ |( z4 [8 n6 X
9. io.on('connection', socket=>{
   
10.   console.log('a user connected')
    6 _  ?  \, l$ T. C# w9 i& [9 `' j
11.   socket.on('disconnect', ()=>{
    
12.     console.log('user disconnect')
    8 ~) J/ ^. v+ |* I+ C, O
13.   })
    
14.   socket.on('chat message', (msg)=>{
    
15.     console.log('clien get message: ', msg)
    5 C) e& M6 v: x) G8 r
16.     setTimeout(()=>{
    + q/ G; m4 [/ X4 J4 _9 b
17.       io.emit('chat message', '<b>Server:</b>' + ' Are you Sure? -- Come from your father')
    
18.     }, 1500)
    
19.   })
    " P( A4 b. Z5 q
20. })
    ) D! F+ Z% ^" J; g. k% j1 Z
21. 
    
22. http.listen(3000, ()=> {
    1 w$ a" ]3 [- n4 _: J8 O0 ^& A& D& B
23.   console.log('Server running at 3000.')
    
24. })

复制代码

WebSocket 的浏览器支持程序为 IE10+， Android 4.4+，所以，如果不是 淘宝那样量级超大的产品，应该都可以使用 这项应该不算是新技术的技术了。