#服務(wù)端
import socket
import subprocess
sever = socket.socket()
sever.bind(('127.0.0.1', 33521))
sever.listen()
while True:
 client, address = sever.accept()
 while True:
  try:
   cmd = client.recv(1024).decode('utf-8')
   p1 = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr= subprocess.PIPE)
   data = p1.stdout.read()
   err_data = p1.stderr.read()
   client.send(data)
   client.send(err_data)
  except ConnectionResetError:
   print('connect broken')
   client.close()
   break
sever.close()
​
​
​
#客戶端
import socket
client = socket.socket()
client.connect(('127.0.0.1', 33521))
while True:
 cmd = input('請(qǐng)輸入指令(Q\q退出)>>:').strip().lower()
 if cmd == 'q':
  break
 client.send(cmd.encode('utf-8'))
 data = client.recv(1024)
 print(data.decode('gbk'))
client.close()

import struct
s = 123456789
res = struct.pack('i', s)
print(res)
​
res2 = struct.unpack('i', res)
print(res2)
print(res2[0])

#服務(wù)器端
import socket
import subprocess
import struct
sever = socket.socket()
sever.bind(('127.0.0.1', 33520))
sever.listen()
while True:
 client, address = sever.accept()
 while True:
  try:
   cmd = client.recv(1024).decode('utf-8')
   #利用子進(jìn)程模塊啟動(dòng)程序
   p = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
   #管道輸出的信息有正確和錯(cuò)誤的
   data = p.stdout.read()
   err_data = p.stderr.read()
   #先將數(shù)據(jù)的長(zhǎng)度發(fā)送給客戶端
   length = len(data)+len(err_data)
   #利用struct模塊將數(shù)據(jù)的長(zhǎng)度信息轉(zhuǎn)化成固定的字節(jié)
   len_data = struct.pack('i', length)
   #以下將信息傳輸給客戶端
   #1.數(shù)據(jù)的長(zhǎng)度
   client.send(len_data)
   #2.正確的數(shù)據(jù)
   client.send(data)
   #2.錯(cuò)誤管道的數(shù)據(jù)
   client.send(err_data)
  except Exception as e:
   client.close()
   print('連接中斷。。。。')
   break
   
​
#客戶端   
import socket
import struct
​
client = socket.socket()
client.connect(('127.0.0.1', 33520))
while True:
 cmd = input('請(qǐng)輸入指令>>:').strip().encode('utf-8')
 client.send(cmd)
 #1.先接收傳過(guò)來(lái)數(shù)據(jù)的長(zhǎng)度是多少，我們通過(guò)struct模塊固定了字節(jié)長(zhǎng)度為4
 length = client.recv(4)
 #將struct的字節(jié)再轉(zhuǎn)回去整型數(shù)字
 len_data = struct.unpack('i', length)
 print(len_data)
 len_data = len_data[0]
 print('數(shù)據(jù)長(zhǎng)度為%s:' % len_data)
​
 all_data = b''
 recv_size = 0
 #2.接收真實(shí)的數(shù)據(jù)
 #循環(huán)接收直到接收到數(shù)據(jù)的長(zhǎng)度等于數(shù)據(jù)的真實(shí)長(zhǎng)度（總長(zhǎng)度）
 while recv_size < len_data:
  data = client.recv(1024)
  recv_size += len(data)
  all_data += data
​
 print('接收長(zhǎng)度%s' % recv_size)
 print(all_data.decode('gbk'))

#服務(wù)器端
import socket
import subprocess
import datetime
import json
import struct
sever = socket.socket()
sever.bind(('127.0.0.1', 33520))
sever.listen()
while True:
 client, address = sever.accept()
 while True:
  try:
   cmd = client.recv(1024).decode('utf-8')
   #啟動(dòng)子進(jìn)程
   p = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
   #得到子進(jìn)程運(yùn)行的數(shù)據(jù)
   data = p.stdout.read() #子進(jìn)程運(yùn)行正確的輸出管道數(shù)據(jù)，數(shù)據(jù)讀出來(lái)后是字節(jié)
   err_data = p.stderr.read() #子進(jìn)程運(yùn)行錯(cuò)誤的輸出管道數(shù)據(jù)
   #計(jì)算數(shù)據(jù)的總長(zhǎng)度
   length = len(data) + len(err_data)
   print('數(shù)據(jù)總長(zhǎng)度：%s' % length)
​
   #先需要發(fā)送報(bào)頭信息，以下為創(chuàng)建報(bào)頭信息（至第一次發(fā)送）
​
​
   #需要添加時(shí)間信息
   time_info = datetime.datetime.now()
   #設(shè)置一個(gè)字典將一些額外的信息和長(zhǎng)度信息放進(jìn)去然后json序列化，報(bào)頭字典
   masthead = {}
   #將時(shí)間數(shù)據(jù)放入報(bào)頭字典中
   masthead['time'] = str(time_info) #時(shí)間格式不能被json序列化，所以將其轉(zhuǎn)化為字符串形式
   masthead['length'] = length
​
   #將報(bào)頭字典json序列化
   json_masthead = json.dumps(masthead)   #得到j(luò)son格式的報(bào)頭
   # 將json格式的報(bào)頭編碼成字節(jié)形式
   masthead_data = json_masthead.encode('utf-8')
   #利用struct將報(bào)頭編碼的字節(jié)的長(zhǎng)度轉(zhuǎn)成固定的字節(jié)(4個(gè)字節(jié)）
   masthead_length = struct.pack('i', len(masthead_data))
​
​
   #1.發(fā)送報(bào)頭的長(zhǎng)度（第一次發(fā)送）
   client.send(masthead_length)
   #2.發(fā)送報(bào)頭信息(第二次發(fā)送）
   client.send(masthead_data)
   #3.發(fā)送真實(shí)數(shù)據(jù)（第三次發(fā)送）
   client.send(data)
   client.send(err_data)
  except ConnectionResetError:
   print('客戶端斷開(kāi)連接。。。')
   client.close()
   break
   
   
   
#客戶端
import socket
import struct
import json
client = socket.socket()
client.connect(('127.0.0.1', 33520))
while True:
 cmd = input('請(qǐng)輸入cmd指令(Q\q退出)>>:').strip()
 if cmd == 'q':
  break
​
 #發(fā)送CMD指令至服務(wù)器
 client.send(cmd.encode('utf-8'))
​
​
 #1.第一次接收，接收?qǐng)?bào)頭信息的長(zhǎng)度，由于struct模塊固定長(zhǎng)度為4字節(jié)，括號(hào)內(nèi)直接填4
 len_masthead = client.recv(4)
 #利用struct反解報(bào)頭長(zhǎng)度，由于是元組形式，取值得到整型數(shù)字masthead_length
 masthead_length = struct.unpack('i', len_masthead)[0]
​
​
 #2.第二次接收，接收?qǐng)?bào)頭信息，接收長(zhǎng)度為報(bào)頭長(zhǎng)度masthead_length 被編碼成字節(jié)形式的json格式的字典,
 # 解字符編碼得到j(luò)son格式的字典masthead_data
 masthead_data = client.recv(masthead_length).decode('utf-8')
 #得到報(bào)頭字典masthead
 masthead = json.loads(masthead_data)
 print('執(zhí)行時(shí)間%s' % masthead['time'])
 #通過(guò)報(bào)頭字典得到數(shù)據(jù)長(zhǎng)度
 data_length = masthead['length']
​
 #3.第三次接收，接收真實(shí)數(shù)據(jù)，真實(shí)數(shù)據(jù)長(zhǎng)度為data_length
 # data = client.recv(data_length) #有可能真實(shí)數(shù)據(jù)長(zhǎng)度太大會(huì)撐爆內(nèi)存。
 #所以循環(huán)讀取數(shù)據(jù)
 all_data = b''
 length = 0
 #循環(huán)直到長(zhǎng)度大于等于數(shù)據(jù)長(zhǎng)度
 while length < data_length:
  data = client.recv(1024)
  length += len(data)
  all_data += data
 print('數(shù)據(jù)的總長(zhǎng)度：%s' % data_length)
​
 #我的電腦是Windows系統(tǒng)，所以用gbk解碼系統(tǒng)發(fā)出的信息
 print(all_data.decode('gbk'))