#!/usr/bin/env python
# -*- coding:utf-8 -*-
__author__ = "loki"import json
import socket
import struct
import subprocess
import times_ip = ("0.0.0.0", 19999)
c_time = time.strftime("%Y-%m-%d %X", time.localtime())win_ser = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
win_ser.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
win_ser.bind(s_ip)
win_ser.listen(5)
print('Server listening begin ,port %s' % s_ip[1])#  get socket
while 1:conn, address = win_ser.accept()while 1:try:cmd = conn.recv(1024)print('Receive client[%s] command : %s %s' % (address, cmd, c_time))client_cmd = cmd.decode('utf-8')client_cmd = client_cmd.split()cmd_len = len(client_cmd)if cmd_len == 3 and client_cmd[0] == 'Dial':username = client_cmd[1]password = client_cmd[2]# command = "echo %s %s" % (username, password)
#                 command = "rasdial 宽带连接 /disconnect && rasdial 宽带连接 %s %s" % (username, password)command = "Dialupass /setpass 宽带连接 %s %s" % (username, password)cmd_execute = subprocess.Popen(command,shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)stdout = cmd_execute.stdout.read()stderr = cmd_execute.stdout.read()# if not cmd:#     break# DIY headheader_dict = {'total_size': len(stdout) + len(stderr),'filename': None}header_bytes = json.dumps(header_dict).encode('utf-8')# Send head lengthheader_len = struct.pack('i', len(header_bytes))conn.send(header_len)# Send head
                conn.send(header_bytes)# conn.send(cmd_execute)# Send data
                conn.send(stdout)conn.send(stderr)else:print('hello...')stdout = 'Please input correct command!Format:Dial <username> <password>'.encode('utf-8')# DIY headheader_dict = {'total_size': len(stdout),'filename': None}header_bytes = json.dumps(header_dict).encode('utf-8')# Send head lengthheader_len = struct.pack('i', len(header_bytes))conn.send(header_len)# Send head
                conn.send(header_bytes)# conn.send(cmd_execute)# Send data
                conn.send(stdout)except Exception as e:print(e)breakconn.close()
# win_ser.close()

#!/usr/bin/env python
# -*- coding:utf-8 -*-
__author__ = "loki"import json
import socket
import structc_ip = ('127.0.0.1', 19999)
win_cli = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
win_cli.connect(c_ip)while 1:mes = input('>>').strip()if mes == 'Quit':breakif not mes:continuewin_cli.send(mes.encode('utf-8'))# receive head lengthres_head_len = win_cli.recv(4)# unpack head length# print(res_head_len, type(res_head_len))head_size = struct.unpack('i', res_head_len)[0]# receive head length contentheader_bytes = win_cli.recv(head_size).decode('utf-8')# to head dic jsonheader_json = json.loads(header_bytes)# get data lengthdata_size = header_json['total_size']# receive data to the length  of the headerreceive_size = 0total_data = b''while receive_size < data_size:data_receive = win_cli.recv(1024)if (data_size - len(data_receive)) < 1024:left_data = win_cli.recv(data_size - len(data_receive))total_data += left_datatotal_data += data_receivereceive_size += len(data_receive)print(total_data.decode('GBK'))