1 # _*_ coding:utf-8 _*_
 2 import socket,os
 3 server = socket.socket() #创建连接描述符，默认使用iv4/tcp
 4 server.bind(("localhost",6969)) #指定监听地址和端口,开始等待客户端连接。
 5 server.listen(5) #监听
 6 print("服务端已启动")
 7 while True:
 8     conn,addr = server.accept() #创建和客户端交互数据的连接
 9     print('new conn',conn)
10     while True:
11         date = conn.recv(1024) #1024为接收字节大小
12         if len(date) == 0:  #判断客户端是否断开，若客户端断开则接收端接收的数据长度为0
13             print("client is close")
14             break
15         print('recv cmd is::',date.decode('utf-8'))
16         cmd_res = os.popen(date.decode('utf-8')).read() #该命令无法获取os返回的异常，使用下面if判断输入cmd是否为异常
17         if len(cmd_res) == 0:
18             cmd_res = 'this is a bad command'
19         conn.send(str( len(cmd_res.encode(encoding='utf-8'))).encode(encoding='utf-8')) #发送命令长度
20         conn.recv(1024) #为解决粘包问题中间插入一个接收操作
21         conn.send(cmd_res.encode(encoding='utf-8'))
22
23
24 server.close()  #关闭连接

# _*_ coding:utf-8 _*_
import socket
client = socket.socket() #创建连接描述符，指定socket连接的网络层和传输层协议，默认使用ipv4/tcp
client.connect(("localhost",6969)) #使用连接描述符连接server,server信息以元组形式传入，包含ip地址和端口号
while True:cmd = input("input your command:")if len(cmd) == 0:continueclient.send(cmd.encode(encoding='utf-8')) #发送hello world，send只能发送byte类型，不能发送字符串。encode默认会将字符串转为byte类型cmd_res_len = client.recv(1024).decode() #接收命令回显的长度print("cmd_res_len:",cmd_res_len)client.send(b'i have receive cmd_res_len') #为解决粘包问题，给服务端发送响应rece_size = 0while rece_size < int(cmd_res_len):  #通过此循环持续收包print(client.recv(1024).decode())rece_size += 1024client.close()