首頁  >  文章  >  後端開發  >  python tornado websocket即時日誌展示的實例程式碼

python tornado websocket即時日誌展示的實例程式碼

高洛峰
高洛峰原創
2017-03-21 13:41:491994瀏覽

一、主題:即時展示伺服器端動態產生的日誌檔案

二、流程

  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')
<div align="center">
    <h2>this logs monitor</h2>
    <div style="width: 70%" id="main">
    <!-- 行展示 -->
    </div>
</div>

2. 伺服器端websocket handler (WriteNewLinesHandler) 、 儲存刪除連結處理類別及客戶端websocket請求js

#
class ProStatus(object):
    &#39;&#39;&#39; 处理类 &#39;&#39;&#39;

    w_register = []

    def register(self, callbacker):
        &#39;&#39;&#39; 记录客户端连接实例 &#39;&#39;&#39;
        self.w_register.append(callbacker)

    def unregister(self, callbacker):
        &#39;&#39;&#39; 删除客户端连接实例 &#39;&#39;&#39;
        self.w_register.remove(callbacker)

    def makelines(self, lines):
        &#39;&#39;&#39; 处理接受的行内容 &#39;&#39;&#39;
        pass

    def trigger(self, line):
        &#39;&#39;&#39; 向所有被记录客户端发送最新内容 &#39;&#39;&#39;
       pass

class WriteNewLinesHandler(tornado.websocket.WebSocketHandler):
    &#39;&#39;&#39; 接受websocket链接,保存链接实例 &#39;&#39;&#39;
    def check_origin(self, origin):     #针对websocket处理类重写同源检查的方法
        return True

    def open(self):
        &#39;&#39;&#39; 处理新的连接  &#39;&#39;&#39;
        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+"</br>")     //写入页面
                }
                websocket.onerror = function(evt){}
            }

            requestText()
})

3. tornado 等待腳本提交新內容處理handler(ReceiveNewLinesHandler)、 向掛起客戶端發送新內容函數 及遍歷日誌提交新內容腳本

class ProStatus(object):
    &#39;&#39;&#39; 处理类 &#39;&#39;&#39;

    w_register = []

    def register(self, callbacker):
        &#39;&#39;&#39; 记录客户端连接实例 &#39;&#39;&#39;
        pass

    def unregister(self, callbacker):
        &#39;&#39;&#39; 删除客户端连接实例 &#39;&#39;&#39;
        pass

    def makelines(self, lines):
        &#39;&#39;&#39; 处理接受的行内容 &#39;&#39;&#39;
        for line in lines:
            self.trigger(line)

    def trigger(self, line):
        &#39;&#39;&#39; 向所有被记录客户端发送最新内容 &#39;&#39;&#39;
        for callabler in self.w_register:
            callabler.write_message(json.dumps(line))

class ReceiveNewLinesHandler(BaseHandler):
    &#39;&#39;&#39; 接受服务器端脚本提交的最新行内容 &#39;&#39;&#39;
    def post(self, *args, **kwargs):
        linesdata = self.get_argument(&#39;lines&#39;, &#39;&#39;)
        #print type(json.loads(linesdata))
        ProStatus().makelines(json.loads(linesdata))
#-*-coding:utf-8-*-
author = &#39;zhouwang&#39;
import time
import urllib
import urllib2
import json

p = 0
while True:
    f = open(&#39;logs.txt&#39;, &#39;r+&#39;)
    f.seek(p, 0)    #偏移到上次结束位置

    lines = f.readlines()

    if lines:
        #对行内容操作, 向服务器发送最新行内容
        data = urllib.urlencode({&#39;lines&#39;:json.dumps(lines)})
        url = &#39;http://localhost:8800/logs/newlinesforserver/&#39;
        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中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn