Python中使用os模組執行遠端命令

在python中使用os模組或者subprocess模組執行遠端命令，並把執行結果傳送給客戶端的時候，會發生黏包現象，這是因為服務端傳送的資料量大，客戶端一次收的資料量小導致快取中的內容沒有讀取完，下次接著執行命令時，還會接著從快取中讀取內容，這時就會發生黏包現象。

1. 使用os模組遠端執行命令

服務端**

1 importsocket

2 importos
3 4 sh_server = socket.socket() #建立乙個socket物件
5 sh_server.setsockopt(socket.sol_socket,socket.so_reuseaddr,1) #重置ip和埠
6 sh_server.bind(('127.0.0.1',8001)) #繫結伺服器ip和埠
7 sh_server.listen(5) #設定最大監聽數
8 9 while true: #鏈結迴圈
10 conn,addr = sh_server.accept() #阻塞，等待客戶端過來鏈結
11 12 while true: #通訊迴圈
13 # 接收客戶端傳送過來的訊息
14 cmd = conn.recv(buffer_size).decode('utf-8')
15 #使用os模組中的popen遠端執行命令
16 data =os.popen(cmd)
17 res_msg=data.read()
18 #執行結果傳送給客戶端
19 conn.send(res_msg.encode('gbk'))
20 print(res_msg)
21 print(len(res_msg))
22 conn.close()
23 

客戶端**

1 importsocket

2 3 sh_client = socket.socket() #建立socket物件
4 sh_client.setsockopt(socket.sol_socket,socket.so_reuseaddr,1)
5 6 sh_client.connect(('127.0.0.1',8001)) #鏈結服務端
7 8 while true: #通訊迴圈
9 cmd = input("請輸入要執行的命令：")
10 if cmd == '': continue
11 if cmd =='exit' or cmd =='quit':break
12 sh_client.send(cmd.encode('utf-8'))
13 res_info = sh_client.recv(1024).decode('gbk')
14 print('命令執行結果是：',res_info)
15 sh_client.close()

2. 使用subprocess模組執行遠端命令

服務端**

1 importsocket

2 importsubprocess
3 4 sh_server =socket.socket()
5 sh_server.setsockopt(socket.sol_socket,socket.so_reuseaddr,1) #重置ip和埠
6 sh_server.bind(('127.0.0.1',8001))
7 sh_server.listen(5)
8 9 while true: #鏈結迴圈
10 conn,addr = sh_server.accept() #阻塞，等待客戶端過來鏈結
11 print('客戶端資訊',conn,addr)
12 13 while true: #通訊迴圈
14 # 接收客戶端傳送過來的訊息
15 print('----------接收命令')
16 cmd = conn.recv(buffer_size).decode('utf-8')
17 print('要執行的命令是:',cmd)
18 if cmd == 'exit' or cmd == 'quit':break
19 #使用subprocess模組執行遠端命令
20 ret = subprocess.popen(cmd,shell=true,
21 stdout =subprocess.pipe,
22 stderr =subprocess.pipe,
23 stdin =subprocess.pipe)
24 25 err =ret.stderr.read()
26 iferr:
27 ret_msg =err
28 else:
29 ret_msg =ret.stdout.read()
30 if notret_msg:
31 ret_msg = "命令執行成功".encode('gbk')
32 print('---------命令執行完成')
33 conn.send(ret_msg)
34 
35 conn.close()

客戶端**

1 importsocket

2 3 sh_client =socket.socket()
4 sh_client.setsockopt(socket.sol_socket,socket.so_reuseaddr,1)
5 6 sh_client.connect(('127.0.0.1',8001))
7 8 while true: #通訊迴圈
9 cmd = input("請輸入要執行的命令：")
10 if cmd == '': continue
11 if cmd =='exit' or cmd =='quit':break
12 sh_client.send(cmd.encode('utf-8'))
13 res_info = sh_client.recv(1024).decode('gbk')
14 print('命令執行結果是：',res_info)
15 sh_client.close()

python的os模組使用

檢視os的名字 import os print os.name nt，nt 表示windows系統，posix 表示linux系統 檢視os環境變數 import os print os.environ print os.environ.get pat default 檢視變數 pat 若不存在，則...

python模組 OS模組

bin env python coding utf 8 import os print os.name 輸出主機平台 print os.getcwd 輸出當前目錄 print os.listdir os.getcwd 輸出當前目錄的檔案 橫向 for i in os.listdir os.getcw...

python 模組 OS模組

print os.getcwd 輸出 e python workspace 原來 print os.getcwd 輸出 e python workspace 返回上級目錄 os.chdir os.getcwd 輸出 e python 更改 os.chdir r e print os.getcwd 輸...