博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Tornado的WebSocket
阅读量:3962 次
发布时间:2019-05-24

本文共 1465 字,大约阅读时间需要 4 分钟。

WebSocket简介

WebSocket是HTML5规范中新提出的客户端-服务器通信协议,协议本身使用新的ws://URL格式。

WebSocket 是独立的、创建在 TCP 上的协议,和 HTTP 的唯一关联是使用 HTTP 协议的101状态码进行协议升级,使用的 TCP 端口是80,可以用于绕过大多数防火墙的限制。

WebSocket 使得客户端和服务器之间的数据交换变得更加简单,允许服务端直接向客户端主动推送数据而不需要客户端进行再次请求,两者之间可以创建持久性连接,并允许数据进行双向通信。

Tornado提供支持WebSocket的模块是tornado.websocket,其中提供了一个WebSocketHandler类用来处理通讯。

常用方法

open()

当一个WebSocket连接建立后被调用。

on_message(message)

当客户端发送消息message过来时被调用,注意此方法必须被重写。

on_close()

当WebSocket连接关闭后被调用。

write_message(message, binary=False)

向客户端发送消息messagea,message可以是字符串或字典(字典会被转为json字符串)。若binary为False,则message以utf8编码发送;二进制模式(binary=True)时,可发送任何字节码。

close()

关闭WebSocket连接。

check_origin(origin)

判断源origin,对于符合条件(返回判断结果为True)的请求源origin允许其连接,否则返回403。可以重写此方法来解决WebSocket的跨域请求(如始终return True)。

from tornado import web,ioloopfrom tornado.websocket import WebSocketHandlerclass Index(web.RequestHandler):    def get(self):        self.render("templates/index.html")class Home(WebSocketHandler):    def open(self):        #         self.write_message("欢迎来到socket.html")    def on_message(self, message):        print("接收数据:%s" % message)    def on_close(self):        print("socket连接断开")    def check_origin(self, origin):        return True  # 允许WebSocket的跨域请求# 设置路由列表urls = [    (r"/", Index),    (r"/home", Home),]if __name__ == "__main__":    # 创建应用实例对象    app = web.Application(urls, debug=True)    # 设置监听的端口和地址    app.listen(port=8888)    # ioloop,全局的tornado事件循环,是服务器的引擎核心,start表示创建IO事件循环    ioloop.IOLoop.current().start()
    

转载地址:http://nwhzi.baihongyu.com/

你可能感兴趣的文章