使用场景
在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. |
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 |
10 |
JavaScript interface . The protocol is specified at |
13 |
Here is an example WebSocket handler that echos back all received messages |
18 |
class EchoWebSocket(tornado.websocket.WebSocketHandler): |
20 |
print( "WebSocket opened" ) |
22 |
def on_message(self, message): |
23 |
self.write_message(u "You said: " + message) |
26 |
print( "WebSocket closed" ) |
Nginx配置反向代理和负载均衡
02 |
server 127.0.0.1:7000; |
03 |
server 127.0.0.1:7001; |
12 |
proxy_http_version 1.1; |
13 |
proxy_set_header Upgrade $http_upgrade ; |
14 |
proxy_set_header Connection "Upgrade" ; |
南京HTML5课程