小編給大家分享一下Django怎么實(shí)現(xiàn)WebSSH操作物理機(jī)或虛擬機(jī)，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！

創(chuàng)新互聯(lián)聯(lián)系電話(huà)：18980820575，為您提供成都網(wǎng)站建設(shè)網(wǎng)頁(yè)設(shè)計(jì)及定制高端網(wǎng)站建設(shè)服務(wù)，創(chuàng)新互聯(lián)網(wǎng)頁(yè)制作領(lǐng)域十多年，包括水處理設(shè)備等多個(gè)方面擁有豐富的網(wǎng)站運(yùn)維經(jīng)驗(yàn)，選擇創(chuàng)新互聯(lián)，為企業(yè)保駕護(hù)航。

WebSSH操作物理機(jī)或虛擬機(jī)

上篇文章給大家介紹詳解基于django實(shí)現(xiàn)的webssh簡(jiǎn)單例子，有小伙伴說(shuō)咖啡哥，我們現(xiàn)在還沒(méi)有用上Kubernetes，但我想通過(guò)瀏覽器連接我們的物理機(jī)和虛擬機(jī)該怎么辦？

這就比較簡(jiǎn)單了，既然我們已經(jīng)實(shí)現(xiàn)了瀏覽器操作Kubernetes的Pod，那么想想操作Pod和物理機(jī)虛擬機(jī)有什么區(qū)別呢？

整個(gè)數(shù)據(jù)流是一點(diǎn)沒(méi)變：用戶(hù)打開(kāi)瀏覽器--》瀏覽器發(fā)送websocket請(qǐng)求給Django建立長(zhǎng)連接--》Django與要操作的服務(wù)器建立SSH通道，實(shí)時(shí)的將收到的用戶(hù)數(shù)據(jù)發(fā)送給SSH后的主機(jī)，并將主機(jī)執(zhí)行的結(jié)果數(shù)據(jù)返回給瀏覽器

唯一不一樣的地方就是Django與要操作的服務(wù)器建立SSH通道的方式，在Kubernetes中是通過(guò)Kubernetes提供的API建立的Stream流，而操作物理機(jī)或者虛擬機(jī)的時(shí)候我們可以使用Paramiko模塊來(lái)建立SSH長(zhǎng)連接隧道，Paramiko模塊建立SSH長(zhǎng)連接通道的方法如下：

# 實(shí)例化SSHClient
ssh = paramiko.SSHClient()
# 當(dāng)遠(yuǎn)程服務(wù)器沒(méi)有本地主機(jī)的密鑰時(shí)自動(dòng)添加到本地，這樣不用在建立連接的時(shí)候輸入yes或no進(jìn)行確認(rèn)
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 連接SSH服務(wù)器，這里以賬號(hào)密碼的方式進(jìn)行認(rèn)證，也可以用key
ssh.connect(hostname=host, port=port, username=username, password=password, timeout=8)
# 打開(kāi)ssh通道，建立長(zhǎng)連接
transport = ssh.get_transport()
self.ssh_channel = transport.open_session()
# 獲取ssh通道，并設(shè)置term和終端大小
self.ssh_channel.get_pty(term=term, width=cols, height=rows)
# 激活終端，這樣就可以正常登陸了
self.ssh_channel.invoke_shell()

連接建立，可以通過(guò)如下方法給SSH通道發(fā)送數(shù)據(jù)

self.ssh_channel.send(data)

當(dāng)然SSH返回的數(shù)據(jù)也可以通過(guò)如下方法持續(xù)的輸出給Websocket

while not self.ssh_channel.exit_status_ready():
 # SSH返回的數(shù)據(jù)需要轉(zhuǎn)碼為utf-8，否則json序列化會(huì)失敗
 data = self.ssh_channel.recv(1024).decode('utf-8','ignore')
 if len(data) != 0:
 message = {'flag': 'success', 'message': data}
 self.websocket.send(json.dumps(message))
 else:
 break

有了這些信息，結(jié)合詳解基于django實(shí)現(xiàn)的webssh簡(jiǎn)單例子的文章，實(shí)現(xiàn)WebSSH瀏覽器操作物理機(jī)或者虛擬機(jī)就不算困難了，完整的Consumer代碼如下：

import io
import json
import paramiko
from threading import Thread
from channels.generic.websocket import WebsocketConsumer
from cmdb.backends.sshargs import args
class SSHBridge(object):
 def __init__(self, websocket):
 self.websocket = websocket
 def connect(self, host, port, username, authtype, password=None, pkey=None, term='xterm', cols=80, rows=24):
 ssh = paramiko.SSHClient()
 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
 try:
 if authtype == 2:
 pkey = paramiko.RSAKey.from_private_key(io.StringIO(pkey))
 ssh.connect(username=username, hostname=host, port=port, pkey=pkey, timeout=8)
 else:
 ssh.connect(hostname=host, port=port, username=username, password=password, timeout=8)
 except Exception as e:
 message = json.dumps({'flag': 'error', 'message': str(e)})
 self.websocket.send(message)
 return False
 # 打開(kāi)一個(gè)ssh通道并建立連接
 transport = ssh.get_transport()
 self.ssh_channel = transport.open_session()
 self.ssh_channel.get_pty(term=term, width=cols, height=rows)
 self.ssh_channel.invoke_shell()
 # 連接建立一次，之后交互數(shù)據(jù)不會(huì)再進(jìn)入該方法
 for i in range(2):
 recv = self.ssh_channel.recv(1024).decode('utf-8', 'ignore')
 message = json.dumps({'flag': 'success', 'message': recv})
 self.websocket.send(message)
 def close(self):
 try:
 self.websocket.close()
 self.ssh_channel.close()
 except BaseException as e:
 pass
 def _ws_to_ssh(self, data):
 try:
 self.ssh_channel.send(data)
 except OSError as e:
 self.close()
 def _ssh_to_ws(self):
 try:
 while not self.ssh_channel.exit_status_ready():
 data = self.ssh_channel.recv(1024).decode('utf-8', 'ignore')
 if len(data) != 0:
 message = {'flag': 'success', 'message': data}
 self.websocket.send(json.dumps(message))
 else:
 break
 except Exception as e:
 message = {'flag': 'error', 'message': str(e)}
 self.websocket.send(json.dumps(message))
 self.close()
 def shell(self, data):
 Thread(target=self._ws_to_ssh, args=(data,)).start()
 Thread(target=self._ssh_to_ws).start()
class SSHConsumer(WebsocketConsumer):
 def connect(self):
 self.pk = self.scope['url_route']['kwargs'].get('id')
 self.query = self.scope.get('query_string')
 self.user = self.scope['user']
 self.accept()
 # ssh_connect_args為SSH連接需要的參數(shù)
 ssh_connect_args = args(self.pk, self.user, self.query)
 self.ssh = SSHBridge(websocket=self)
 self.ssh.connect(**ssh_connect_args)
 def disconnect(self, close_code):
 self.ssh.close()
 def receive(self, text_data=None):
 text_data = json.loads(text_data)
 self.ssh.shell(data=text_data.get('data', ''))

動(dòng)態(tài)調(diào)整終端窗口大小

看了詳解基于django實(shí)現(xiàn)的webssh簡(jiǎn)單例子文章，小伙伴又說(shuō)了，你這只能在連接建立時(shí)確定終端窗口的大小，如果我中途調(diào)整了瀏覽器的大小，顯示就亂了，這該怎么辦？

不要著急，接下來(lái)就讓我們看看怎么讓終端窗口隨著瀏覽器大小的調(diào)整而改變，上邊的文章中已經(jīng)說(shuō)過(guò)，終端窗口的大小需要瀏覽器和后端返回的Terminal大小保持一致，單單調(diào)整頁(yè)面窗口大小或者后端返回的Terminal窗口大小都是不行的，那么從這兩個(gè)方向來(lái)說(shuō)明該如何動(dòng)態(tài)調(diào)整窗口的大小

首先Paramiko模塊建立的SSH通道可以通過(guò)resize_pty來(lái)動(dòng)態(tài)改變返回Terminal窗口的大小，使用方法如下：

def resize_pty(self, cols, rows):
 self.ssh_channel.resize_pty(width=cols, height=rows)

然后Django的Channels每次接收到前端發(fā)過(guò)來(lái)的數(shù)據(jù)時(shí)，判斷一下窗口是否有變化，如果有變化則調(diào)用上邊的方法動(dòng)態(tài)改變Terminal輸出窗口的大小

我在實(shí)現(xiàn)時(shí)會(huì)給傳過(guò)來(lái)的數(shù)據(jù)加個(gè)flag，如果flag是resize，則調(diào)用resize_pty的方法動(dòng)態(tài)調(diào)整窗口大小，否則就正常調(diào)用執(zhí)行命令的方法，代碼如下：

def receive(self, text_data=None):
 text_data = json.loads(text_data)
 if text_data.get('flag') == 'resize':
 self.ssh.resize_pty(cols=text_data['cols'], rows=text_data['rows'])
 else:
 self.ssh.shell(data=text_data.get('data', ''))

后端都搞定了，那么來(lái)看看前端如何處理吧

首先有一個(gè)terminal_size的方法根據(jù)瀏覽器窗口大小除以每個(gè)字符所占用的大小計(jì)算出cols和rows的值，無(wú)論是xterm.js還是Paramiko都是根據(jù)這兩個(gè)值來(lái)調(diào)整窗口大小的

function terminal_size() {
 return {
 cols: Math.floor($('#terminal').width() / 9),
 rows: Math.floor($(window).height() / 17),
 }
}

然后通過(guò)$(window).resize()來(lái)檢測(cè)瀏覽器窗口的變化，一旦發(fā)生變化，則發(fā)送一個(gè)帶resize標(biāo)記的數(shù)據(jù)給Django，同時(shí)傳遞的數(shù)據(jù)還有新的cols和rows

// terminal resize
$(window).resize(function () {
 let cols = terminal_size().cols;
 let rows = terminal_size().rows;
 send_data = JSON.stringify({
 'flag': 'resize',
 'cols': cols,
 'rows': rows
 });
 socket.send(send_data);
 term.resize(cols, rows)
})

最后通過(guò)term.resize來(lái)調(diào)整xterm渲染的窗口的大小

這樣一個(gè)完整的動(dòng)態(tài)調(diào)整窗口大小的方案就完成了

演示與源碼

我寫(xiě)了個(gè)簡(jiǎn)單的Demo來(lái)實(shí)現(xiàn)上邊的功能，Demo寫(xiě)完發(fā)現(xiàn)還挺好用，我就擴(kuò)展了一下添加了內(nèi)網(wǎng)的物理機(jī)和虛擬機(jī)，歷史原因，有些是賬號(hào)密碼認(rèn)證，有些是密鑰認(rèn)證，我都給兼容了一下，最終實(shí)現(xiàn)的效果如上圖所示

項(xiàng)目里邊要記錄主機(jī)的密碼，為了安全這個(gè)密碼是通過(guò)RSA加密存放在數(shù)據(jù)庫(kù)的，每次使用的時(shí)候進(jìn)行解密，加解密的實(shí)現(xiàn)，可參考這篇文章django 開(kāi)發(fā)忘記密碼通過(guò)郵箱找回功能示例

看完了這篇文章，相信你對(duì)“Django怎么實(shí)現(xiàn)WebSSH操作物理機(jī)或虛擬機(jī)”有了一定的了解，如果想了解更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)成都網(wǎng)站設(shè)計(jì)公司行業(yè)資訊頻道，感謝各位的閱讀！

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線(xiàn)，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性?xún)r(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專(zhuān)為企業(yè)上云打造定制，能夠滿(mǎn)足用戶(hù)豐富、多元化的應(yīng)用場(chǎng)景需求。

文章名稱(chēng)：Django怎么實(shí)現(xiàn)WebSSH操作物理機(jī)或虛擬機(jī)-創(chuàng)新互聯(lián)
分享鏈接：http://chinadenli.net/article14/dgpcge.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供靜態(tài)網(wǎng)站、手機(jī)網(wǎng)站建設(shè)、網(wǎng)站維護(hù)、ChatGPT、軟件開(kāi)發(fā)、App設(shè)計(jì)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)