一、主题：实时展示服务器端动态生成的日志文件
二、流程：
1. 客户端浏览器与服务器建立websocket 链接，服务器挂起保存链接实例，等待新内容触发返回动作
2. 日志服务器脚本循环去发现新内容，发现新行向 tornado等待api post 发送新内容
3. tornado 处理器接收到新内容， 通过 websocket 向保存的客户端链接返回新行
4. 客户端浏览器接收到新内容，修饰，展示
三、代码：
1. tornado服务器url路由、基本页面handler 及 html：
#模块路径根据自身项目而定
(r’/logs/index/’, ‘apps.logs.handler.indexhandler’),
(r’/logs/newlinesforcallbacker/’, ‘apps.logs.handler.writenewlineshandler’),
(r’/logs/newlinesforserver/’, ‘apps.logs.handler.receivenewlineshandler’),class indexhandler(basehandler):
”’ 主页 ”’
def get(self, *args, **kwargs):
self.render(‘logs/index.html’)
this logs monitor
2. 服务器端websocket handler (writenewlineshandler) 、 保存删除链接处理类 及客户端websocket请求 js
class prostatus(object):
”’ 处理类 ”’
w_register = []
def register(self, callbacker):
”’ 记录客户端连接实例 ”’
self.w_register.append(callbacker)
def unregister(self, callbacker):
”’ 删除客户端连接实例 ”’
self.w_register.remove(callbacker)
def makelines(self, lines):
”’ 处理接受的行内容 ”’
pass
def trigger(self, line):
”’ 向所有被记录客户端发送最新内容 ”’
pass
class writenewlineshandler(tornado.websocket.websockethandler):
”’ 接受websocket链接，保存链接实例 ”’
def check_origin(self, origin): #针对websocket处理类重写同源检查的方法
return true
def open(self):
”’ 处理新的连接 ”’
prostatus().register(self)
def on_close(self):
prostatus().unregister(self) #删除客户端连接
def on_message(self, message):
pass$(function(){
function requesttext(){
host = “ws://” + location.hostname + “:” + location.port + “/logs/newlinesforcallbacker/”
websocket = new websocket(host)
websocket.onopen = function(evt){} // 建立连接
websocket.onmessage = function(evt){ // 获取服务器返回的信息
data = $.parsejson(evt.data)
$(“#main”).append(data+””) //写入页面
}
websocket.onerror = function(evt){}
}
requesttext()
})
3. tornado 等待脚本提交新内容处理handler(receivenewlineshandler)、 向挂起客户端发送新内容函数 及 遍历日志提交新内容脚本
class prostatus(object):
”’ 处理类 ”’
w_register = []
def register(self, callbacker):
”’ 记录客户端连接实例 ”’
pass
def unregister(self, callbacker):
”’ 删除客户端连接实例 ”’
pass
def makelines(self, lines):
”’ 处理接受的行内容 ”’
for line in lines:
self.trigger(line)
def trigger(self, line):
”’ 向所有被记录客户端发送最新内容 ”’
for callabler in self.w_register:
callabler.write_message(json.dumps(line))
class receivenewlineshandler(basehandler):
”’ 接受服务器端脚本提交的最新行内容 ”’
def post(self, *args, **kwargs):
linesdata = self.get_argument(‘lines’, ”)
#print type(json.loads(linesdata))
prostatus().makelines(json.loads(linesdata))#-*-coding:utf-8-*-
author = ‘zhouwang’
import time
import urllib
import urllib2
import json
p = 0
while true:
f = open(‘logs.txt’, ‘r+’)
f.seek(p, 0) #偏移到上次结束位置
lines = f.readlines()
if lines:
#对行内容操作, 向服务器发送最新行内容
data = urllib.urlencode({‘lines’:json.dumps(lines)})
url = ‘http://localhost:8800/logs/newlinesforserver/’
req = urllib2.request(url, data)
res_data = urllib2.urlopen(req)
#print res_data.read()
#获取当前位置，作为偏移值
p = f.tell()
f.close()
time.sleep(1)
以上就是python tornado websocket实时日志展示的实例代码的详细内容，更多请关注 第一php社区 其它相关文章！