码迷,mamicode.com
首页 > 其他好文 > 详细

网络编程粘包问题

时间:2018-05-16 00:44:40      阅读:171      评论:0      收藏:0      [点我收藏+]

标签:listen   粘包   decode   receive   tput   open   oca   put   auth   

    首先说为什么会粘包,在py2上运行时,服务器把两次发送的操作强制的合成一次发送给客户端,所以 粘在一起了,因为python3的版本是可以的,但是有的时候python3也会出现粘包现象。

  解决粘包的问题有两种方法:

    1  可以先sleep一下,这个样子就可以使缓冲区超时,就不在等下一次的了,这样就可以和下一条命令隔离开了

    2  我在服务端来一个等待客户端确认,就ok了,这个确认不需要我们用户输入,而是客户端自动的给你来这个响应,就是说,客户端自动的写好代码,自动的给服务器一个响应,只要收到服务端的数据大小,我就立刻给服务器一个响应,就是在第一次send和第二次send之前插入一个交互,就能把数据分开了。

      下面也有两次send 的原因。

 

 

代码:中间空白分割的部分

#!usr/bin/env phthon3
# -*- coding:utf-8 -*-
# _Author_:"zhang Yaoqing"

import socket

client = socket.socket()
client.connect(("localhost", 9999))

while True:
    cmd = input(">>>:").strip()
    if len(cmd) == 0: continue
    client.send(cmd.encode("utf-8"))
    cmd_res_size = client.recv(500)  # 接收命令的长度
    print("命令结果大小:", cmd_res_size.decode())


    client.send(准备好了,可以发送了.encode(utf-8))       # 客户端已经确认。



    recevied_size = 0  # 接收客户端发来数据的计算器
    recevied_data = b‘‘  # 客户端每次发来内容的计数器
    while recevied_size < int(cmd_res_size.decode()):  # 当接收的数据大小 小于 客户端发来的数据
        cmd_res = client.recv(500)
        recevied_size += len(cmd_res)  # 每次收到的服务端的数据有可能小于1024,所以必须用len判断
        recevied_data += cmd_res
    else:
        print(recevied_data.decode("utf-8", "ignore"))
        print("cmd res receive done ....", recevied_size)

 

#!usr/bin/env phthon3
# -*- coding:utf-8 -*-
# _Author_:"zhang Yaoqing"

import socket, os

server = socket.socket()
server.bind(("localhost", 9999))
server.listen(5)
while True:
    conn, addr = server.accept()
    print("new addr:", addr)
    print(conn,conn)
    while True:
        data = conn.recv(500)
        if not data:
            print("客户端已断开")
            break
        print("执行指令:", data)
        cmd_res = os.popen(data.decode()).read()
        print("before send:", len(cmd_res))
        if len(cmd_res) == 0:
            cmd_res = "cmd has no output...."
        conn.send(str(len(cmd_res.encode())).encode())  # 发送服务端发送给客户端数据的长度


        client_ack = conn.recv(1024)  # 等待确认


        conn.send(cmd_res.encode("utf-8"))  # 发送服务端的数据
        print("send done")

 

网络编程粘包问题

标签:listen   粘包   decode   receive   tput   open   oca   put   auth   

原文地址:https://www.cnblogs.com/littlesky1124/p/9043593.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!