Tornado是一个异步Python框架,最初由FriendFeed发起并开源,目前由Facebook维护,非常适合实时做Web应用。
Redis是一个NoSQL数据库,常用于做缓存系统,这里主要用到了它的Pub/Sub功能。即当一个用户发送一条消息时,所有的用户都会收到消息。
关于什么是Ajax长轮询(Comet)不再介绍
我是参照the5fire的一篇博客来组织项目源码的:http://www.the5fire.com/tornado-mvc-helloworld-2.html
当Tornado收到浏览器的消息时,将这条消息publish到Redis里,所有的subscriber就都会收到通知。
def post(self) : #接受POST请求
name = self.get_secure_cookie('name')
msg = self.get_argument('msg', '')
if name == '':
name = 'Anonymous'
data=json_encode({'name':name, 'msg':msg})
c.publish('test_channel', data) #收到将消息publish到Redis
self.write(json_encode({'result':True}));
self.finish();
将Tornado超时时间设置为60s,如果在60s内,收到了Redis的消息,就把消息发送给浏览器;如果60s超时了,则发送一条msg为空的消息给浏览器。
import time
import tornado.web
import tornado.gen
import tornadoredis
from tornado.escape import json_encode
from model.entity import Entity
class LongPollingHandler(tornado.web.RequestHandler):
def initialize(self):
self.client = tornadoredis.Client()
self.client.connect() #连接到Redis
@tornado.web.asynchronous
def get(self):
self.get_data()
@tornado.web.asynchronous
def post(self):
self.get_data()
@tornado.gen.engine
def subscribe(self): #订阅Redis的消息
yield tornado.gen.Task(self.client.subscribe, 'test_channel')
self.client.listen(self.on_message)
def get_data(self):
if self.request.connection.stream.closed():
return
self.subscribe()
num = 60 #设置超时时间为60s
tornado.ioloop.IOLoop.instance().add_timeout(
time.time()+num,
lambda: self.on_timeout(num)
)
def on_timeout(self, num):
self.send_data(json_encode({'name':'', 'msg':''}))
if (self.client.connection.connected()):
self.client.disconnect()
def send_data(self, data): #发送响应
if self.request.connection.stream.closed():
return
self.set_header('Content-Type', 'application/json; charset=UTF-8')
self.write(data)
self.finish()
def on_message(self, msg): #收到了Redis的消息
if (msg.kind == 'message'):
self.send_data(str(msg.body))
elif (msg.kind == 'unsubscribe'):
self.client.disconnect()
def on_finish(self):
if (self.client.subscribed):
self.client.unsubscribe('test_channel');
浏览器JavaScript代码如下,每当服务器返回结果以后,就立即再发送一个请求到服务器。因为空闲的时候,服务器要等60s才会有响应,所以这并不会消耗很多资源。
var updater = {
poll: function(){
$.ajax({url: "/longpolling",
type: "POST",
dataType: "json",
success: updater.onSuccess,
error: updater.onError});
},
onSuccess: function(data, dataStatus){
try{
if (data.msg != "") {
$("p").append(data.name+": " + data.msg + "<br />");
}
}
catch(e){
updater.onError(e);
return;
}
updater.poll(); //收到响应后立即再发一条请求
},
onError: function(e){
if (e.message)
console.log("Poll Error" + e.message);
else
console.log(e);
}
};
updater.poll();
全部代码参见我的git:https://github.com/wylazy/tornado-chat
分享到:
相关推荐
资源分类:Python库 所属语言:Python 资源全名:tornado-redis-session-0.1.3.tar.gz 资源来源:官方 安装方法:https://lanzao.blog.csdn.net/article/details/101784059
龙卷风-redis 简单的异步 Tornado-redis 连接器 去做: 处理与 ioloop.WRITE 的连接 处理第二次和更多读取操作
NULL 博文链接:https://edisonlz.iteye.com/blog/1679114
龙卷风重演基于Redis的服务器端会话中间件安装pip install tornado-redis-session用法 from tornado . httpserver import HTTPServerfrom tornado . ioloop import IOLoopfrom tornado . web import authenticated ,...
龙卷风-重新聊天更多信息怎么跑 cd tornado-redis-chatdocker build -t chat .docker run --name some-redis -d redisdocker run --name some-app -p 8888:8888 --link some-redis:redis -d chat然后您可以转到 (对...
在全民编程的大环境下,学习编程的人与日俱增,而为开发者提供问答的社区也逐渐流行起来。例如,国外最著名技术问答社区 ...本章主要使用 Python中的轻量级异步框架 Tornado来实现一个类似 Stackoverflow的问答社区网站。
把酒言欢话聊天,基于Vue3.0+Tornado6.1+Redis发布订阅(pubsub)模式打造实时(websocket)通信聊天系统,非阻塞(aioredis)
一个基于Tornado/mongodb/redis的社区系统。特点 简单:去除传统社区中多数不常用到的功能,保留精华。(这里向 http://zone.wooyun.org 学习) 高效: mongodb:数据库设计合理,以空间换取时间,尽量减少数据库...
使用tornado作为服务器,qt作为客户端。部分代码来自网络,如有侵权,请联系删除。
Tomcat7 Ext4. WebSocket 聊天室,经过优化的,具有详细注释的,学习WebSocket的经典例子。
tornado_4.5.3.zip,网站开发框架,当redis-server.exe开启后,最新的tornado-redis不能开启,可尝试该版本
Tornado使用指南(中文版)
基于Python的博客使用tornado和bootstrap框架开发(螺壳网)
Tornado使用指南是学习使用Tornado编程的好资料,中文版的
本文介绍了tornado的安装和使用特点,适合初级入门者使用擦靠
tornado使用指南 tornado使用指南 tornado使用指南
Tornado_2.2使用指南(中文完全版)!!!
tornado使用技巧
教程:使用Tornado构建,测试和分析高效的微服务 0.获取源代码 获取该教程的源代码: $ git clone https://github.com/scgupta/tutorial-python-microservice-tornado.git $ cd tutorial-python-microservice-...
解决使用Tornado过程中不能启动simulator的补丁