day31 粘包问题

时间：2024-04-06 14:33:05

TCP粘包问题

cmd客户端代码

import socket

import struct

import socket

import json

c = socket.socket()

c.connect(("127.0.0.1",9090))

while True:

    cmd = input(">>:")

    if not cmd:

        print("命令不能为空")

        continue

    c.send(cmd.encode("utf-8"))

    # 1.接收的是额外信息的长度

    length = c.recv(4)

    len_data = struct.unpack("i",length)[0] # 转换为整型

    # 2.接收额外信息

    t_data = c.recv(len_data)

    print(t_data.decode("utf-8"))

    json_dic = json.loads(t_data.decode("utf-8"))

    print("执行时间:%s" % json_dic["time"])

    data_size = json_dic["size"] # 得到数据长度

    # 3.接收真实数据

    all_data = b"" # 存储已接收数据

    rcv_size = 0 # 已接收长度

    # 接收真实数据

    # 循环接收 直到 接收到的长度等于总长度

    while  rcv_size < data_size:

        data = c.recv(1024)

        rcv_size += len(data)

        all_data += data

    print("接收长度%s" % rcv_size)

    print(all_data.decode("gbk"))

cmd服务端代码

import  socket

import subprocess

import struct

import datetime

import json

server = socket.socket()

server.bind(("127.0.0.1",9090))

server.listen()

# 要求  不仅返回命令的结果 还要返回执行命令的时间  执行时间:2018/12/26

while True:

    client,addr = server.accept()

    while True:

        try:

            # 接收命令

            cmd = client.recv(1024).decode("utf-8")

            p = subprocess.Popen(cmd,shell=True,stdout=-1,stderr=-1)

            # data与err_data 都是采用的系统编码 windows是GBK

            data = p.stdout.read()

            err_data = p.stderr.read()

            print("数据长度:%s" % (len(data)   + len(err_data)))

            # 计算真实数据长度

            length = len(data)   + len(err_data)

            # 在发送数据之前发送额外的信息

            #t = "{执行时间:%s 真实数据长度:%s" % (datetime.datetime.now(),length)

            # 把要发送的数据先存到字典中

            t = {}

            t["time"] = str(datetime.datetime.now())

            t["size"] = length

            t["filename"] = "a.mp4"

            t_json = json.dumps(t) # 得到json格式字符串

            t_data = t_json.encode("utf-8") # 将json转成了字节

            t_length = struct.pack("i",len(t_data))

            # 1.先发送额外信息的长度

            client.send(t_length)

            # 2.发送额外信息

            client.send(t_data)

            # 3.发送真实数据

            client.send(data)

            client.send(err_data)

        except ConnectionResetError:

            client.close()

            print("连接中断......")

            break

#  1.发送了真实数据长度

2.发送了额外信息长度

3.发送额外信息

4.真实数据

粘包测试

服务器端

import  socket

import subprocess

server = socket.socket()

server.bind(("127.0.0.1",9090))

server.listen()

client,addr = server.accept()

# data =  client.recv(2)

# print(data.decode("utf-8"))

# data =  client.recv(2)

# print(data.decode("utf-8"))

# data =  client.recv(2)

# print(data.decode("utf-8"))

data =  client.recv(1024)

print(data.decode("utf-8"))

data =  client.recv(1024)

print(data.decode("utf-8"))

data =  client.recv(1024)

print(data.decode("utf-8"))

客户端

import time

import socket

c = socket.socket()

c.connect(("127.0.0.1",9090))

# c.send("abcdefg".encode("utf-8"))

c.send("bc".encode("utf-8"))

# time.sleep(1)

c.send("ca".encode("utf-8"))

# time.sleep(1)

c.send("da".encode("utf-8"))

相关文章