class subprocess.Popen( args, 
  bufsize = 0, 
  executable = None, 
  stdin = None, 
  stdout = None, 
  stderr = None, 
  preexec_fn = None, 
  close_fds = False, 
  shell = False, 
  cwd = None, 
  env = None, 
  universal_newlines = False, 
  startupinfo = None, 
  creationflags = 0)

import socket
import subprocess

# 建立
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

# 綁定
phone.bind(('127.0.0.1', 8081))

# 監(jiān)聽
phone.listen(5)

# 通信循環(huán)
while True:
  # 接收客戶端連接請求
  conn, client_addr = phone.accept()
  while True:
    # 接收客戶端數(shù)據(jù)/命令
    cmd = conn.recv(1024)
    if not cmd:
      break
    # 創(chuàng)建管道
    obj = subprocess.Popen(cmd.decode('utf-8'), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    stdout = obj.stdout.read()
    stderr = obj.stderr.read()
    # 向客戶端發(fā)送數(shù)據(jù)
    conn.send(stdout)
    conn.send(stderr)
  # 結(jié)束連接
  conn.close()

# 關(guān)閉套接字
phone.close()

import socket

# 建立
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 連接
phone.connect(('127.0.0.1', 8081))
while True:
  cmd = input('>>> ').strip()
  if not cmd:
    continue
  if cmd == 'quit':
    break
  # 給服務(wù)端發(fā)送數(shù)據(jù)/命令
  phone.send(cmd.encode('utf-8'))
  # 接收服務(wù)端數(shù)據(jù)/命令
  data = phone.recv(1024)
  print(data.decode('utf-8'))

# 關(guān)閉套接字
phone.close()

import socket
import subprocess
import json
import struct

# 建立
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

# 綁定
phone.bind(('127.0.0.1', 8081))

# 監(jiān)聽
phone.listen(5)

# 通信循環(huán)
while True:
  # 接收客戶端連接請求
  conn, client_addr = phone.accept()
  while True:
    # 接收客戶端數(shù)據(jù)/命令
    cmd = conn.recv(1024)
    if not cmd:
      continue
    # 創(chuàng)建數(shù)據(jù)流管道
    obj = subprocess.Popen(cmd.decode('utf-8'), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    stdout = obj.stdout.read()
    stderr = obj.stderr.read()
    # 向客戶端發(fā)送數(shù)據(jù)

    # 解決粘包問題
    # 1.制作固定長度的報頭
    header_dic = {
      'filename': 'a.txt',
      'total_size': len(stdout)+len(stderr)
    }
    # 序列化報頭
    header_json = json.dumps(header_dic) # 序列化為byte字節(jié)流類型
    header_bytes = header_json.encode('utf-8') # 編碼為utf-8（Mac系統(tǒng)）
    # 2.先發(fā)送報頭的長度
    # 2.1 將byte類型的長度打包成4位int
    conn.send(struct.pack('i', len(header_bytes)))
    # 2.2 再發(fā)報頭
    conn.send(header_bytes)
    # 2.3 再發(fā)真實(shí)數(shù)據(jù)
    conn.send(stdout)
    conn.send(stderr)
  # 結(jié)束連接
  conn.close()

# 關(guān)閉套接字
phone.close()

import socket
import struct
import json

# 建立
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 連接
phone.connect(('127.0.0.1', 8081))
while True:
  cmd = input('>>> ').strip()
  if not cmd:
    continue
  if cmd == 'quit':
    break
  # 給服務(wù)端發(fā)送命令
  phone.send(cmd.encode('utf-8'))
  # 接收服務(wù)端數(shù)據(jù)

  # 1.先收報頭長度
  obj = phone.recv(4)
  header_size = struct.unpack('i', obj)[0]
  # 2.收報頭
  header_bytes = phone.recv(header_size)
  # 3.從報頭中解析出數(shù)據(jù)的真實(shí)信息（報頭字典）
  header_json = header_bytes.decode('utf-8')
  header_dic = json.loads(header_json)
  total_size = header_dic['total_size']
  # 4.接受真實(shí)數(shù)據(jù)
  recv_size = 0
  recv_data = b''
  while recv_size < total_size:
    res = phone.recv(1024)
    recv_data += res
    recv_size += len(res)
  print(recv_data.decode('utf-8'))

# 關(guān)閉套接字
phone.close()