Python socketserver求助：服务端读取不同位置的报文，print出来是一样的

zzz_1015

问题描述：服务端读取报文头、报文体都没问题，但是读取报文尾的时候，内容是跟报文体是一样的，求大神指导

报文 = 报文头（标识报文体长度） + 报文体 + 报文尾（标识报文体的hash值，用于校验报文是否被篡改）

客户端

1. import socket
   
2. import time
   
3. import json
   
4. import traceback
   
5. 
   
6. 
   
7. def connect(ip, port):
   
8.     server_ip = ip
   
9.     server_port = port
   
10.     tcp_client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
11.     try:
    
12.         tcp_client.connect((server_ip, server_port))
    
13.     except socket.error:
    
14.         print('连接失败！！！')
    
15.     return tcp_client
    
16. 
    
17. 
    
18. def recv_msg(conn, length: int):
    
19.     ret_msg = bytes()
    
20.     recv_len = length
    
21.     while recv_len > 0:
    
22.         msg = conn.recv(recv_len)
    
23.         ret_msg += msg
    
24.         cur_len = len(msg)
    
25.         recv_len -= cur_len
    
26.     return ret_msg
    
27. 
    
28. 
    
29. def send_msg(tcp_client):
    
30.     try:
    
31.         data = dict()
    
32.         data['name'] = 'login'
    
33.         data['user_id'] = '8888'
    
34.         data['password'] = '123456'
    
35.         # for i in range(1000):
    
36.         #     data['demo_field_{}'.format(
    
37.         #         i)] = 'sdflakswdfnasdlfkjalnsdfknalksdjflkjaslkdfjlksajdflkjalksdfjlkasjdfklajslkdfjklsadjflks_{}'.format(
    
38.         #         i)
    
39. 
    
40.         data['time'] = time.strftime("%Y-%m-%d")
    
41.         # dict转json
    
42.         str_json = json.dumps(data)
    
43.         # 计算长度
    
44.         length = len(str_json)
    
45.         head = length.to_bytes(4, byteorder='big', signed=False)
    
46.         #计算hash值
    
47.         client_hash = "{:0>20}".format(str(hash(str_json)))
    
48.         # 拼装报文头与报文体
    
49.         msg = head + str_json.encode('utf-8') + client_hash.encode('utf-8')
    
50.         print(msg)
    
51.         tcp_client.send(msg)
    
52. 
    
53.         # 1.先接收头四位报文头
    
54.         len_msg = tcp_client.recv(4)
    
55.         length = int.from_bytes(len_msg, byteorder='big', signed=False)
    
56. 
    
57.         print('客户端收到报文长度:{}'.format(length))
    
58.         # 2.再接收报文体
    
59.         req_msg = recv_msg(tcp_client, length)
    
60.         json_str = str(req_msg, encoding='utf-8')
    
61.         print('客户端收到报文str:{}'.format(json_str))
    
62.         req_msg_dict = json.loads(json_str)
    
63.         # print('客户端收到报文dict:{}'.format(req_msg_dict))
    
64.     except Exception as e:
    
65.         print('连接失败！！！')
    
66.         traceback.print_exc()
    
67.         raise e
    
68. 
    
69. 
    
70. IP = '127.0.0.1'
    
71. PORT = 12581
    
72. if __name__ == '__main__':
    
73.     conn = connect(ip=IP, port=PORT)
    
74.     send_msg(conn)
    
75.     conn.close()
    

复制代码

服务端

1. from socketserver import ThreadingTCPServer
   
2. from socketserver import StreamRequestHandler
   
3. import json
   
4. import traceback
   
5. 
   
6. 
   
7. def recv_msg(conn, length: int):
   
8.     ret_msg = bytes()
   
9.     recv_len = length
   
10.     while recv_len > 0:
    
11.         msg = conn.read(recv_len)
    
12.         ret_msg += msg
    
13.         cur_len = len(msg)
    
14.         recv_len -= cur_len
    
15.     return ret_msg
    
16. 
    
17. 
    
18. class MyStreamRequestHandler(StreamRequestHandler):
    
19. 
    
20.     def handle(self):
    
21.         print('连接上来啦, 连接号:[{0}]'.format(self.wfile))
    
22.         while True:
    
23.             try:
    
24.                 print("等待客户端发送报文...")
    
25.                 # 1.先接收头四位报文头
    
26.                 len_msg = self.rfile.read(4)
    
27.                 if len_msg:
    
28.                     length = int.from_bytes(len_msg, byteorder='big', signed=False)
    
29.                     print('服务端收到报文长度:{}'.format(length))
    
30.                     # 2.再接收报文体
    
31.                     req_msg = recv_msg(self.rfile, length)
    
32.                     # req_msg = self.rfile.read(length)
    
33.                     #接收报文尾
    
34.                     req_hash = str(self.rfile.read(20),encoding='utf-8')
    
35.                     json_str = str(req_msg, encoding='utf-8')
    
36.                     print('服务端收到报文str:{}'.format(json_str))
    
37.                     print('服务端收到hash:{}'.format(req_hash))
    
38.                     req_msg_dict = json.loads(str(req_msg, encoding='utf-8'))
    
39.                     # print('服务端收到报文dict:{}'.format(req_msg_dict))
    
40.                     # 发送应答
    
41.                     head = length.to_bytes(4, byteorder='big', signed=False)
    
42.                     rsp_msg = head + bytes(json.dumps(req_msg_dict), encoding='utf-8')
    
43.                     print('服务端发送应答报文:{}'.format(rsp_msg))
    
44.                     self.wfile.write(rsp_msg)
    
45.                 else:
    
46.                     # 客户端主动断开后，req_msg是b''
    
47.                     print('连接已断开, 连接号:[{0}]'.format(self.wfile))
    
48.                     break
    
49.             except Exception as e:
    
50.                 print('Socket异常:{}'.format(e))
    
51.                 traceback.print_exc()
    
52.                 break
    
53. 
    
54.         self.request.close()
    
55. 
    
56. 
    
57. def start_server(port: int):
    
58.     # 设置IP 和 Port
    
59.     addr = ('0.0.0.0', port)
    
60.     # 使用socketserver库
    
61.     server = ThreadingTCPServer(addr, MyStreamRequestHandler)
    
62.     # 启动服务，线程挂起
    
63.     server.serve_forever()
    
64. 
    
65. 
    
66. PORT = 12581
    
67. if __name__ == '__main__':
    
68.     print("启动服务端！！！")
    
69.     start_server(PORT)
    
70.     print("服务端关闭")
    

复制代码

zzz_1015

原理--不知道，但是原因好像是我改了服务端但是没有重启服务端的原因