一 tcp网络编程
server 端 import socket
sk=socket.socket() #实例化一个对象
sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)#端口可以重用
sk.bind(('127.0.0.1',9100))
sk.listen()#监听
while True:
conn,addr=sk.accept() #阻塞，三次握手完毕
while True:
inp=input('请输入你要发送的消息：')
conn.send(inp.encode('utf-8'))
if inp == 'q': break
ret=conn.recv(1024).decode('utf-8')
if ret == 'q': break
print(ret) conn.close()
sk.close()
client端
1 import socket
sk=socket.socket()
#while True:
sk.connect(('127.0.0.1',9100))
while True:
ret=(sk.recv(1024).decode('utf-8'))
if ret == 'q': break
print(ret)
inp=input('请输入你要发送的消息：')
sk.send(inp.encode('utf-8'))
if inp == 'q': break sk.close()
二 tcp粘包
1 发送方的缓存机制
发送数据时间间隔很短，数据了很小，会合到一起，产生粘包
服务端
#_*_coding:utf-8_*_
from socket import *
ip_port=('127.0.0.1',8080) tcp_socket_server=socket(AF_INET,SOCK_STREAM)
tcp_socket_server.bind(ip_port)
tcp_socket_server.listen(5) conn,addr=tcp_socket_server.accept() data1=conn.recv(10)
data2=conn.recv(10) print('----->',data1.decode('utf-8'))
print('----->',data2.decode('utf-8')) conn.close() 服务端
服务端
#_*_coding:utf-8_*_
import socket
BUFSIZE=1024
ip_port=('127.0.0.1',8080) s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
res=s.connect_ex(ip_port) s.send('hello'.encode('utf-8'))
s.send('egg'.encode('utf-8'))
客户端
2接收方的缓存机制
客户端发送了一段数据，服务端只收了一小部分，服务端下次再收的时候还是从缓冲区拿上次遗留的数据，产生粘包）
#_*_coding:utf-8_*_
from socket import *
ip_port=('127.0.0.1',8080) tcp_socket_server=socket(AF_INET,SOCK_STREAM)
tcp_socket_server.bind(ip_port)
tcp_socket_server.listen(5) conn,addr=tcp_socket_server.accept() data1=conn.recv(2) #一次没有收完整
data2=conn.recv(10)#下次收的时候,会先取旧的数据,然后取新的 print('----->',data1.decode('utf-8'))
print('----->',data2.decode('utf-8')) conn.close()
服务端
#_*_coding:utf-8_*_
import socket
BUFSIZE=1024
ip_port=('127.0.0.1',8080) s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
res=s.connect_ex(ip_port) s.send('hello egg'.encode('utf-8'))
客户端
三 解决粘包问题
import socket
import struct
sk=socket.socket()
sk.bind(('127.0.0.1',8090))
sk.listen()
conn,addr=sk.accept()
inp=input('>>>:').encode('utf-8')
inp_len=len(inp)#计算用户输入的长度
bytes_msg=struct.pack('i',inp_len)#将数字转换成固定的bytes
conn.send(bytes_msg) #先发送报头的长度4个bytes
conn.send(inp)#在发送报头的字节格式
conn.send(b'alex sb')#最后发送真实内容的字节格式
conn.close()
sk.close()
服务端
import socket
import struct
sk=socket.socket()
sk.connect(('127.0.0.1',8090))
num=sk.recv(4) #先接受bytes的长度
num=struct.unpack('i',num)[0]#提取报文的长度
print(sk.recv(num).decode('utf-8'))
print(sk.recv(10)) sk.close()
客户端
四 udp
udp server端 import socket
sk=socket.socket(type=socket.SOCK_DGRAM)
sk.bind(('127.0.0.1',8899))
while True:
msg,addr=sk.recvfrom(1024)
print(msg.decode('utf-8'),addr)
inp=input('>>>:')
if inp=='q':break
sk.sendto(inp.encode('utf-8'),addr)
#print(msg)
sk.close()
udp client import socket
sk=socket.socket(type=socket.SOCK_DGRAM)
sk.bind(('127.0.0.1',8899))
while True:
msg,addr=sk.recvfrom(1024)
print(msg.decode('utf-8'),addr)
inp=input('>>>:')
if inp=='q':break
sk.sendto(inp.encode('utf-8'),addr)
#print(msg)
sk.close()