首页 > PHP资讯 > HTML5培训技术 > WebSocket使用初探(Tornado+Nginx)

WebSocket使用初探(Tornado+Nginx)

HTML5培训技术

  使用场景

 

  在web开发中有时候需要实时获取数据,可以采用的方法也很多,比如ajax轮询,长连接等。之前项目中有一个需求是实时的日志展示,实时性要求高

  还有根据历史监控数据进行趋势图的绘制,数据量巨大,等待时间长。那么如果使用http请求来处理则面临着超时的问题,如果用ajax频繁的轮询将对服务器造成很大的压力。websocket提供了客户端和服务器进行双向实时的全双工通信的方法。并且绝大多数现代浏览器都支持websocket,因此需要使用nginx对websocket服务进行反代和负载均衡,nginx从1.3版本后开始支持websocket。项目用到的tornado框架也原生支持websocket,看来可以尝试用websocket来尝试解决问题。

 

  Tornado的支持

 

  tornado对websocket支持的很好,通过继承tornado.websocket.WebSocketHandler类就可以实现对websocket连接的处理。websocket是在标准

  http上实现的,websocket中的握手和http中的握手兼容,它使用http中的Upgrade协议头将连接从http升级到WebSocket,从源码上可以看出

  WebSocketHandler继承了tornado.web.RequestHandler,因此websocket也可以通过get_argument方法获取ws://URL?**=传来的参数。

  WebSocketHandler提供了一系列方法用以处理连接和消息收发,源码中的docstring描述得很清楚,源码是最好的文档没有之一。

  class WebSocketHandler(tornado.web.RequestHandler):

01 class WebSocketHandler(tornado.web.RequestHandler):
02 """Subclass this class to create a basic WebSocket handler.
03  
04 Override `on_message` to handle incoming messages, and use
05 `write_message` to send messages to the client. You can also
06 override `open` and `on_close` to handle opened and closed
07 connections.
08  
09 See http://dev.w3.org/html5/websockets/ for details on the
10 JavaScript interface.  The protocol is specified at
11 http://tools.ietf.org/html/rfc6455.
12  
13 Here is an example WebSocket handler that echos back all received messages
14 back to the client:
15  
16 .. testcode::
17  
18   class EchoWebSocket(tornado.websocket.WebSocketHandler):
19       def open(self):
20           print("WebSocket opened")
21  
22       def on_message(self, message):
23           self.write_message(u"You said: " + message)
24  
25       def on_close(self):
26           print("WebSocket closed")
27  
28 .. testoutput::
29    :hide:
30  
31 ...

 

  Nginx配置反向代理和负载均衡

01 upstream tornadoes {
02     server 127.0.0.1:7000;
03     server 127.0.0.1:7001;
04 }
05  
06 server {
07     listen 8000;
08     server_name ***.com;
09  
10     location / {
11         proxy_pass http://tornadoes;
12         proxy_http_version 1.1;
13         proxy_set_header Upgrade $http_upgrade;
14         proxy_set_header Connection "Upgrade";
15     }
16 }

南京HTML5课程

本文由欣才IT学院整理发布,未经许可,禁止转载。