socket__服務端、客戶端(註釋版)
阿新 • • 發佈:2017-08-23
發送數據 data sea Coding 開始 等待 hang size light
# !/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2017/8/22 16:14 # @Author : Mr_zhang # @Site : # @File : server.py # @Software: PyCharm from socket import * import subprocess import struct phone = socket(AF_INET,SOCK_STREAM) phone.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) phone.bind((‘127.0.0.1‘,8080)) phone.listen(7) print(‘startting...‘) while True: conn,client_addr = phone.accept() #等待客戶端發送數據 ======>接收 print(‘------->‘,conn,client_addr) while True: try: cmd = conn.recv(1024) if not cmd:break res = subprocess.Popen(cmd.decode(‘utf-8‘),shell=True, #將普通字符串轉化為系統命令 stdout=subprocess.PIPE, stderr=subprocess.PIPE) stdout = res.stdout.read() #輸入正確讀取的內容 stderr = res.stderr.read() #輸入錯誤讀取的內容 header = struct.pack(‘i‘,len(stdout)+len(stderr)) #根據長度制作報頭 conn.send(header) #發送報頭去探路 conn.send(stdout) conn.send(stderr) except Exception: break conn.close() phone.close()
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2017/8/22 16:14 # @Author : Mr_zhang # @Site : # @File : client.py # @Software: PyCharm from socket import * import struct phone = socket(AF_INET,SOCK_STREAM) phone.connect((‘127.0.0.1‘,8080)) while True: cmd = input(‘>>:‘).strip() #輸入的命令 if not cmd:continue phone.send(cmd.encode(‘utf-8‘)) #encode之後發送出去 header_struct = phone.recv(4) #接收的報頭信息 unpack_res = struct.unpack(‘i‘,header_struct) #將字節流轉化為Python數據類型 total_size = unpack_res[0] #拆包之後是元組,取第一項 recv_size = 0 #接收道德數據,剛開始為0 total_data = b‘‘ #初始數據 while recv_size < total_size: #接收到的數據<總共的數據 recv_data = phone.recv(1024) #每次接收的數據 recv_size+=len(recv_data) #接收到的數據=每次接收的收據+上次接收的數據 total_data+=recv_data #最後的總數據 print(total_data.decode(‘gbk‘)) #轉換為本機電腦的編碼 phone.close()
socket__服務端、客戶端(註釋版)