其他分享
首页 > 其他分享> > 自定义协议解决粘包问题,阿里云部署,udp协议套接字,socketserver模块的使用

自定义协议解决粘包问题,阿里云部署,udp协议套接字,socketserver模块的使用

作者:互联网

一:粘包问题解决

1.tcp流式协议

(1)粘包原因是底层的算法决定的,设计原因就是提升的效率,tcp流式协议会将时间间隔短,数据量小的字节 合到一起再去发送的。

(2)只有tcp流式协议才会有粘包现象,udp协议压根没有粘包此说

(3)发收数据是发给操作系统的接口的缓存,再送到对方的操作系统

(4)不是一个send唯一对应一个recv

 

2.模块struct的用法:

import struct,json
header_dic={
'filename':'a.tat',
'total_size':100,
'md5':45612
}
header_json = json.dumps(header_dic)
header_bytes = header_json.encode('utf-8')
header=struct.pack('i',14873) #i是int类型
print(header) #结果是:'\xd9\x90\x16\x00'
print(len(header))
total_size=struct.unpack('i',header)[0] #不加[0]结果会是:1478873,

print(total_size)

结果是:

b'\x19:\x00\x00'
4
14873

 

 

 

 

3.解决粘包的方法

服务端:

import subprocess
from socket import *
import struct,json

#1买手机
phone=socket(AF_INET,SOCK_STREAM)

#phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR)
#2绑定银行卡
phone.bind(('127.0.0.1',8081)) #元组内放自己的ip地址
#再次启动服务端,告诉端口已经占用,解决办法有:1.换个端口,8080换掉同时客户端也需要换掉 2.在绑定之前加上下面内容:phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR)
# 防止位置在 #2绑定银行卡 上面

#3开机
phone.listen(5)  #半连接池,5以内接受访问请求。  5是访问数量,也就是说除了正在访问的这个,最多再有5个

#4建立链接的请求
while True:       #需要一个循环不停地与客户端交互
    connect,client=phone.accept()
    print(client)

# 5 收/发消息
    while True:
        try:                           #避免客户端突然中断,不会造成服务端崩溃,针对Windows
            date=connect.recv(1024)    #此处的connect 是 connect,client=phone.accept() 处的,1024是最大的接受字节数
            if len(date)==0:           #针对linux系统的
                break
            cmd=date.decode('utf-8')
            obj=subprocess.Popen(cmd,shell=True,
                                 stdout=subprocess.PIPE,
                                 stderr=subprocess.PIPE)
            res1=obj.stdout.read()
            res2=obj.stderr.read()

            head_dic={
                'filename':'a.txt',
                'total_size':len(res1)+len(res2),
                'md5':'12345dvxvvv'
            }
            header_json=json.dumps(head_dic)
            head_bytes=header_json.encode('utf-8')

            #先发4个字节
            connect.send(struct.pack('i',len(head_bytes)))   #字节长度是4个
            #再发报头字典
            connect.send(head_bytes)
            #再发真正的数据
            connect.send(res1)
            connect.send(res2)
        except Exception:
            break
    connect.close()

 

客户端:


import subprocess
from socket import *
import struct,json

#1买手机
phone=socket(AF_INET,SOCK_STREAM)

#phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR)
#2绑定银行卡
phone.bind(('127.0.0.1',8081)) #元组内放自己的ip地址
#再次启动服务端,告诉端口已经占用,解决办法有:1.换个端口,8080换掉同时客户端也需要换掉 2.在绑定之前加上下面内容:phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR)
# 防止位置在 #2绑定银行卡 上面

#3开机
phone.listen(5)  #半连接池,5以内接受访问请求。  5是访问数量,也就是说除了正在访问的这个,最多再有5个

#4建立链接的请求
while True:       #需要一个循环不停地与客户端交互
    connect,client=phone.accept()
    print(client)

# 5 收/发消息
    while True:
        try:                           #避免客户端突然中断,不会造成服务端崩溃,针对Windows
            date=connect.recv(1024)    #此处的connect 是 connect,client=phone.accept() 处的,1024是最大的接受字节数
            if len(date)==0:           #针对linux系统的
                break
            cmd=date.decode('utf-8')
            obj=subprocess.Popen(cmd,shell=True,
                                 stdout=subprocess.PIPE,
                                 stderr=subprocess.PIPE)
            res1=obj.stdout.read()
            res2=obj.stderr.read()

            head_dic={
                'filename':'a.txt',
                'total_size':len(res1)+len(res2),
                'md5':'12345dvxvvv'
            }
            header_json=json.dumps(head_dic)
            head_bytes=header_json.encode('utf-8')

            #先发4个字节
            connect.send(struct.pack('i',len(head_bytes)))   #字节长度是4个
            #再发报头字典
            connect.send(head_bytes)
            #再发真正的数据
            connect.send(res1)
            connect.send(res2)
        except Exception:
            break
    connect.close()

 

 

 

二:阿里云部署

1.部署步骤

(1)

1.登陆阿里云官网

https://cn.aliyun.com/
2.右上角注册,可以用支付宝扫码登陆
3.点左上角最新活动
4.然后往下拉有个精彩活动,,里面有个阿里云试用中心,点立即查看
5.然后选那个右上角有个人用户字样,可以试用一个月的,就可以试用了,但是好像要先实名注册一下

(2)

注册完就可以拿到一个公网IP地址,可以试用一个月,还有试用的时候,让你选网速,可以调成最大,就是5Mbps,反正都是免费的,还有最重要的一点,自动续费那个选项千万不要勾选

申请完还会给你发个短信,短信里会告诉你怎么设置密码,还会有小姐姐给你打电话,发邮箱,让你有问题联系她,密码是一定要设置的,不然上不去,好像还要设置一下端口

(3)

全部弄好以后,可以照这个网址https://www.cnblogs.com/kimyeee/p/7250560.html装一下python3,然后就可以当服务端用了

 

2.过程中

 

 

 

 

三:udp协议的套接字

特点:没有粘包,只管收发,不稳定,适用于访问和消息发送

服务端:


from socket import *
server=socket(AF_INET,SOCK_DGRAM)
server.bind(('127.0.0.1',9999))

while True:
    date,client_addr=server.recvfrom(1024)
    print(date,client_addr)
    server.sendto(date.upper(),client_addr)

 

客户端:


from socket import *
client=socket(AF_INET,SOCK_DGRAM)


while True:
    msg=input('>>>').strip()
    client.sendto(msg.encode('utf-8'),('127.0.0.1',9999))
    res,sever_adder=client.recvfrom(1024)
    print(res.decode('utf-8'))

 

三:socketsever模块的使用

 

功能在于同时并发几个客户端

服务端:

import socketserver
class MyRequestHandler(socketserver.BaseRequestHandler):
    def handle(self):
        while True:
            try:
                date=self.request.recv(1024)
                if len(date)==0:
                    break
                print(date)
                self.request.send(date.upper())
            except Exception:
                break
        self.request.close()

server=socketserver.ThreadingTCPServer(('127.0.0.1',8085),MyRequestHandler,bind_and_activate=True)
server.serve_forever()
客户端1:


import socket
#1买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)  #流式协议

#2打电话
phone.connect(('127.0.0.1',8085))

#3发/收数据
while True:
    msg=input('<<<<').strip()
    if len(msg)==0:                      #避免客户端输入是空的时候出现异常,下面的无法操作
        continue
    phone.send(msg.encode('utf-8'))
    date=phone.recv(1024)
    print(date.decode('utf-8'))

#4关闭
phone.close()

 

客户端2:


import socket
#1买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)  #流式协议

#2打电话
phone.connect(('127.0.0.1',8085))

#3发/收数据
while True:
    msg=input('<<<<').strip()
    if len(msg)==0:                      #避免客户端输入是空的时候出现异常,下面的无法操作
        continue
    phone.send(msg.encode('utf-8'))
    date=phone.recv(1024)
    print(date.decode('utf-8'))

#4关闭
phone.close()

 

标签:udp,自定义,socketserver,phone,connect,date,import,True,socket
来源: https://www.cnblogs.com/dayday-up-a/p/14295216.html