一 客户端/服务器架构
1.硬件C/S架构(打印机)
2.软件C/S架构
互联网中处处是C/S架构
如黄色网站是服务端，你的浏览器是客户端（B/S架构也是C/S架构的一种）
腾讯作为服务端为你提供视频，你得下个腾讯视频客户端才能看它的视频）
C/S架构与socket的关系：
我们学习socket就是为了完成C/S架构的开发
二 osi七层
引子：
须知一个完整的计算机系统是由硬件、操作系统、应用软件三者组成,具备了这三个条件，一台计算机系统就可以自己跟自己玩了（打个单机游戏，玩个扫雷啥的）
如果你要跟别人一起玩，那你就需要上网了，什么是互联网？
互联网的核心就是由一堆协议组成，协议就是标准，比如全世界人通信的标准是英语
如果把计算机比作人，互联网协议就是计算机界的英语。所有的计算机都学会了互联网协议，那所有的计算机都就可以按照统一的标准去收发信息从而完成通信了。
人们按照分工不同把互联网协议从逻辑上划分了层级，
详见网络通信原理：http://www.cnblogs.com/linhaifeng/articles/5937962.html
为何学习socket一定要先学习互联网协议：
1.首先：本节课程的目标就是教会你如何基于socket编程，来开发一款自己的C/S架构软件
2.其次：C/S架构的软件（软件属于应用层）是基于网络进行通信的
3.然后：网络的核心即一堆协议，协议即标准，你想开发一款基于网络通信的软件，就必须遵循这些标准。
4.最后：就让我们从这些标准开始研究，开启我们的socket编程之旅
图1
三 socket层
在图1中，我们没有看到Socket的影子，那么它到底在哪里呢？还是用图来说话，一目了然。
图2
四 socket是什么
Socket是应用层与TCP/IP协议族通信的中间软件抽象层，它是一组接口。在设计模式中，Socket其实就是一个门面模式，它把复杂的TCP/IP协议族隐藏在Socket接口后面，对用户来说，一组简单的接口就是全部，让Socket去组织数据，以符合指定的协议。
所以，我们无需深入理解tcp/udp协议，socket已经为我们封装好了，我们只需要遵循socket的规定去编程，写出的程序自然就是遵循tcp/udp标准的。
五 套接字发展史及分类
套接字起源于 20 世纪 70 年代加利福尼亚大学伯克利分校版本的 Unix,即人们所说的 BSD Unix。 因此,有时人们也把套接字称为“伯克利套接字”或“BSD 套接字”。一开始,套接字被设计用在同 一台主机上多个应用程序之间的通讯。这也被称进程间通讯,或 IPC。套接字有两种（或者称为有两个种族）,分别是基于文件型的和基于网络型的。
基于文件类型的套接字家族
套接字家族的名字：AF_UNIX
unix一切皆文件，基于文件的套接字调用的就是底层的文件系统来取数据，两个套接字进程运行在同一机器，可以通过访问同一个文件系统间接完成通信
基于网络类型的套接字家族套接字家族的名字：AF_INET
(还有AF_INET6被用于ipv6，还有一些其他的地址家族，不过，他们要么是只用于某个平台，要么就是已经被废弃，或者是很少被使用，或者是根本没有实现，所有地址家族中，AF_INET是使用最广泛的一个，python支持很多种地址家族，但是由于我们只关心网络编程，所以大部分时候我么只使用AF_INET)
六 套接字工作流程
一个生活中的场景。你要打电话给一个朋友，先拨号，朋友听到电话铃声后提起电话，这时你和你的朋友就建立起了连接，就可以讲话了。等交流结束，挂断电话结束此次交谈。 生活中的场景就解释了这工作原理。
图3
先从服务器端说起。服务器端先初始化Socket，然后与端口绑定(bind)，对端口进行监听(listen)，调用accept阻塞，等待客户端连接。在这时如果有个客户端初始化一个Socket，然后连接服务器(connect)，如果连接成功，这时客户端与服务器端的连接就建立了。客户端发送数据请求，服务器端接收请求并处理请求，然后把回应数据发送给客户端，客户端读取数据，最后关闭连接，一次交互结束
socket()模块函数用法
import socket socket.socket(socket_family,socket_type,protocal=0) socket_family 可以是 AF_UNIX 或 AF_INET。socket_type 可以是 SOCK_STREAM 或 SOCK_DGRAM。protocol 一般不填,默认值为 0。 获取tcp/ip套接字 tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 获取udp/ip套接字 udpSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 由于 socket 模块中有太多的属性。我们在这里破例使用了'from module import *'语句。使用 'from socket import *',我们就把 socket 模块里的所有属性都带到我们的命名空间里了,这样能 大幅减短我们的代码。 例如tcpSock = socket(AF_INET, SOCK_STREAM)
服务端套接字函数
s.bind() 绑定(主机,端口号)到套接字
s.listen() 开始TCP监听
s.accept() 被动接受TCP客户的连接,(阻塞式)等待连接的到来
客户端套接字函数
s.connect() 主动初始化TCP服务器连接
s.connect_ex() connect()函数的扩展版本,出错时返回出错码,而不是抛出异常
公共用途的套接字函数
s.recv() 接收TCP数据
s.send() 发送TCP数据(send在待发送数据量大于己端缓存区剩余空间时,数据丢失,不会发完)
s.sendall() 发送完整的TCP数据(本质就是循环调用send,sendall在待发送数据量大于己端缓存区剩余空间时,数据不丢失,循环调用send直到发完)
s.recvfrom() 接收UDP数据
s.sendto() 发送UDP数据
s.getpeername() 连接到当前套接字的远端的地址
s.getsockname() 当前套接字的地址
s.getsockopt() 返回指定套接字的参数
s.setsockopt() 设置指定套接字的参数
s.close() 关闭套接字
面向锁的套接字方法
s.setblocking() 设置套接字的阻塞与非阻塞模式
s.settimeout() 设置阻塞套接字操作的超时时间
s.gettimeout() 得到阻塞套接字操作的超时时间
面向文件的套接字的函数
s.fileno() 套接字的文件描述符
s.makefile() 创建一个与该套接字相关的文件
1：用打电话的流程快速描述socket通信
2：服务端和客户端加上基于一次链接的循环通信
3：客户端发送空，卡主，证明是从哪个位置卡的
服务端：
from socket import *
phone=socket(AF_INET,SOCK_STREAM)
phone.bind(('127.0.0.1',8081))
phone.listen(5)
conn,addr=phone.accept()
while True:
data=conn.recv(1024)
print('server===>')
print(data)
conn.send(data.upper())
conn.close()
phone.close()
客户端：
from socket import *
phone=socket(AF_INET,SOCK_STREAM)
phone.connect(('127.0.0.1',8081))
while True:
msg=input('>>: ').strip()
phone.send(msg.encode('utf-8'))
print('client====>')
data=phone.recv(1024)
print(data)
说明卡的原因：缓冲区为空recv就卡住，引出原理图
4.演示客户端断开链接，服务端的情况，提供解决方法
5.演示服务端不能重复接受链接，而服务器都是正常运行不断来接受客户链接的
6:简单演示udp
服务端
from socket import *
phone=socket(AF_INET,SOCK_DGRAM)
phone.bind(('127.0.0.1',8082))
while True:
msg,addr=phone.recvfrom(1024)
phone.sendto(msg.upper(),addr)
客户端
from socket import *
phone=socket(AF_INET,SOCK_DGRAM)
while True:
msg=input('>>: ')
phone.sendto(msg.encode('utf-8'),('127.0.0.1',8082))
msg,addr=phone.recvfrom(1024)
print(msg)
udp客户端可以并发演示
udp客户端可以输入为空演示，说出recvfrom与recv的区别，暂且不提tcp流和udp报的概念，留到粘包去说
读者勿看：socket实验推演流程
七 基于TCP的套接字
tcp是基于链接的，必须先启动服务端，然后再启动客户端去链接服务端
1.简单套接字
a.服务器端
import socket
#1 买手机
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#2 绑定手机卡
phone.bind(('127.0.0.1', 10000)) # 0-65535 0-1024给操作系统，
#3 开机
phone.listen(5) # 最大挂起链接数5
#4 等电话链接
print('stearting')
conn, client_addr = phone.accept()
# print(res)
print('ending')
#5 收发消息
date = conn.recv(1024) # 接受数据的最大数1024个bytes， 单位bytes
print('客户端的数据', date)
conn.send(date.upper())
#6 挂电话
conn.close()
#7 关机
phone.close()
b.客户端
import socket
#1 买手机
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#2 拨号
phone.connect(('127.0.0.1', 10000))
#3 发收消息
phone.send('hello'.encode('utf-8'))
date = phone.recv(1024)
print(date)
# 4 关闭
phone.close()
2.加上通讯循环
a.服务器端
import socket
#1 买手机
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#2 绑定手机卡
phone.bind(('127.0.0.1', 10000)) # 0-65535 0-1024给操作系统，
#3 开机
phone.listen(5) # 最大挂起链接数5
#4 等电话链接
print('stearting')
conn, client_addr = phone.accept()
print(client_addr)
#5 收发消息
while True: # 通信循环
date = conn.recv(1024) # 接受数据的最大数1024个bytes， 单位bytes
print('客户端的数据', date)
conn.send(date.upper())
#6 挂电话
conn.close()
#7 关机
phone.close()
b.客户端
import socket
#1 买手机
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#2 拨号
phone.connect(('127.0.0.1', 10000))
print(phone)
#3 发收消息
while True: # 循环通信
msg = input('>>:').strip()
phone.send(msg.encode('utf-8'))
date = phone.recv(1024)
print(date)
# 4 关闭
phone.close()
3.加上链接循环
a.服务器端
import socket
#1 买手机
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # 回收重用端口10000
#2 绑定手机卡
phone.bind(('127.0.0.1', 10000)) # 0-65535 0-1024给操作系统，
#3 开机
phone.listen(5) # 最大挂起链接数5
#4 等电话链接
print('stearting')
while True: # 建链接循环
conn, client_addr = phone.accept()
print(client_addr)
#5 收发消息
while True: # 通信循环
try:
date = conn.recv(1024) # linux断开之后会发''空的过来，windows会报错
print('客户端的数据', date)
conn.send(date.upper())
except ConnectionResetError:
break
#6 挂电话
conn.close()
#7 关机
phone.close()
b.客户端
import socket
#1 买手机
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#2 拨号
phone.connect(('127.0.0.1', 10000))
#3 发收消息
while True: # 循环通信
msg = input('>>:').strip() # mag = ''
if not msg:
continue
phone.send(msg.encode('utf-8')) # phone..send(b'')
date = phone.recv(1024)
print(date.decode('utf-8'))
# 4 关闭
phone.close()
4.模拟ssh远程执行命令
（补充）
# windows #dir:查看某一个文件夹下的子文件名与子文件夹名 #ipconfig：查看本机网卡的ip信息 #tasklist：查看运行的进程 # linux #ls #ifconfia #ps aux # 执行系统命令 # import os # res = os.system('dir') # print(res) # 命令执行成功0，非0表示失败了 # 不能返回结果 import subprocess o = subprocess.Popen('dir', shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) print(o) print(o.stdout.read().decode('gbk')) print(o.stderr.read().decode('gbk'))
a.服务器端
import socket
import subprocess
#1 买手机
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # 回收重用端口10000
#2 绑定手机卡
phone.bind(('127.0.0.1', 10000)) # 0-65535 0-1024给操作系统，
#3 开机
phone.listen(5) # 最大挂起链接数5
#4 等电话链接
print('stearting')
while True: # 建链接循环
conn, client_addr = phone.accept()
print(client_addr)
#5 收发消息
while True: # 通信循环
try:
# 1收命令
cmd = conn.recv(1024) # linux断开之后会发''空的过来，windows会报错
print('客户端的数据', cmd)
# 2执行命令
o = subprocess.Popen(cmd.decode('utf-8'), shell=True,
stdout=subprocess.PIPE,
stderr=subprocess.PIPE)
stdout = o.stdout.read()
stdeer = o.stderr.read()
# 3返回命令执行的结果
print(len(stdeer) + len(stdout))
conn.send(stdout + stdeer) # +是一个可以优化的点
except ConnectionResetError:
break
#6 挂电话
conn.close()
#7 关机
phone.close()
b.服务器端
import socket
#1 买手机
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#2 拨号
phone.connect(('127.0.0.1', 10000))
#3 发收消息
while True: # 循环通信
cmd = input('>>:').strip() # mag = ''
if not cmd:
continue
phone.send(cmd.encode('utf-8')) # phone..send(b'')
date = phone.recv(1024) # 1024是一个可能的坑
print(date.decode('gbk'))
# 4 关闭
phone.close()
基于UDP的套接字
udp是无链接的，先启动哪一端都不会报错
udp服务端
1 ss = socket() #创建一个服务器的套接字 2 ss.bind() #绑定服务器套接字 3 inf_loop: #服务器无限循环 4 cs = ss.recvfrom()/ss.sendto() # 对话(接收与发送) 5 ss.close() # 关闭服务器套接字
udp客户端
cs = socket() # 创建客户套接字
comm_loop: # 通讯循环
cs.sendto()/cs.recvfrom() # 对话(发送/接收)
cs.close() # 关闭客户套接字
服务器端
from socket import *
server = socket(AF_INET, SOCK_DGRAM)
server.bind(('127.0.0.1', 10000))
while True:
date, client_addr = server.recvfrom(1024) # 可以发空，会带client_addr
print(date)
print(client_addr)
server.sendto(date.upper(), client_addr)
server.close()
客户端
from socket import *
client = socket(AF_INET, SOCK_DGRAM)
while True:
msg = input('>>>:').strip()
client.sendto(msg.encode('utf-8'), ('127.0.0.1', 10000))
date, server = client.recvfrom(1024)
print(date)
client.close()
udp实现的聊天
服务端
__author__ = 'Administrator'
from socket import *
s=socket(AF_INET,SOCK_DGRAM)
s.bind(("127.0.0.1",8083))
while True:
msg,client_addr=s.recvfrom(1024)
if not msg: break
print("来自%s的消息：%s"%(client_addr,msg.decode("utf-8")))
req=input("回复消息:").strip()
s.sendto(req.encode("utf-8"),client_addr)
s.close()
客户端
__author__ = 'Administrator'
from socket import *
c=socket(AF_INET,SOCK_DGRAM)
name_dic={
"xiaoming":("127.0.0.1",8083),
"xiaodong":("127.0.0.1",8083),
"xiaohong":("127.0.0.1",8083),
}
print(name_dic)
while True:
name=input("请选择聊天对象:").strip()
if not name or name not in name_dic:continue
while True:
msg=input(">>").strip()
if not msg:continue
c.sendto(msg.encode("utf-8"),("127.0.0.1",8083))
rec_data,serv_addr=c.recvfrom(1024)
print("收到%s的消息:%s"%(serv_addr,rec_data.decode("utf-8")))
c.close()
九 粘包现象
让我们基于tcp先制作一个远程执行命令的程序（1：执行错误命令 2：执行ls 3：执行ifconfig）
注意注意注意：
res=subprocess.Popen(cmd.decode('utf-8'),
shell=True,
stderr=subprocess.PIPE,
stdout=subprocess.PIPE)
的结果的编码是以当前所在的系统为准的，如果是windows，那么res.stdout.read()读出的就是GBK编码的，在接收端需要用GBK解码
且只能从管道里读一次结果
注意：命令ls -l ; lllllll ; pwd 的结果是既有正确stdout结果，又有错误stderr结果
TCP
服务器端
#_*_coding:utf-8_*_
__author__ = 'Linhaifeng'
from socket import *
import subprocess
ip_port=('127.0.0.1',8080)
BUFSIZE=1024
tcp_socket_server=socket(AF_INET,SOCK_STREAM)
tcp_socket_server.bind(ip_port)
tcp_socket_server.listen(5)
while True:
conn,addr=tcp_socket_server.accept()
print('客户端',addr)
while True:
cmd=conn.recv(BUFSIZE)
if len(cmd) == 0:break
res=subprocess.Popen(cmd.decode('utf-8'),shell=True,
stdout=subprocess.PIPE,
stdin=subprocess.PIPE,
stderr=subprocess.PIPE)
stderr=act_res.stderr.read()
stdout=act_res.stdout.read()
conn.send(stderr)
conn.send(stdout)
客户端
#_*_coding:utf-8_*_
__author__ = 'Linhaifeng'
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)
while True:
msg=input('>>: ').strip()
if len(msg) == 0:continue
if msg == 'quit':break
s.send(msg.encode('utf-8'))
act_res=s.recv(BUFSIZE)
print(act_res.decode('utf-8'),end='')
上述程序是基于tcp的socket，在运行时会发生粘包
udp
让我们再基于udp制作一个远程执行命令的程序
服务器端
#_*_coding:utf-8_*_
__author__ = 'Linhaifeng'
#_*_coding:utf-8_*_
__author__ = 'Linhaifeng'
from socket import *
import subprocess
ip_port=('127.0.0.1',9003)
bufsize=1024
udp_server=socket(AF_INET,SOCK_DGRAM)
udp_server.bind(ip_port)
while True:
#收消息
cmd,addr=udp_server.recvfrom(bufsize)
print('用户命令----->',cmd)
#逻辑处理
res=subprocess.Popen(cmd.decode('utf-8'),shell=True,stderr=subprocess.PIPE,stdin=subprocess.PIPE,stdout=subprocess.PIPE)
stderr=res.stderr.read()
stdout=res.stdout.read()
#发消息
udp_server.sendto(stderr,addr)
udp_server.sendto(stdout,addr)
udp_server.close()
客户端
from socket import *
ip_port=('127.0.0.1',9003)
bufsize=1024
udp_client=socket(AF_INET,SOCK_DGRAM)
while True:
msg=input('>>: ').strip()
udp_client.sendto(msg.encode('utf-8'),ip_port)
data,addr=udp_client.recvfrom(bufsize)
print(data.decode('utf-8'),end='')
上述程序是基于udp的socket，在运行时永远不会发生粘包
什么是粘包
须知：只有TCP有粘包现象，UDP永远不会粘包，为何，且听我娓娓道来
首先需要掌握一个socket收发消息的原理
发送端可以是一K一K地发送数据，而接收端的应用程序可以两K两K地提走数据，当然也有可能一次提走3K或6K数据，或者一次只提走几个字节的数据，也就是说，应用程序所看到的数据是一个整体，或说是一个流（stream），一条消息有多少字节对应用程序是不可见的，因此TCP协议是面向流的协议，这也是容易出现粘包问题的原因。而UDP是面向消息的协议，每个UDP段都是一条消息，应用程序必须以消息为单位提取数据，不能一次提取任意字节的数据，这一点和TCP是很不同的。怎样定义消息呢？可以认为对方一次性write/send的数据为一个消息，需要明白的是当对方send一条信息的时候，无论底层怎样分段分片，TCP协议层会把构成整条消息的数据段排序完成后才呈现在内核缓冲区。
例如基于tcp的套接字客户端往服务端上传文件，发送时文件内容是按照一段一段的字节流发送的，在接收方看了，根本不知道该文件的字节流从何处开始，在何处结束
所谓粘包问题主要还是因为接收方不知道消息之间的界限，不知道一次性提取多少字节的数据所造成的。
此外，发送方引起的粘包是由TCP协议本身造成的，TCP为提高传输效率，发送方往往要收集到足够多的数据后才发送一个TCP段。若连续几次需要send的数据都很少，通常TCP会根据优化算法把这些数据合成一个TCP段后一次发送出去，这样接收方就收到了粘包数据。
- TCP（transport control protocol，传输控制协议）是面向连接的，面向流的，提供高可靠性服务。收发两端（客户端和服务器端）都要有一一成对的socket，因此，发送端为了将多个发往接收端的包，更有效的发到对方，使用了优化方法（Nagle算法），将多次间隔较小且数据量小的数据，合并成一个大的数据块，然后进行封包。这样，接收端，就难于分辨出来了，必须提供科学的拆包机制。 即面向流的通信是无消息保护边界的。
- UDP（user datagram protocol，用户数据报协议）是无连接的，面向消息的，提供高效率服务。不会使用块的合并优化算法，, 由于UDP支持的是一对多的模式，所以接收端的skbuff(套接字缓冲区）采用了链式结构来记录每一个到达的UDP包，在每个UDP包中就有了消息头（消息来源地址，端口等信息），这样，对于接收端来说，就容易进行区分处理了。 即面向消息的通信是有消息保护边界的。
- tcp是基于数据流的，于是收发的消息不能为空，这就需要在客户端和服务端都添加空消息的处理机制，防止程序卡住，而udp是基于数据报的，即便是你输入的是空内容（直接回车），那也不是空消息，udp协议会帮你封装上消息头，实验略
udp的recvfrom是阻塞的，一个recvfrom(x)必须对唯一一个sendinto(y),收完了x个字节的数据就算完成,若是y>x数据就丢失，这意味着udp根本不会粘包，但是会丢数据，不可靠
tcp的协议数据不会丢，没有收完包，下次接收，会继续上次继续接收，己端总是在收到ack时才会清除缓冲区内容。数据是可靠的，但是会粘包。
两种情况下会发生粘包。
发送端需要等缓冲区满才发送出去，造成粘包（发送数据时间间隔很短，数据了很小，会合到一起，产生粘包）
#_*_coding:utf-8_*_
__author__ = 'Linhaifeng'
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_*_
__author__ = 'Linhaifeng'
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('feng'.encode('utf-8'))
客户端
接收方不及时接收缓冲区的包，造成多个包接收（客户端发送了一段数据，服务端只收了一小部分，服务端下次再收的时候还是从缓冲区拿上次遗留的数据，产生粘包）
#_*_coding:utf-8_*_
__author__ = 'Linhaifeng'
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_*_
__author__ = 'Linhaifeng'
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 feng'.encode('utf-8'))
客户端
拆包的发生情况
当发送端缓冲区的长度大于网卡的MTU时，tcp会将这次发送的数据拆成几个数据包发送出去。
补充问题一：为何tcp是可靠传输，udp是不可靠传输
基于tcp的数据传输请参考我的另一篇文章http://www.cnblogs.com/linhaifeng/articles/5937962.html，tcp在数据传输时，发送端先把数据发送到自己的缓存中，然后协议控制将缓存中的数据发往对端，对端返回一个ack=1，发送端则清理缓存中的数据，对端返回ack=0，则重新发送数据，所以tcp是可靠的
而udp发送数据，对端是不会返回确认信息的，因此不可靠
补充问题二：send(字节流)和recv(1024)及sendall
recv里指定的1024意思是从缓存里一次拿出1024个字节的数据
send的字节流是先放入己端缓存，然后由协议控制将缓存内容发往对端，如果待发送的字节流大小大于缓存剩余空间，那么数据丢失，用sendall就会循环调用send，数据不会丢失
解决沾包
为字节流加上自定义固定长度报头，报头中包含字节流长度，然后一次send到对端，对端在接收时，先从缓存中取出定长的报头，然后再取真实数据
struct模块
该模块可以把一个类型，如数字，转成固定长度的bytes
>>> struct.pack('i',1111111111111)
。。。。。。。。。
struct.error: 'i' format requires -2147483648 <= number <= 2147483647 #这个是范围
import struct import json # res = struct.pack('i', 1230) # 打包 # print(res, type(res), len(res)) # # #client.recv(4) # ans = struct.unpack('i', res) # print(ans[0]) # print(ans, type(ans), len(ans)) # res = struct.pack('i', 12222222220) # 被报错 # res = struct.pack('l', 123123) # re = struct.pack('i', 123123) # print(res, type(res), len(res)) # print(re, type(re), len(re)) header_dic = { 'filename': 'a.text', 'md5': 'xxdxx', 'total_size': 65465456123123 } header_json = json.dumps(header_dic) print(header_json, type(header_json)) header_bytes = header_json.encode('utf-8') print(type(header_bytes)) print(len(header_bytes))
一、简单版
服务端
import socket
import subprocess
import struct
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # 回收重用端口10000
phone.bind(('127.0.0.1', 10000)) # 0-65535 0-1024给操作系统，
phone.listen(5)
print('stearting')
while True: # 建链接循环
conn, client_addr = phone.accept()
print(client_addr)
while True: # 通信循环
try:
cmd = conn.recv(1024) # linux断开之后会发''空的过来，windows会报错
print('客户端的数据', cmd)
obj = subprocess.Popen(cmd.decode('utf-8'), shell=True,
stdout=subprocess.PIPE,
stderr=subprocess.PIPE)
stdout = obj.stdout.read()
stderr = obj.stderr.read()
# 把命令结果返回
# 1制作报头
total_size = len(stdout) + len(stderr)
header = struct.pack('i', total_size) # 固定长度4
# 2 发报头
conn.send(header)
# 3发内容
conn.send(stdout)
conn.send(stderr)
except ConnectionResetError:
break
conn.close()
phone.close()
客户端
import socket
import struct
pc = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
pc.connect(('127.0.0.1', 10000))
while True:
cmd = input('>>>:').strip()
if not cmd:
continue
pc.send(cmd.encode('utf-8'))
# 拿结果
# 1收报头
header = pc.recv(4)
# 2解析报头
total_size = struct.unpack('i', header)[0]
# 3 接受真实的数据
recv_size = 0
recv_data = b''
while recv_size < total_size:
res = pc.recv(1024)
recv_data += res
recv_size += len(res)
print(recv_data.decode('gbk'))
pc.close()
二、高级版本（加强版 json）
服务端
import socket
import subprocess
import struct
import json
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # 回收重用端口10000
phone.bind(('127.0.0.1', 10000)) # 0-65535 0-1024给操作系统，
phone.listen(5)
print('stearting')
while True: # 建链接循环
conn, client_addr = phone.accept()
print(client_addr)
while True: # 通信循环
try:
cmd = conn.recv(1024) # linux断开之后会发''空的过来，windows会报错
print('客户端的数据', cmd)
obj = subprocess.Popen(cmd.decode('utf-8'), shell=True,
stdout=subprocess.PIPE,
stderr=subprocess.PIPE)
stdout = obj.stdout.read()
stderr = obj.stderr.read()
# 把命令结果返回
# 1制作报头
header_dic = {
'filename': 'a.text',
'md5': 'xxdxx',
'total_size': len(stderr) + len(stdout)
}
header_json = json.dumps(header_dic)
header_bytes = header_json.encode('utf-8')
# 2 发送报头长度
conn.send(struct.pack('i', len(header_bytes))) # 固定长度4
# 3 发报头
conn.send(header_bytes)
# 4发传递内容
conn.send(stdout)
conn.send(stderr)
except ConnectionResetError:
break
conn.close()
phone.close()
obj = subprocess.Popen(cmd, shell=True,
stdout=subprocess.PIPE,
stderr=subprocess.PIPE)
stderr = obj.stderr.read()
stdout = obj.stdout.read()
客户端
import socket
import struct
import json
pc = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
pc.connect(('127.0.0.1', 10000))
while True:
cmd = input('>>>:').strip()
if not cmd:
continue
pc.send(cmd.encode('utf-8'))
# 拿结果
# 1收报头长度
obj = pc.recv(4)
header_size = struct.unpack('i', obj)[0]
# 2接收报头
header_bytes = pc.recv(header_size)
# 3解析报头
header_json = header_bytes.decode('utf-8')
header_dic = json.loads(header_json)
print(header_dic)
total_size = header_dic['total_size']
# 3 接受真实的数据
recv_size = 0
recv_data = b''
while recv_size < total_size:
res = pc.recv(1024)
recv_data += res
recv_size += len(res)
print(recv_data.decode('gbk'))
pc.close()
socketserver实现并发（下一章节并发编程中有详细讲解）
基于tcp的套接字，关键就是两个循环，一个链接循环，一个通信循环
socketserver模块中分两大类：server类（解决链接问题）和request类（解决通信问题）
import socketserver """ socketserver 使用模式 1 功能类 class Myserver(socketserver.BaseRequestHandler): def handle(self): pass 2 socketserver.ThreadingTCPServer(('127.0.0.1', 10000), Myserver) 3 server.serve_forever() """ class Myserver(socketserver.BaseRequestHandler): def handle(self): """ 并发的业务逻辑 conn:self.requset :return: """ while True: client_data = self.request.recv(1024) print(client_data.decode('utf-8')) if client_data.decode('utf-8') == 'exit': print('客户端断开连接，等待链接') break print('接收数据>>>', str(client_data, 'utf-8')) self.request.send(client_data.upper()) self.request.close() # 1 self.socket 2 self.socket.bind 3 self.socket.listen(5) 可查看源码 server = socketserver.ThreadingTCPServer(('127.0.0.1', 10000), Myserver) server.serve_forever()
server类：
request类：
继承关系:
以下述代码为例，分析socketserver源码：
ftpserver=socketserver.ThreadingTCPServer(('127.0.0.1',8080),FtpServer)
ftpserver.serve_forever()
查找属性的顺序：ThreadingTCPServer->ThreadingMixIn->TCPServer->BaseServer
- 实例化得到ftpserver，先找类ThreadingTCPServer的__init__,在TCPServer中找到，进而执行server_bind,server_active
- 找ftpserver下的serve_forever,在BaseServer中找到，进而执行self._handle_request_noblock()，该方法同样是在BaseServer中
- 执行self._handle_request_noblock()进而执行request, client_address = self.get_request()（就是TCPServer中的self.socket.accept()），然后执行self.process_request(request, client_address)
- 在ThreadingMixIn中找到process_request，开启多线程应对并发，进而执行process_request_thread，执行self.finish_request(request, client_address)
- 上述四部分完成了链接循环，本部分开始进入处理通讯部分，在BaseServer中找到finish_request,触发我们自己定义的类的实例化，去找__init__方法，而我们自己定义的类没有该方法，则去它的父类也就是BaseRequestHandler中找....
源码分析总结：
基于tcp的socketserver我们自己定义的类中的
- self.server即套接字对象
- self.request即一个链接
- self.client_address即客户端地址
基于udp的socketserver我们自己定义的类中的
- self.request是一个元组（第一个元素是客户端发来的数据，第二部分是服务端的udp套接字对象），如(b'adsf', <socket.socket fd=200, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)>)
- self.client_address即客户端地址
#FtpServer
import socketserver
import struct
import json
import os
class FtpServer(socketserver.BaseRequestHandler):
coding='utf-8'
server_dir='file_upload'
max_packet_size=1024
BASE_DIR=os.path.dirname(os.path.abspath(__file__))
def handle(self):
print(self.request)
while True:
data=self.request.recv(4)
data_len=struct.unpack('i',data)[0]
head_json=self.request.recv(data_len).decode(self.coding)
head_dic=json.loads(head_json)
# print(head_dic)
cmd=head_dic['cmd']
if hasattr(self,cmd):
func=getattr(self,cmd)
func(head_dic)
def put(self,args):
file_path = os.path.normpath(os.path.join(
self.BASE_DIR,
self.server_dir,
args['filename']
))
filesize = args['filesize']
recv_size = 0
print('----->', file_path)
with open(file_path, 'wb') as f:
while recv_size < filesize:
recv_data = self.request.recv(self.max_packet_size)
f.write(recv_data)
recv_size += len(recv_data)
print('recvsize:%s filesize:%s' % (recv_size, filesize))
ftpserver=socketserver.ThreadingTCPServer(('127.0.0.1',8080),FtpServer)
ftpserver.serve_forever()
#FtpClient
import socket
import struct
import json
import os
class MYTCPClient:
address_family = socket.AF_INET
socket_type = socket.SOCK_STREAM
allow_reuse_address = False
max_packet_size = 8192
coding='utf-8'
request_queue_size = 5
def __init__(self, server_address, connect=True):
self.server_address=server_address
self.socket = socket.socket(self.address_family,
self.socket_type)
if connect:
try:
self.client_connect()
except:
self.client_close()
raise
def client_connect(self):
self.socket.connect(self.server_address)
def client_close(self):
self.socket.close()
def run(self):
while True:
inp=input(">>: ").strip()
if not inp:continue
l=inp.split()
cmd=l[0]
if hasattr(self,cmd):
func=getattr(self,cmd)
func(l)
def put(self,args):
cmd=args[0]
filename=args[1]
if not os.path.isfile(filename):
print('file:%s is not exists' %filename)
return
else:
filesize=os.path.getsize(filename)
head_dic={'cmd':cmd,'filename':os.path.basename(filename),'filesize':filesize}
print(head_dic)
head_json=json.dumps(head_dic)
head_json_bytes=bytes(head_json,encoding=self.coding)
head_struct=struct.pack('i',len(head_json_bytes))
self.socket.send(head_struct)
self.socket.send(head_json_bytes)
send_size=0
with open(filename,'rb') as f:
for line in f:
self.socket.send(line)
send_size+=len(line)
print(send_size)
else:
print('upload successful')
client=MYTCPClient(('127.0.0.1',8080))
client.run()