粘包3

用tcp协议进行远程控制；服务端代码：

解决粘包方法一：

from socket import *
import subprocess

tcp_server = socket(AF_INET, SOCK_STREAM)
tcp_server.bind(('127.0.0.1', 8080))
tcp_server.listen(128)
while True:
    print('等待新用户连接')
    coon, addr = tcp_server.accept()
    print('新的客户端连接：', addr)
    while True:
        try:
            cmd = coon.recv(1024)
            print('执行的命令为', cmd.decode())
            res = subprocess.Popen(cmd.decode(), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                   stdin=subprocess.PIPE)
            err = res.stderr.read()
            if err:
                cmd_res = err
            else:
                cmd_res = res.stdout.read()
            if not cmd_res:
                cmd_res = '执行成功'.encode('GBK')
            length = len(cmd_res)  # 计算字节的长度，长度为整型
            coon.send(str(length).encode())  # 将字节的长度发送给客户端，注意需将整型变为字符串后在转化为字节发送。
            begin_start = coon.recv(1024)
            if begin_start.decode() == '开始接收':
                coon.send(cmd_res)

        except Exception as f:
            break

    coon.close()

客户端代码  ：

from socket import *

tcp_client = socket(AF_INET, SOCK_STREAM)
tcp_client.connect(('127.0.0.1', 8080))
while True:
    cmd = input('请输入指令：').strip()
    if not cmd: continue
    if cmd == 'quit': break
    tcp_client.send(cmd.encode())
    num = tcp_client.recv(1024)  # 收到的服务端发来的字节长度，注意此时为字节
    tcp_client.send('开始接收'.encode())
    num = int(num.decode())  # 将字节变为字符串（此字符串为整型字符串），然后变为整型
    recv_size = 0
    data = b''
    while recv_size < num:  # 比较收到字节长度和本来长度进行比较
        data += tcp_client.recv(102)  # 收到的字节进行拼接
        recv_size = len(data)  # 计算收到字节的长度
    print(data.decode('gbk'))  # 最后将收到的字节进行解码打印。

stuckt模块，可以直接将int整型直接变为字节

解决办法二：服务端

from socket import *
import subprocess
import struct
tcp_server = socket(AF_INET, SOCK_STREAM)
tcp_server.bind(('127.0.0.1', 8080))
tcp_server.listen(128)
while True:
    print('等待新用户连接')
    coon, addr = tcp_server.accept()
    print('新的客户端连接：', addr)
    while True:
        try:
            cmd = coon.recv(1024)
            print('执行的命令为', cmd.decode())
            res = subprocess.Popen(cmd.decode(), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                   stdin=subprocess.PIPE)
            err = res.stderr.read()
            if err:
                cmd_res = err
            else:
                cmd_res = res.stdout.read()
            if not cmd_res:
                cmd_res = '执行成功'.encode('GBK')
            length = len(cmd_res)  # 计算字节的长度，长度为整型
            # coon.send(str(length).encode())  # 将字节的长度发送给客户端，注意需将整型变为字符串后在转化为字节发送。
            # coon.send(struct.pack('i',length))
            length = struct.pack('i',length)
            coon.send(length)
            begin_start = coon.recv(1024)
            if begin_start.decode() == '开始接收':
                coon.send(cmd_res)

        except Exception as f:
            break

    coon.close()

客户端：

from socket import *
import struct
tcp_client = socket(AF_INET, SOCK_STREAM)
tcp_client.connect(('127.0.0.1', 8080))
while True:
    cmd = input('请输入指令：').strip()
    if not cmd: continue
    if cmd == 'quit': break
    tcp_client.send(cmd.encode())
    num = tcp_client.recv(1024)  # 收到的服务端发来的字节长度，注意此时为字节
    tcp_client.send('开始接收'.encode())
    # num = int(num.decode())  # 将字节变为字符串（此字符串为整型字符串），然后变为整型
    num = struct.unpack('i',num)[0]
    recv_size = 0
    data = b''
    while recv_size < num:  # 比较收到字节长度和本来长度进行比较
        data += tcp_client.recv(102)  # 收到的字节进行拼接
        recv_size = len(data)  # 计算收到字节的长度
    print(data.decode('gbk'))  # 最后将收到的字节进行解码打印。

解决办法三，迭代器和偏函数公用：

迭代器和偏函数  如下：

from functools import partial  # 偏函数


def add(x, y):
    return x + y


func = partial(add, 1)  # 偏函数可以固定一个函数的第一个值
print(func(1))
print(func(5))
l = [1, 2, 3, 4, 5, 6]


def test():
    return l.pop()


f = iter(test, 4)
print(f.__next__())
print(f.__next__())
print(f.__next__())

 待续