爱了散了演员表,尖锐湿疣能彻底治好吗,配钥匙
tcp协议传输数据存在粘包现象,udp协议不存在粘包协议。
1.发生在发送端的粘包
由于两个数据的发送时间间隔短+数据的长度小,所以由tcp协议的优化机制将两条信息作为一条信息发送出去了,是为了减少tcp协议中的“确认收到”的网络延迟时间
2.在接收端的粘包
由于tcp协议中所传输的数据无边界,所以来不及接收的多条数据会在接收方的内核的缓存端黏在一起
3.本质: 接收信息的边界不清晰
1.自定义协议1:
a.首先发送报头
报头长度4个字节
内容是 即将发送的报文的字节长度
struct模块
b.再发送报文
2.自定义协议2
专门用来做文件发送的协议
1.三次握手
三次握手的过程在代码中是由accept和connect共同完成的,具体的细节再socket中没有体现出来
2.四次挥手
io模型种类:
server端同时与多个client客户端之间的聊天:
socket的非阻塞io模型 + io多路复用实现的
虽然非阻塞,提高了cpu的利用率,但是耗费cpu做了很多无用功
# server.py import socket sk = socket.socket() sk.bind(('127.0.0.1',9000)) sk.setblocking(false) # 非阻塞,setblocking()的参数为false时,表示非阻塞,如果参数不写,默认为true。 sk.listen() conn_l = [] del_l = [] while true: try: conn,addr = sk.accept() # 阻塞,直到有一个客户端来连我 print(conn) conn_l.append(conn) except blockingioerror: for c in conn_l: try: msg = c.recv(1024).decode('utf-8') if not msg: del_l.append(c) continue print('-->',[msg]) c.send(msg.upper().encode('utf-8')) except blockingioerror:pass for c in del_l: conn_l.remove(c) del_l.clear() sk.close() # client.py import time import socket sk = socket.socket() sk.connect(('127.0.0.1',9000)) for i in range(30): sk.send(b'zhangsan') msg = sk.recv(1024) print(msg) time.sleep(0.2) sk.close()
客户端是提供给 用户使用的 —— 登陆验证
你的用户 就能看到你的client端源码了,用户就不需要自己写客户端了
客户端是提供给 机器使用的 —— 验证客户端的合法性
防止非法用户进入服务端窃取内部重要信息
# server.py import os import hashlib import socket def get_md5(secret_key,randseq): md5 = hashlib.md5(secret_key) md5.update(randseq) res = md5.hexdigest() return res def chat(conn): while true: msg = conn.recv(1024).decode('utf-8') print(msg) conn.send(msg.upper().encode('utf-8')) sk = socket.socket() sk.bind(('127.0.0.1',9000)) sk.listen() secret_key = b'names' while true: conn,addr = sk.accept() randseq = os.urandom(32) conn.send(randseq) md5code = get_md5(secret_key,randseq) ret = conn.recv(32).decode('utf-8') print(ret) if ret == md5code: print('是合法的客户端') chat(conn) else: print('不是合法的客户端') conn.close() sk.close() # client.py import hashlib import socket import time def get_md5(secret_key,randseq): md5 = hashlib.md5(secret_key) md5.update(randseq) res = md5.hexdigest() return res def chat(sk): while true: sk.send(b'hello') msg = sk.recv(1024).decode('utf-8') print(msg) time.sleep(0.5) sk = socket.socket() sk.connect(('127.0.0.1',9000)) secret_key = b'names' randseq = sk.recv(32) md5code = get_md5(secret_key,randseq) sk.send(md5code.encode('utf-8')) chat(sk) sk.close()
socketserver模块解决了socket的阻塞问题,直接实现tcp协议可并发的server端
# server.py import socketserver class myserver(socketserver.baserequesthandler): def handle(self): # 自动触发了handle方法,并且self.request == conn msg = self.request.recv(1024).decode('utf-8') self.request.send('1'.encode('utf-8')) msg = self.request.recv(1024).decode('utf-8') self.request.send('2'.encode('utf-8')) msg = self.request.recv(1024).decode('utf-8') self.request.send('3'.encode('utf-8')) server = socketserver.threadingtcpserver(('127.0.0.1',9000),myserver) server.serve_forever() # client.py import socket import time sk = socket.socket() sk.connect(('127.0.0.1',9000)) for i in range(3): sk.send(b'hello,yuan') msg = sk.recv(1024) print(msg) time.sleep(1) sk.close()
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
新手学习Python2和Python3中print不同的用法
Python基于os.environ从windows获取环境变量
网友评论