1
# -*-coding: Utf-8 -*-
2
# @File : 客户端 .py
3
# author: Chimengmeng
4
# blog_url : https://www.cnblogs.com/dream-ze/
5
# Time：2023/6/22
6
import json
7
from socket import *
8

9
# 解指定数据长度
10
import struct
11

12
# 创建  socket 对象
13
client = socket(AF_INET, SOCK_STREAM)
14

15
# 创建链接 IP 和 端口
16
client.connect(('127.0.0.1', 8085))
17

18
while True:
19
    msg = input('enter msg :>>>').strip()
20

21
    # 输入的内容不能为空
22
    if len(msg) == 0:
23
        continue
24

25
    # 传输过程中的数据为二进制数据。对文本数据进行转码
26
    msg = msg.encode('utf-8')
27
    client.send(msg)
28

29
    # 接收来自服务端返回的结果
30

31
    # （1.1） 先收四个字节的数据，从接收到的数据中解析出json格式的二进制数据的长度
32
    json_data_size_unpack = client.recv(4)
33

34
    # 解包返回的是元祖。元祖第一个参数就是打包的数字
35
    json_data_size = struct.unpack('i', json_data_size_unpack)[0]
36

37
    # （1.2） 对 服务端 返回的数据中指定长度进行截取 拿到 json 格式的二进制数据
38
    json_data_bytes = client.recv(json_data_size)
39

40
    # （1.3） 对指定数据进行json格式的解码并取出需要的信息
41
    header_dict_str = json_data_bytes.decode('utf-8')
42
    header_dict = json.loads(header_dict_str)
43

44
    # （1.4） 取出字典中的信息总长度
45
    recv_total_size = header_dict['total_size']
46

47
    # （2） 接收真实的数据
48
    # recv_size = 0 ，循环接收，每接收一次，recv_size += 接收的长度
49
    # （3） 直到 recv_size = recv_total_size 表示接受信息完毕，结束循环
50
    # 初始化数据长度
51
    recv_size = 0
52
    while recv_size < recv_total_size:
53
        # 本次接收 最多能接收 1024 字节的数据
54
        msg_from_server = client.recv(1024)
55
        # 本次接收到的打印的数据长度
56
        recv_size += len(msg_from_server)
57

58
        # 对服务端返回的信息进行解码（Mac/Linux解码用utf-8，Windows用GBK）
59
        msg_from_server = msg_from_server.decode('gbk')
60
        print(msg_from_server, end='')
61

62
    else:
63
        print('命令结束')
64

65
    client.close()

1
# -*-coding: Utf-8 -*-
2
# @File : 服务端 .py
3
# author: Chimengmeng
4
# blog_url : https://www.cnblogs.com/dream-ze/
5
# Time：2023/6/22
6

7
# client.connect(('127.0.0.1', 8880))
8
# 客户端设置的 ip 和 port
9
from socket import *
10

11
# 执行命令模块
12
import subprocess
13
# 将数据打包成指定4个长度的数据
14
import struct
15
# 将头部信息转成json格式（通用信息格式）
16
import json
17

18
# （1）创建服务对象
19
# 参数 ： AF_INET（默认，初始化操作）
20
# 参数 ： SOCK_STREAM（流式传输协议）
21
server = socket(AF_INET, SOCK_STREAM)
22

23
# （2）建立链接桥梁 --（呼应客户端的 ip 和 port）
24
IP = '127.0.0.1'
25
PORT = 8080
26
server.bind((IP, PORT))
27

28
# （3）指定半连接池大小
29
server.listen(5)
30

31
# （4）接收数据和发送数据
32
while True:
33
    # （4.1）从半连接池里面取出链接请求，建立双向链接，拿到连接对象
34
    # （4.2）返回参数解压赋值 ： （建成的链接对象,客户端的 ip port）
35
    conn, client_addr = server.accept()
36

37
    while True:
38
        # （5）检测可能会抛出的异常 并 对异常做处理
39
        try:
40
            # （5.1）基于 取出的链接对象 进行通信
41
            # （5.2）接受客户端传入的指定信息
42
            cmd_from_client = conn.recv(1024)
43

44
            # 不允许传过来的信息为空
45
            if len(cmd_from_client) == 0:
46
                break
47

48
            # （5.3）通过subprocess模块，执行客户端传过来的命令
49
            # （5.3.1）接收执行命令的结果
50
            msg_server = subprocess.Popen(cmd_from_client.decode('utf-8'),  # 对命令进行解码
51
                                          shell=True,  # 执行shell命令
52
                                          stdout=subprocess.PIPE,  # 管道一
53
                                          stderr=subprocess.PIPE,  # 管道二
54
                                          )
55

56
            # （5.3.2）返回命令的结果  ---- 成功或失败
57
            # ****** 对于返回给客户端的数据，客户端 Linux系统可以用utf-8解码，Windows系统需要用gbk解码 ******
58
            true_msg = msg_server.stdout.read()  # 读取到执行成功的结果 ---- 二进制数据类型
59
            false_msg = msg_server.stderr.read()  # 读取到执行失败的结果 ---- 二进制数据类型
60

61
            # （5.4）：头部信息（程序执行的结果，成功信息长度 + 失败信息长度）
62
            total_size_from_server = len(true_msg) + len(false_msg)
63

64
            # （5.5）自定义头部信息（存储任意数据拼接数据）
65
            headers_dict = {
66
                'file_name': 'a.txt',
67
                'total_size': total_size_from_server,
68
                'md5': 'md5'
69
            }
70

71
            # （5.6）打包头部信息 - 将字典转成 json 格式数据类型
72
            json_data_str = json.dumps(headers_dict)
73
            # （5.7）将 json 格式数据转成二进制数据传输
74
            json_data_bytes = json_data_str.encode('utf-8')
75

76
            # （5.8）int类型  -----> 将json格式的二进制数据打成固定长度的 bytes
77
            # 参数 i 表示是整型，具体解释参考文档
78
            json_data_size_pack = struct.pack('i', len(json_data_bytes))
79
            conn.send(json_data_size_pack)
80

81
            # （5.9）发送打包好的头信息
82
            conn.send(json_data_bytes)
83

84
            # （5.10）反馈信息（成功信息 + 失败信息）给 发送信息的客户端
85
            conn.send(true_msg)
86
            conn.send(false_msg)
87

88
        except Exception as e:
89

90
            break
91
    # 关闭服务端
92
    conn.close()