在進行socket編程的時候,可以實現遠程執行命令,然后返回相關的結果,但是這種。。。很容易就把服務器搞掛了。
在這里需要用到commands模塊,commands模塊中有一個方法為getstatusoutput,主要就是返回執行的返回碼和結果,如下所示:
>>> import commands >>> commands.getstatusoutput('ls') (0, 'client.py\nserver.py')
>>> commands.getstatusoutput('kel') (32512, 'sh: kel: command not found') >>>
返回的結果是一個元組,第一個為返回碼,第一個返回值0表示命令成功執行,其他的表示為未能正確執行;第二個返回值表示返回的結果,如果命令執行失敗,那就是返回命令執行的錯誤信息。
服務器端代碼如下:
#!/usr/bin/env python import commands import SocketServer class MyHandler(SocketServer.BaseRequestHandler): def handle(self): while True: data = self.request.recv(1024) if not data: break cmd = data.strip() status,output = commands.getstatusoutput(cmd) #send the output size self.request.sendall(str(len(output))) #sent the content self.request.sendall(output) HOST = '192.168.1.60' PORT = 9999 s = SocketServer.ThreadingTCPServer((HOST,PORT),MyHandler) print 'waiting for connection...' s.serve_forever()在服務器端代碼中,在發送的時候,需要發送需要發送的結果的大小,從而發送了兩次信息,第一次發送的是文件的大小,第二次發送的是文件的內容。
客戶端代碼如下:
#!/usr/bin/env python import socket s = socket.socket() HOST = '192.168.1.60' PORT = 9999 def recv_all(s,file_size): results = '' file_size = int(file_size) while file_size > 0: if file_size <= 1024: data = s.recv(1024) results += data break elif file_size > 1024: data = s.recv(1024) results += data file_size -= 1024 return results s.connect((HOST,PORT)) while True: data = raw_input('>>>') if not data:break if data.strip() == 'exit': break s.sendall(data) if not data:break #first time get the size of the file file_size = s.recv(1024) contens = recv_all(s,file_size) print contens s.close()在進行接收的時候,第一次接收了發過來的文件的大小,然后在進行調用函數recv_all接收所有的文件,在此函數中,主要就是根據緩沖區的大小,將文件進行接收,在這里緩沖區的大小是有設置的,設置為1024,從而每次判斷文件的大小,進行接收剩下的文件內容。
在這里基本實現了ssh的命令執行功能,也就是在服務器端執行相關的命令,然后返回結果。
主要在進行命令執行的時候,直接使用了commands模塊的getstatusoutput方法。
其實在進行連接ssh時候,python也是可以做到的,密碼登錄驗證,使用paramiko進行連接,好像都是可以直接進行遠程操作,不過這也就是socket網絡編程的一個功能。