Python网络编程03/ low版解决粘包问题，, 目录

目录

Python网络编程03/ low版解决粘包问题 1.操作系统的缓存区 2.基于TCP协议的socket循环通信 2.1 服务端(server) 2.2客户端(client) 3.基于TCP协议的socket链接+循环 通信 3.1服务端(server) 3.2 客户端(client) 4.基于TCP协议的socket应用实例:执行远程命令 4.1服务端(server) 4.2客户端(client) 5.粘包现象 5.1服务端(server) 5.2客户端(client) 5.3展示收发问题的服务端(server) 5.4 展示收发问题的客户端(client) 6.如何解决粘包现象 5.low版解决粘包现象 5.1服务端 5.2客户端(client)

Python网络编程03/ low版解决粘包问题

1.操作系统的缓存区

1.为什么存在缓冲区    1. 暂时存储一些数据.    2. 缓冲区存在如果你的网络波动,保证数据的收发稳定,匀速.缺点: 造成了粘包现象之一.

2.基于TCP协议的socket循环通信

2.1 服务端(server)

# import socket# # phone = socket.socket()# # phone.bind(('127.0.0.1',8848))# # phone.listen()# listen: 允许5个人链接我,剩下的链接也可以链接,等待.# # conn,addr = phone.accept()  # 等待客户端链接我,阻塞状态中# print(f'链接来了: {conn,addr}')# # while 1:#     try:#         from_client_data = conn.recv(1024)  # 最多接受1024字节# #         if from_client_data.upper() == b'Q':#             print('客户端正常退出聊天了')#             break# #         print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')#         to_client_data = input('>>>').strip().encode('utf-8')#         conn.send(to_client_data)#     except ConnectionResetError:#         print('客户端链接中断了')#         break# conn.close()# phone.close()

2.2客户端(client)

# import socket# # phone = socket.socket()# # phone.connect(('127.0.0.1',8848))# while 1:#     to_server_data = input('>>>输入q或者Q退出').strip().encode('utf-8')#     if not to_server_data:#         # 服务端如果接受到了空的内容，服务端就会一直阻塞中，所以无论哪一端发送内容时，都不能为空发送#         print('发送内容不能为空')#         continue#     phone.send(to_server_data)#     if to_server_data.upper() == b'Q':#         break#     from_server_data = phone.recv(1024)  # 最多接受1024字节#     print(f'来自服务端消息:{from_server_data.decode("utf-8")}')# # phone.close()# # # s1 = 'q'# # s2 = b'q'# # s3 = '中国'# # print(s3.encode('utf-8'))# # print(type(s1),type(s2))# # # s1 = 'q'# # print(s1.encode('utf-8'))# # # bytes类型：#     # ASCII字符： 在字符串前面b''#     # 非ASCII字符： encode 转化成 bytes类型

3.基于TCP协议的socket链接+循环 通信

3.1服务端(server)

# import socket# # phone = socket.socket()# # phone.bind(('127.0.0.1',8848))# # phone.listen(2)# # listen: 2 允许有两个客户端加到半链接池，超过两个则会报错# # while 1:#     conn,addr = phone.accept()  # 等待客户端链接我,阻塞状态中#     print(f'链接来了: {conn,addr}')# #     while 1:#         try:#             from_client_data = conn.recv(1024)  # 最多接受1024字节# #             if from_client_data.upper() == b'Q':#                 print('客户端正常退出聊天了')#                 break# #             print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')#             to_client_data = input('>>>').strip().encode('utf-8')#             conn.send(to_client_data)#         except ConnectionResetError:#             print('客户端链接中断了')#             break#     conn.close()# phone.close()

3.2 客户端(client)

# import socket# # phone = socket.socket()# # phone.connect(('127.0.0.1',8848))# while 1:#     to_server_data = input('>>>输入q或者Q退出').strip().encode('utf-8')#     if not to_server_data:#         # 服务端如果接受到了空的内容，服务端就会一直阻塞中，所以无论哪一端发送内容时，都不能为空发送#         print('发送内容不能为空')#         continue#     phone.send(to_server_data)#     if to_server_data.upper() == b'Q':#         break#     from_server_data = phone.recv(1024)  # 最多接受1024字节#     print(f'来自服务端消息:{from_server_data.decode("utf-8")}')# # phone.close()

4.基于TCP协议的socket应用实例:执行远程命令

4.1服务端(server)

# import socket# import subprocess# phone = socket.socket()# # phone.bind(('127.0.0.1',8848))# # phone.listen(2)# # listen: 2 允许有两个客户端加到半链接池，超过两个则会报错# # while 1:#     conn,addr = phone.accept()  # 等待客户端链接我,阻塞状态中#     print(f'链接来了: {conn,addr}')# #     while 1:#         try:# #             from_client_data = conn.recv(1024)  # 最多接受1024字节# # #             if from_client_data.upper() == b'Q':#                 print('客户端正常退出聊天了')#                 break# #             obj = subprocess.Popen(from_client_data.decode('utf-8'),#                                    shell=True,#                                    stdout=subprocess.PIPE,#                                    stderr=subprocess.PIPE,# #                                    )#             result = obj.stdout.read() + obj.stderr.read()# #             conn.send(result)#         except ConnectionResetError:#             print('客户端链接中断了')#             break#     conn.close()# phone.close()# # # # # # shell: 命令解释器，相当于调用cmd 执行指定的命令。# # stdout:正确结果丢到管道中。# # stderr:错了丢到另一个管道中。# # windows操作系统的默认编码是gbk编码。#

4.2客户端(client)

# import socket# # phone = socket.socket()# # phone.connect(('127.0.0.1',8848))# while 1:#     to_server_data = input('>>>输入q或者Q退出').strip().encode('utf-8')#     if not to_server_data:#         # 服务端如果接受到了空的内容，服务端就会一直阻塞中，所以无论哪一端发送内容时，都不能为空发送#         print('发送内容不能为空')#         continue#     phone.send(to_server_data)#     if to_server_data.upper() == b'Q':#         break#     from_server_data = phone.recv(1024)  # 最多接受1024字节#     print(f'{from_server_data.decode("gbk")}')# # phone.close()

5.粘包现象

5.1服务端(server)

# 1. 粘包第一种： send的数据过大，大于对方recv的上限时，对方第二次recv时，会接收上一次没有recv完的剩余的数据。# import socket# import subprocess# phone = socket.socket()## phone.bind(('127.0.0.1',8848))## phone.listen(2)# # listen: 2 允许有两个客户端加到半链接池，超过两个则会报错## while 1:#     conn,addr = phone.accept()  # 等待客户端链接我,阻塞状态中#     # print(f'链接来了: {conn,addr}')##     while 1:#         try:##             from_client_data = conn.recv(1024)  # 最多接受1024字节###             if from_client_data.upper() == b'Q':#                 print('客户端正常退出聊天了')#                 break##             obj = subprocess.Popen(from_client_data.decode('utf-8'),#                                    shell=True,#                                    stdout=subprocess.PIPE,#                                    stderr=subprocess.PIPE,##                                    )#             result = obj.stdout.read() + obj.stderr.read()#             print(f'总字节数：{len(result)}')#             conn.send(result)#         except ConnectionResetError:#             print('客户端链接中断了')#             break#     conn.close()# phone.close()# s1 = '太白jx'# # print(len(s1))# b1 = s1.encode('utf-8')# # print(b1)# print(len(b1))'''         客户端                          服务端第一次：  ipconfig                       317字节         300个字节                       17个字节                  客户端                          服务端第二次：   dir                           376字节          17字节                        376字节         '''# 2. 连续短暂的send多次(数据量很小),你的数据会统一发送出去.# import socket## phone = socket.socket()## phone.bind(('127.0.0.1',8848))## phone.listen(5)### conn,addr = phone.accept()  # 等待客户端链接我,阻塞状态中## from_client_data = conn.recv(1024)  # 最多接受1024字节# print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')# conn.close()# phone.close()# 展示一些收发的问题。

5.2客户端(client)

# import socket## phone = socket.socket()## phone.connect(('127.0.0.1',8848))# while 1:#     to_server_data = input('>>>输入q或者Q退出').strip().encode('utf-8')#     if not to_server_data:#         # 服务端如果接受到了空的内容，服务端就会一直阻塞中，所以无论哪一端发送内容时，都不能为空发送#         print('发送内容不能为空')#         continue#     phone.send(to_server_data)#     if to_server_data.upper() == b'Q':#         break#     from_server_data = phone.recv(300)  # 最多接受1024字节#     # print(f'{from_server_data.decode("gbk")}')#     print(len(from_server_data))## phone.close()# 2. 连续短暂的send多次(数据量很小),你的数据会统一发送出去.# import socket## phone = socket.socket()## phone.connect(('127.0.0.1',8848))### phone.send(b'he')# phone.send(b'll')# phone.send(b'o')### phone.close()# Nigle算法

5.3展示收发问题的服务端(server)

# 发多次收一次# import socket## phone = socket.socket()## phone.bind(('127.0.0.1',8848))## phone.listen(5)### conn,addr = phone.accept()  # 等待客户端链接我,阻塞状态中## from_client_data = conn.recv(1024)  # 最多接受1024字节# print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')## from_client_data = conn.recv(1024)  # 最多接受1024字节# print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')# conn.close()# phone.close()# 发一次收多次# import socket## phone = socket.socket()## phone.bind(('127.0.0.1',8848))## phone.listen(5)### conn,addr = phone.accept()  # 等待客户端链接我,阻塞状态中## from_client_data = conn.recv(3)  # 最多接受1024字节# print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')## from_client_data = conn.recv(3)  # 最多接受1024字节# print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')## from_client_data = conn.recv(3)  # 最多接受1024字节# print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')## from_client_data = conn.recv(3)  # 最多接受1024字节# print(f'来自客户端{addr}消息:{from_client_data.decode("utf-8")}')## conn.close()# phone.close()

5.4 展示收发问题的客户端(client)

# 发多次收一次# import socket## phone = socket.socket()## phone.connect(('127.0.0.1',8848))### phone.send(b'he')# phone.send(b'llo')### phone.close()# Nigle算法# 发一次收多次# import socket## phone = socket.socket()## phone.connect(('127.0.0.1',8848))### phone.send(b'hello world')### phone.close()

6.如何解决粘包现象

解决粘包现象的思路:服务端发一次数据 10000字节,  客户端接收数据时,循环接收,每次(至多)接收1024个字节,直至将所有的字节全部接收完毕.将接收的数据拼接在一起,最后解码.1. 遇到的问题: recv的次数无法确定.   你发送总具体数据之前,先给我发一个总数据的长度:5000个字节。然后在发送总数据。   客户端： 先接收一个长度。 5000个字节。   然后我再循环recv 控制循环的条件就是只要你接受的数据< 5000 一直接收。2. 遇到的问题： 总数据的长度转化成的字节数不固定

服务端：conn.send(total_size) conn.send(result)total_size int类型客户端：total_size_bytes = phone.recv(4)total_sizedata = b''while len(data) < total_size:    data = data + phone.recv(1024)

你要将total_size int类型转化成bytes类型才可以发送387    ---- > str(387)  '387'  ---->bytes   b'387'        长度   3bytes4185  ---->  str(4185)  '4185'  ---->bytes   b'4185'  长度   4bytes18000------------------------------------------------------>  长度   5bytes我们要解决： 将不固定长度的int类型转化成固定长度的bytes并且还可以翻转回来。

struct模块

5.low版解决粘包现象

5.1服务端

# 1. 粘包第一种： send的数据过大，大于对方recv的上限时，对方第二次recv时，会接收上一次没有recv完的剩余的数据。import socketimport subprocessimport structphone = socket.socket()phone.bind(('127.0.0.1',8848))phone.listen(2)# listen: 2 允许有两个客户端加到半链接池，超过两个则会报错while 1:    conn,addr = phone.accept()  # 等待客户端链接我,阻塞状态中    # print(f'链接来了: {conn,addr}')    while 1:        try:            from_client_data = conn.recv(1024)  # 接收命令            if from_client_data.upper() == b'Q':                print('客户端正常退出聊天了')                break            obj = subprocess.Popen(from_client_data.decode('utf-8'),                                   shell=True,                                   stdout=subprocess.PIPE,                                   stderr=subprocess.PIPE,                                   )            result = obj.stdout.read() + obj.stderr.read()            total_size = len(result)            print(f'总字节数：{total_size}')            # 1. 制作固定长度的报头            head_bytes = struct.pack('i',total_size)            # 2. 发送固定长度的报头            conn.send(head_bytes)            # 3. 发送总数据            conn.send(result)        except ConnectionResetError:            print('客户端链接中断了')            break    conn.close()phone.close()# import struct# # 将一个数字转化成等长度的bytes类型。# ret = struct.pack('i', 180000000)# # print(ret, type(ret), len(ret))## # 通过unpack反解回来# ret1 = struct.unpack('i',ret)[0]# # print(ret1)# print(ret1, type(ret1))# 总数据：总数据长度# s1 = 'lagfdkjglkhjklh'# b1 = s1.encode('utf-8')# print(b1)# print(len(b1))

5.2客户端(client)

import socketimport structphone = socket.socket()phone.connect(('127.0.0.1',8848))while 1:    to_server_data = input('>>>输入q或者Q退出').strip().encode('utf-8')    if not to_server_data:        # 服务端如果接受到了空的内容，服务端就会一直阻塞中，所以无论哪一端发送内容时，都不能为空发送        print('发送内容不能为空')        continue    phone.send(to_server_data)    if to_server_data.upper() == b'Q':        break    # 1. 接收报头    head_bytes = phone.recv(4)    # 2. 反解报头    total_size = struct.unpack('i',head_bytes)[0]    total_data = b''    while len(total_data) < total_size:        total_data += phone.recv(1024)    print(len(total_data))    print(total_data.decode('gbk'))phone.close()

Python网络编程03/ low版解决粘包问题