解决tcp粘包问题的两种办法

# __author__:Kelvin

# date:2019/4/28 21:36

from socket import *

import subprocess

import struct

server = socket(AF_INET, SOCK_STREAM)

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

server.listen(5)

while True:

    conn, addr = server.accept()

    print("创建了一个新的连接！")

    while True:

        try:

            data = conn.recv(1024)

            if not data: break

            res = subprocess.Popen(data.decode("utf-8"), shell=True, stdout=subprocess.PIPE, stdin=subprocess.PIPE,

                                   stderr=subprocess.PIPE)

            err = res.stderr.read()

            if err:

                cmd_msg = err

            else:

                cmd_msg = res.stdout.read()

            if not cmd_msg: cmd_msg = "action success!".encode("gbk")

            length = len(cmd_msg)

            conn.send(struct.pack("i", length))

            conn.send(cmd_msg)

        except Exception as e:

            print(e)

            break