真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH

這篇文章主要講解了“如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH”,文中的講解內(nèi)容簡(jiǎn)單清晰,易于學(xué)習(xí)與理解,下面請(qǐng)大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH”吧!

“只有客戶發(fā)展了,才有我們的生存與發(fā)展!”這是創(chuàng)新互聯(lián)公司的服務(wù)宗旨!把網(wǎng)站當(dāng)作互聯(lián)網(wǎng)產(chǎn)品,產(chǎn)品思維更注重全局思維、需求分析和迭代思維,在網(wǎng)站建設(shè)中就是為了建設(shè)一個(gè)不僅審美在線,而且實(shí)用性極高的網(wǎng)站。創(chuàng)新互聯(lián)對(duì)網(wǎng)站建設(shè)、成都做網(wǎng)站、網(wǎng)站制作、網(wǎng)站開發(fā)、網(wǎng)頁設(shè)計(jì)、網(wǎng)站優(yōu)化、網(wǎng)絡(luò)推廣、探索永無止境。

Flask 框架中如果想要實(shí)現(xiàn)WebSocket功能有許多種方式,運(yùn)用SocketIO庫來實(shí)現(xiàn)無疑是最簡(jiǎn)單的一種方式,F(xiàn)lask中封裝了一個(gè)flask_socketio庫該庫可以直接通過pip倉庫安裝,如下內(nèi)容將重點(diǎn)簡(jiǎn)述SocketIO庫在Flask框架中是如何被應(yīng)用的,最終實(shí)現(xiàn)WebSSH命令行終端功能,其可用于在Web瀏覽器內(nèi)實(shí)現(xiàn)SSH命令行執(zhí)行。

首先我們先來看一下SocketIO庫是如何進(jìn)行通信的,對(duì)于前端部分需要引入socket.io這個(gè)框架,然后就是利用該框架內(nèi)提供的各類函數(shù)實(shí)現(xiàn)創(chuàng)建WS通道,如下代碼:

代碼中通過調(diào)用io.connect來連接后端,socket.emit則是用于向后端推送一條消息,而socket.on則是一個(gè)回調(diào)函數(shù),一旦有數(shù)據(jù)被傳出則第一時(shí)間執(zhí)行回調(diào)函數(shù)內(nèi)的代碼。




    
    
    



    $(document).ready(function() {
        namespace = '/Socket';
        var socket = io.connect("http://" + document.domain + ":" + location.port + namespace);

        // 初始化完成后,發(fā)送一條消息
        socket.emit("message",{"data":"hello lyshark"});

        // 收到數(shù)據(jù)后,執(zhí)行輸出
        socket.on('response', function(recv) {
            console.log('hello lyshark ' + recv.Data)
        });
    });


接著就是后端,后端部分代碼如下所示,代碼中app.config['SECRET_KEY']是配置一個(gè)安全密鑰這里可以隨意填寫,通過socketio = SocketIO(app)初始化一個(gè)SOCKET對(duì)象,當(dāng)有消息出現(xiàn)時(shí)SocketIO會(huì)自動(dòng)執(zhí)行相應(yīng)的處理函數(shù),常見的處理方法也就如下這三種。

  • message 出現(xiàn)消息后,率先執(zhí)行此處

  • connect 當(dāng)websocket連接成功時(shí),自動(dòng)觸發(fā)connect默認(rèn)方法

  • disconnect 當(dāng)websocket連接失敗時(shí),自動(dòng)觸發(fā)disconnect默認(rèn)方法

from flask import Flask,render_template,request
from flask_socketio import SocketIO

async_mode = None

app = Flask(import_name=__name__,
            static_url_path='/python',   # 配置靜態(tài)文件的訪問url前綴
            static_folder='static',      # 配置靜態(tài)文件的文件夾
            template_folder='templates') # 配置模板文件的文件夾

app.config['SECRET_KEY'] = "lyshark"
socketio = SocketIO(app)

@app.route("/")
def index():
    return render_template("index.html")

# 出現(xiàn)消息后,率先執(zhí)行此處
@socketio.on("message",namespace="/Socket")
def socket(message):
    print("接收到消息:",message['data'])

    for i in range(1,100):
        socketio.sleep(1)
        socketio.emit("response",           # 綁定通信
                      {"Data":i},           # 返回socket數(shù)據(jù)
                      namespace="/Socket")

# 當(dāng)websocket連接成功時(shí),自動(dòng)觸發(fā)connect默認(rèn)方法
@socketio.on("connect",namespace="/Socket")
def connect():
    print("鏈接建立成功..")

# 當(dāng)websocket連接失敗時(shí),自動(dòng)觸發(fā)disconnect默認(rèn)方法
@socketio.on("disconnect",namespace="/Socket")
def disconnect():
    print("鏈接建立失敗..")

if __name__ == '__main__':
    socketio.run(app,debug=True,host="0.0.0.0")

如上就是前后端所有的代碼,當(dāng)我們運(yùn)行Flask后端時(shí),打開前端頁面并查看控制臺(tái),可以看到效果,后臺(tái)會(huì)每隔一段時(shí)間自動(dòng)向前端推送一個(gè)消息此時(shí)這個(gè)通道也算是建立成功了。

如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH

原理明白了以后,再去實(shí)現(xiàn)一個(gè)WebSSH終端就會(huì)變得很容易,WebSSH終端我們需要xterm這個(gè)前端庫來實(shí)現(xiàn),其原理就是當(dāng)后臺(tái)有數(shù)據(jù)輸出或前臺(tái)有輸入時(shí)第一時(shí)間傳遞給SSH模塊執(zhí)行然后返回結(jié)果,我們先來看前端部分是如何實(shí)現(xiàn)這段功能的。




    
    
    
    
    
    


    
    

上方代碼中當(dāng)鏈接SOCKET成功后,則socket.on("response",function(recv)用于接收后臺(tái)的輸出,一旦后臺(tái)有輸出數(shù)據(jù)則直接調(diào)用term.write(recv.Data);將該數(shù)據(jù)寫出到控制臺(tái),而term.on則是xterm中提供的接收方法,其作用是接收用戶的輸入并將該輸入傳遞給后臺(tái)來處理。

那后臺(tái)是如何處理的呢,其實(shí)后端只是使用paramiko模塊建立一個(gè)SSH隧道,并在message函數(shù)內(nèi)處理發(fā)送接收數(shù)據(jù)。

from flask import Flask,render_template,request
from flask_socketio import SocketIO
import paramiko

async_mode = None
app = Flask(import_name=__name__,
            static_url_path='/python',   # 配置靜態(tài)文件的訪問url前綴
            static_folder='static',      # 配置靜態(tài)文件的文件夾
            template_folder='templates') # 配置模板文件的文件夾

app.config['SECRET_KEY'] = "lyshark"
socketio = SocketIO(app)

def ssh_cmd():
    tran = paramiko.Transport(('192.168.150.129', 22,))
    tran.start_client()
    tran.auth_password('root', '1233')
    chan = tran.open_session()
    chan.get_pty(height=492,width=1312)
    chan.invoke_shell()
    return chan

sessions = ssh_cmd()

@app.route("/")
def index():
    return render_template("index.html")

# 出現(xiàn)消息后,率先執(zhí)行此處
@socketio.on("message",namespace="/Socket")
def socket(message):
    print("接收到消息:",message)
    sessions.send(message)
    ret = sessions.recv(4096)
    socketio.emit("response", {"Data": ret.decode("utf-8")}, namespace="/Socket")
    print(message)

# 當(dāng)websocket連接成功時(shí),自動(dòng)觸發(fā)connect默認(rèn)方法
@socketio.on("connect",namespace="/Socket")
def connect():
    ret = sessions.recv(4096)
    socketio.emit("response", {"Data": ret.decode("utf-8")}, namespace="/Socket")
    print("鏈接建立成功..")

# 當(dāng)websocket連接失敗時(shí),自動(dòng)觸發(fā)disconnect默認(rèn)方法
@socketio.on("disconnect",namespace="/Socket")
def disconnect():
    print("鏈接建立失敗..")

if __name__ == '__main__':
    socketio.run(app,debug=True,host="0.0.0.0")

代碼運(yùn)行后我們?cè)L問Web頁面,即可成功登錄到Linux主機(jī),并執(zhí)行任意命令。

如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH

當(dāng)執(zhí)行輸出目錄時(shí)也是帶有顏色的,顏色的上色部分是xterm中自帶的并不需要自己去配置。

如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH

感謝各位的閱讀,以上就是“如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對(duì)如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH這一問題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián),小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!


網(wǎng)站名稱:如何運(yùn)用SocketIO實(shí)現(xiàn)WebSSH
當(dāng)前網(wǎng)址:http://weahome.cn/article/gcepdc.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部