業(yè)務流程圖如下

效果圖展示

1.django安裝websocket模塊

pip install dwebsocket

2.shell腳本

用來傳遞不同的行號輸出不同的內(nèi)容;
第一個參數(shù)為0的時候,默認輸出最后200行內(nèi)容
第一個參數(shù)為其余數(shù)字時候,和總行數(shù)比較,取差值內(nèi)容

#!/bin/bash LOGDIR=/export/Instances/*/*/logs/ LineNum=$1 CatalinaLogFilename=`ls -lrt $LOGDIR | grep catalina.out | tail -1 | awk '{print $NF}'` LocalhostLogFilename=`ls -lrt $LOGDIR | grep localhost | tail -1 | awk '{print $NF}'`CatalinaLogFullFilename="${LOGDIR}${CatalinaLogFilename}" LocalhostLogFullFilename="${LOGDIR}${LocalhostLogFilename}"#echo $CatalinaLogFullFilename #echo $LocalhostLogFullFilename getLogContent(){wc -l ${CatalinaLogFullFilename} | awk '{print $1}'echo '###########################Catalina.out#######################################'/usr/bin/tail -200 ${CatalinaLogFullFilename} } if [ -z $LineNum ];thengetLogContent elif [ $LineNum -eq 0 ];thengetLogContent elsetotalNum=`wc -l ${CatalinaLogFullFilename} | awk '{print $1}'`let catNum=totalNum-LineNumif [ $catNum -ne 0 ];thenecho $totalNum/usr/bin/tail -${catNum} ${CatalinaLogFullFilename}fi fi

3.django后臺試圖函數(shù)

views.py對應了/index/websocket_demo/函數(shù)處理
應用名字叫做app

from dwebsocket import require_websocket os.environ.setdefault("DJANGO_SETTINGS_MODULE", "app.settings")'''websokcet測試函數(shù)接收用戶發(fā)送過來的IP數(shù)''' require_websocket def websocket_demo(request):flag = True# num用作判斷是不是第一次請求,取最后200行內(nèi)容的判斷num = 0line_num = 0while flag:# read方法是非阻塞的方法,所以每3秒收集一次,防止前端掛掉message = request.websocket.read()# 客戶端發(fā)過來的是close的話關(guān)閉websocket連接if message == 'close':flag = False# 關(guān)閉連接request.websocket.close()break#message = request.websocket.wait()# 如果客戶端沒發(fā)送數(shù)據(jù),就是None,再判斷是否num 為1,為1代表第一次讀數(shù)據(jù)已讀過elif not message:if num != 1:passelse:print '捕獲更新日志開始'from CeleryTasks import ansible_playinstance = ansible_play.Ansible_Playbook(3,[ip,])print line_numresult = instance.script_shell('/export/App/DevOPS/Python_20160906/CeleryTasks/tomcatLog.sh %s'%line_num)if result:line_num = result.split('\n')[0].strip()request.websocket.send(str(result))else:passprint '捕獲更新日志結(jié)束'else:# 第一次請求取最后200行內(nèi)容,此時line_num為0num = 1ip = messageprint '捕獲初始日志開始'#request.websocket.send('return')from CeleryTasks import ansible_playinstance = ansible_play.Ansible_Playbook(3,[ip,])print line_numresult = instance.script_shell('/export/App/DevOPS/Python_20160906/CeleryTasks/tomcatLog.sh %s'%line_num) # print result.split('\n')line_num = result.split('\n')[0].strip() # #message = request.websocket.wait() # #print messagerequest.websocket.send(str(result))print '捕獲初始日志結(jié)束' # time.sleep(5) # request.websocket.close() # breaktime.sleep(3)

4.前端頁面

$(function() {t=null;// connection全局,關(guān)閉彈窗作用,websocket關(guān)閉操作時候connection=null;// 連接成功后,置為trueflag=false;// 關(guān)閉模態(tài)框調(diào)用的函數(shù)$('#myModal').on('hide.bs.modal',function() {//alert('嘿，我聽說您喜歡模態(tài)框...');if(t == null){}else{clearInterval(t); }//clearInterval(t);$('.modal-footer').empty();if(connection == null){}else{// 關(guān)閉websocket連接connection.send('close');}}) });//pre標簽外部的div標簽,實現(xiàn)彈窗的滾輪一直在下面 function Setdeep(){$('.modal-body').scrollTop($('.modal-body')[0].scrollHeight); }/*下面定義一些函數(shù),用做websocket的連接相關(guān) */ // 發(fā)送關(guān)閉websocket命令函數(shù) function wsClose () {connection.send('close');console.log("Closed"); } // 收到callback函數(shù)回調(diào),插入內(nèi)容 function wsMessage (event) {$('.modal-body').find('pre').append('<code class="avrasm">' + event.data + '</code>');Setdeep(); } // 連接成功,調(diào)用函數(shù)回調(diào),flag置為true function wsOpen (event,ip) {flag = true;console.log('Connected to: ' + event.currentTarget.URL);//connection.send('10.187.109.116'); } // websocket異常報錯console輸出 function wsError(event) {console.log("Error: " + event.data); }//Tomcat日志查看清理函數(shù),彈窗 function tomcatLog(ths){//if( connection == null ){}else{connection.send('close');}$('#myModal').find('.modal-dialog').removeClass('modal-sm');$('#myModal').find('.modal-dialog').addClass('modal-lg');var ip = $(ths).parents('tr').find("td:first").text();$('#myModal').find('.modal-body').removeClass('hide');$('#myModal').find('.modal-body').empty();$('#myModal').find('.modal-body').css("height","750px");$('.modal-footer').empty();$('#myModal').find('.modal-body').append('<img src="/static/image/loading.gif"></img>');$('#myModalLabel').text(ip + ' Tomcat日志');$('.modal-body').append('<pre>' + '<code class="avrasm">' + '</code>' + '</pre>');// 建立websocket連接,ws是標簽協(xié)議,目前nginx上還沒更改;connection = new WebSocket('ws://10.187.196.225:65535/index/websocket_demo/');connection.onopen = wsOpen;connection.onclose = wsClose;connection.onmessage = wsMessage;connection.onerror = wsError;// 每2秒判斷一下是否成功連接上了setInterval(function(){if(flag){$('.modal-body').find('img').remove();connection.send(ip);// 連接置位符置位false,防止頻繁發(fā)送數(shù)據(jù)給服務器,主要服務器推數(shù)據(jù)flag = false;$('.modal-footer').append('<button type="button" class="btn btn-danger" onclick="wsClose();buttonDisabled(this);">關(guān)閉實時刷新</button>')$('.modal-footer').append('<button type="button" class="btn btn-default" onclick="dowlandTomcatLog(this);">下載日志文件</button>');}},2000); }//獲取pre標簽的中內(nèi)容給用戶下載 function dowlandTomcatLog(ths){var tomcatLogContent = $('.modal-body').find('pre').first().text();var blob = stringToBlob(tomcatLogContent);//var blob = stringToBlob('hello jd.com\r\nhello baidu.com');download('tomcatLog.txt', blob); } /* fileName: 默認下載文件名 blob: 下載Blob對象 */ function download(fileName, blob){var aLink = document.createElement('a');var evt = document.createEvent("MouseEvents");evt.initEvent('click', true, false, window, 0, 0, 0, 0, 0, false, false, false, false, 0, null);aLink.download = fileName;aLink.href = URL.createObjectURL(blob);aLink.dispatchEvent(evt); }/* 文本轉(zhuǎn)Blob對象 */ function stringToBlob(text) {var arr_text = text.split("\n");for (var i = 0;i<arr_text.length;i++){arr_text[i] = arr_text[i] + '\r\n';}var blob = new Blob([arr_text],{type : 'text/html'});return blob; }

轉(zhuǎn)載于:https://www.cnblogs.com/PythonOrg/p/6519409.html

總結(jié)

以上是生活随笔為你收集整理的websocket 和 ansible配合Tomcat实时日志给前端展示的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。