python之socket编程

客户端/服务器架构

1.硬件C/S架构(打印机)

2.软件C/S架构

　　互联网中处处是C/S架构

　　如百度是服务端，你的浏览器是客户端（B/S架构也是C/S架构的一种）

　　腾讯作为服务端为你提供视频，你得下个腾讯视频客户端才能看它的视频）

C/S架构与socket的关系：

我们学习socket就是为了完成C/S架构的开发

osi七层

引子：

须知一个完整的计算机系统是由硬件、操作系统、应用软件三者组成,具备了这三个条件，一台计算机系统就可以自己跟自己玩了（打个单机游戏，玩个扫雷啥的）

如果你要跟别人一起玩，那你就需要上网了，什么是互联网？

互联网的核心就是由一堆协议组成，协议就是标准，比如全世界人通信的标准是英语

如果把计算机比作人，互联网协议就是计算机界的英语。所有的计算机都学会了互联网协议，那所有的计算机都就可以按照统一的标准去收发信息从而完成通信了。

人们按照分工不同把互联网协议从逻辑上划分了层级：

互联网协议按照功能不同分为osi七层或tcp/ip五层或tcp/ip四层

每层运行常见物理设备

为何学习socket一定要先学习互联网协议：

1.首先：本节课程的目标就是教会你如何基于socket编程，来开发一款自己的C/S架构软件

2.其次：C/S架构的软件（软件属于应用层）是基于网络进行通信的

3.然后：网络的核心即一堆协议，协议即标准，你想开发一款基于网络通信的软件，就必须遵循这些标准。

4.最后：就让我们从这些标准开始研究，开启我们的socket编程之旅

socket层

在上面中，我们没有看到Socket的影子，那么它到底在哪里呢？还是用图来说话，一目了然。

socket是什么

Socket是应用层与TCP/IP协议族通信的中间软件抽象层，它是一组接口。在设计模式中，Socket其实就是一个门面模式，它把复杂的TCP/IP协议族隐藏在Socket接口后面，对用户来说，一组简单的接口就是全部，让Socket去组织数据，以符合指定的协议。

所以，我们无需深入理解tcp/udp协议，socket已经为我们封装好了，我们只需要遵循socket的规定去编程，写出的程序自然就是遵循tcp/udp标准的。

也有人将socket说成ip+port，ip是用来标识互联网中的一台主机的位置，而port是用来标识这台机器上的一个应用程序，ip地址是配置到网卡上的，而port是应用程序开启的，ip与port的绑定就标识了互联网中独一无二的一个应用程序 而程序的pid是同一台机器上不同进程或者线程的标识

套接字发展史及分类

套接字起源于 20 世纪 70 年代加利福尼亚大学伯克利分校版本的 Unix,即人们所说的 BSD Unix。 因此,有时人们也把套接字称为“伯克利套接字”或“BSD 套接字”。一开始,套接字被设计用在同 一台主机上多个应用程序之间的通讯。这也被称进程间通讯,或 IPC。套接字有两种（或者称为有两个种族）,分别是基于文件型的和基于网络型的。

基于文件类型的套接字家族

套接字家族的名字：AF_UNIX

unix一切皆文件，基于文件的套接字调用的就是底层的文件系统来取数据，两个套接字进程运行在同一机器，可以通过访问同一个文件系统间接完成通信

基于网络类型的套接字家族

套接字家族的名字：AF_INET

(还有AF_INET6被用于ipv6，还有一些其他的地址家族，不过，他们要么是只用于某个平台，要么就是已经被废弃，或者是很少被使用，或者是根本没有实现，所有地址家族中，AF_INET是使用最广泛的一个，python支持很多种地址家族，但是由于我们只关心网络编程，所以大部分时候我么只使用AF_INET)

套接字工作流程

一个生活中的场景。你要打电话给一个朋友，先拨号，朋友听到电话铃声后提起电话，这时你和你的朋友就建立起了连接，就可以讲话了。等交流结束，挂断电话结束此次交谈。 生活中的场景就解释了这工作原理。

先从服务器端说起。服务器端先初始化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()        创建一个与该套接字相关的文件

基于TCP的套接字

tcp是基于链接的，必须先启动服务端，然后再启动客户端去链接服务端

tcp服务端

import socket
ss = socket() #创建服务器套接字
ss.bind()      #把地址绑定到套接字
ss.listen()      #监听链接
inf_loop:      #服务器无限循环
    cs = ss.accept() #接受客户端链接
    comm_loop:         #通讯循环
        cs.recv()/cs.send() #对话(接收与发送)
    cs.close()    #关闭客户端套接字
ss.close()        #关闭服务器套接字(可选)

tcp客户端

import socket
cs = socket()    # 创建客户套接字
cs.connect()    # 尝试连接服务器
comm_loop:        # 通讯循环
cs.send()/cs.recv()    # 对话(发送/接收)
cs.close()

实例：模仿ssh写服务端与客户端

tcp服务端

import socket
import subprocess
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.bind(('192.168.1.5', 8017))
phone.listen(5)
print('start....')
while True:
    conf,message = phone.accept()
    print(conf)
    print(message)
    while True:
        try:
            data = conf.recv(1024)
            if not data:
                break
            data_tr = data.decode('utf-8')
            print(data_tr)
            #  stdin,stdout, stderr： 分别指示要执行的程序标准输入、标准输出、标准错误输出文件的句柄
            re = subprocess.Popen(data_tr, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
            r1 = re.stdout.read() #读出来的是字节格式
            r2 = re.stderr.read()
            conf.send(r1)
            conf.send(r2)
        except Exception:
            break
    conf.close()
phone.close()

tcp客户端

import socket
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.connect(('192.168.1.5', 8017))
while True:
    sd = input("输入:".strip())
    if not sd:
        continue
    phone.send(sd.encode('utf-8'))
    message = phone.recv(1024)
    print("----------------------")
    print(message.decode('gbk'))
phone.close()

基于UDP的套接字

udp是无链接的，先启动哪一端都不会报错

udp服务端

ss = socket()   #创建一个服务器的套接字
ss.bind()       #绑定服务器套接字
inf_loop:       #服务器无限循环
	cs = ss.recvfrom()/ss.sendto() # 对话(接收与发送)
ss.close()                         # 关闭服务器套接字

udp客户端

cs = socket()   # 创建客户套接字
comm_loop:      # 通讯循环
    cs.sendto()/cs.recvfrom()   # 对话(发送/接收)
cs.close()                      # 关闭客户套接字

udp套接字简单示例

udp服务端

import socket
ip_port=('127.0.0.1',9000)
BUFSIZE=1024
udp_server_client=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
 
udp_server_client.bind(ip_port)
 
while True:
    msg,addr=udp_server_client.recvfrom(BUFSIZE)
    print(msg,addr)
 
    udp_server_client.sendto(msg.upper(),addr)

udp客户端

import socket
ip_port=('127.0.0.1',9000)
BUFSIZE=1024
udp_server_client=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
 
while True:
    msg=input('>>: ').strip()
    if not msg:continue
 
    udp_server_client.sendto(msg.encode('utf-8'),ip_port)
 
    back_msg,addr=udp_server_client.recvfrom(BUFSIZE)
    print(back_msg.decode('utf-8'),addr)

粘包现象

根据我之前写的模仿ssh程序，如果输入的命令，得到的内容比较大时，recv(1024)则可能不够用

什么是粘包

须知：只有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段后一次发送出去，这样接收方就收到了粘包数据。

1. TCP（transport control protocol，传输控制协议）是面向连接的，面向流的，提供高可靠性服务。收发两端（客户端和服务器端）都要有一一成对的socket，因此，发送端为了将多个发往接收端的包，更有效的发到对方，使用了优化方法（Nagle算法），将多次间隔较小且数据量小的数据，合并成一个大的数据块，然后进行封包。这样，接收端，就难于分辨出来了，必须提供科学的拆包机制。 即面向流的通信是无消息保护边界的。
2. UDP（user datagram protocol，用户数据报协议）是无连接的，面向消息的，提供高效率服务。不会使用块的合并优化算法，, 由于UDP支持的是一对多的模式，所以接收端的skbuff(套接字缓冲区）采用了链式结构来记录每一个到达的UDP包，在每个UDP包中就有了消息头（消息来源地址，端口等信息），这样，对于接收端来说，就容易进行区分处理了。 即面向消息的通信是有消息保护边界的。
3. tcp是基于数据流的，于是收发的消息不能为空，这就需要在客户端和服务端都添加空消息的处理机制，防止程序卡住，而udp是基于数据报的，即便是你输入的是空内容（直接回车），那也不是空消息，udp协议会帮你封装上消息头，实验略

udp的recvfrom是阻塞的，一个recvfrom(x)必须对唯一一个sendinto(y),收完了x个字节的数据就算完成,若是y>x数据就丢失，这意味着udp根本不会粘包，但是会丢数据，不可靠

tcp的协议数据不会丢，没有收完包，下次接收，会继续上次继续接收，己端总是在收到ack时才会清除缓冲区内容。数据是可靠的，但是会粘包。

两种情况下会发生粘包。

1.发送端需要等缓冲区满才发送出去，造成粘包（发送数据时间间隔很短，数据了很小，会合到一起，产生粘包）

服务端

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()

客户端

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'))

2.接收方不及时接收缓冲区的包，造成多个包接收（客户端发送了一段数据，服务端只收了一小部分，服务端下次再收的时候还是从缓冲区拿上次遗留的数据，产生粘包）

服务端

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()

客户端

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在数据传输时，发送端先把数据发送到自己的缓存中，然后协议控制将缓存中的数据发往对端，对端返回一个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 json,struct
#假设通过客户端上传1T:1073741824000的文件a.txt
 
#为避免粘包,必须自定制报头
header={'file_size':1073741824000,'file_name':'/a/b/c/d/e/a.txt','md5':'8f6fbf8347faa4924a76856701edb0f3'} #1T数据,文件路径和md5值
 
#为了该报头能传送,需要序列化并且转为bytes
head_bytes=bytes(json.dumps(header),encoding='utf-8') #序列化并转成bytes,用于传输
 
#为了让客户端知道报头的长度,用struck将报头长度这个数字转成固定长度:4个字节
head_len_bytes=struct.pack('i',len(head_bytes)) #这4个字节里只包含了一个数字,该数字是报头的长度
 
#客户端开始发送
conn.send(head_len_bytes) #先发报头的长度,4个bytes
conn.send(head_bytes) #再发报头的字节格式
conn.sendall(文件内容) #然后发真实内容的字节格式
 
#服务端开始接收
head_len_bytes=s.recv(4) #先收报头4个bytes,得到报头长度的字节格式
x=struct.unpack('i',head_len_bytes)[0] #提取报头的长度
 
head_bytes=s.recv(x) #按照报头长度x,收取报头的bytes格式
header=json.loads(json.dumps(header)) #提取报头
 
#最后根据报头的内容提取真实的数据,比如
real_data_len=s.recv(header['file_size'])
s.recv(real_data_len)

服务端（自定制报头）

import socket
import subprocess
import struct
import json
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.bind(('192.168.1.1', 8019))
phone.listen(5)
print('start....')
while True:
    conf,message = phone.accept()
    print(conf)
    print(message)
    while True:
        try:
            data = conf.recv(1024)
            if not data:
                break
            data_tr = data.decode('utf-8')
            print(data_tr)
            #  stdin,stdout, stderr： 分别指示要执行的程序标准输入、标准输出、标准错误输出文件的句柄
            re = subprocess.Popen(data_tr, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
            r1 = re.stdout.read()
            r2 = re.stderr.read()
            # 真正内容的长度
            r_size = len(r1) + len(r2)
            # head头字典的格式
            head_dict = {'data_size': r_size}
            # 用json转换
            head_json = json.dumps(head_dict)
            head_content = head_json.encode('utf-8')
            # 发送报头的长度
            head_size = len(head_content)
            conf.send(struct.pack('i', head_size))
            # 发送报头
            conf.send(head_content)
            # 发送真正的内容
            conf.send(r1)
            conf.send(r2)
        except Exception:
            break
    conf.close()
phone.close()

客户端（自定制报头）

import socket
import struct
import json
phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
phone.connect(('192.168.1.1', 8019))
while True:
    sd = input("输入:".strip())
    if not sd:
        continue
    phone.send(sd.encode('utf-8'))
    baotou = phone.recv(4)
    baotou_len = struct.unpack('i', baotou)[0]
    head_json = phone.recv(baotou_len).decode('utf-8')
    head_size = json.loads(head_json)
    data_size = head_size['data_size']
    real_content = b''
    real_size = 0
    if real_size < data_size:
        data = phone.recv(1024)
        real_size += len(data)
        real_content += data
    print(real_content.decode('gbk'))
phone.close()

FTP例子：服务端有上传文件到服务器的功能

客户端

import json
import struct
import os
import socket
 
 
class MyClient:
    coding = 'utf-8'
    address_family = socket.AF_INET
    socket_type = socket.SOCK_STREAM
 
    def __init__(self, client_address, client_active=True):
        self.client_address = client_address
        self.sock = socket.socket(self.address_family, self.socket_type)
        if client_active:
            try:
                self.client_connect()
            except:
                self.client_close()
                raise
 
    def client_connect(self):
        self.sock.connect(self.client_address)
 
    def client_close(self):
        self.sock.close()
 
    def run(self):
        print('请输入命令以及要上传的文件的路径')
        while True:
            inp = input(">>: ").strip()
            if not inp:
                continue
            inp_split = inp.split()
            cmd = inp_split[0]
            if hasattr(self, cmd):
                fu = getattr(self, cmd)
                fu(inp_split)
 
    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, 'file_name': os.path.basename(filename), 'file_size': filesize}
        head_json = json.dumps(head_dic)
        head_json_bytes = head_json.encode(self.coding)
        head_struct = struct.pack('i', len(head_json_bytes))
        # 发送报头的长度
        self.sock.send(head_struct)
        # 发送真正的报头
        self.sock.send(head_json_bytes)
        # 发送内容
        send_size = 0
        with open(filename, 'rb') as f:
                for i in f:
                    self.sock.send(i)
                    send_size += len(i)
                    print(send_size)
                else:
                    print('upload successful')
 
 
c = MyClient(('192.168.1.1', 8089))
c.run()

服务端

import json
import os
import struct
import socket
 
 
class MyFtp:
    coding = 'utf-8'
    address_family = socket.AF_INET
    socket_type = socket.SOCK_STREAM
    server_dir = 'D://test'
    request_size = 5
    max_packet_size = 8000
 
    def __init__(self, server_address, server_active=True):
        self.server_address = server_address
        self.sock = socket.socket(self.address_family, self.socket_type)
        if server_active:
            try:
                self.server_bind()
                self.server_listen()
            except:
                self.server_close()
                raise
 
    def server_bind(self):
        self.sock.bind(self.server_address)
 
    def server_listen(self):
        self.sock.listen(self.request_size)
 
    def server_close(self):
        self.sock.close()
 
    def get_requset(self):
        return self.sock.accept()
 
    def run(self):
        while True:
            self.con,self.client_address = self.get_requset()
            while True:
                try:
                    head_struct = self.con.recv(4)
                    if not head_struct:
                        break
                    head_size = struct.unpack('i', head_struct)[0]
                    head_json = self.con.recv(head_size).decode(self.coding)
                    head_content = json.loads(head_json)
                    cmd = head_content['cmd']
                    if hasattr(self, cmd):
                        fuc = getattr(self, cmd)
                        fuc(head_content)
                except Exception:
                    break
 
    def put(self, head_content):
        file_path = os.path.normpath(os.path.join(self.server_dir, head_content['file_name']))
        file_size = head_content['file_size']
        recv_size = 0
        with open(file_path, 'wb') as f:
            while recv_size < file_size:
                file_content = self.con.recv(self.max_packet_size)
                f.write(file_content)
                recv_size += len(file_content)
                print(recv_size)
 
 
t = MyFtp(('192.168.1.1', 8089))
t.run()

socketserver实现并发

基于tcp的套接字，关键就是两个循环，一个链接循环，一个通信循环

socketserver模块中分两大类：server类（解决链接问题）和request类（解决通信问题）

server类：

request类：

继承关系:

以下述代码为例，分析socketserver源码：

import socketserver
 
class MyServer(socketserver.BaseRequestHandler):
 
    def handle(self):
        data = self.request.recv(1024)
        self.request.send(data.upper())
 
if __name__ == '__main__':
    obj = socketserver.ThreadingTCPServer(('192.168.1.1', 8014), MyServer)
    # 循环链接
    obj.serve_forever()

查找属性的顺序：ThreadingTCPServer->ThreadingMixIn->TCPServer->BaseServer

1、实例化得到ftpserver，先找类ThreadingTCPServer的__init__,在TCPServer中找到，进而执行server_bind,server_active
2、找ftpserver下的serve_forever,在BaseServer中找到，进而执行self._handle_request_noblock()，该方法同样是在BaseServer中
3、执行self._handle_request_noblock()进而执行request, client_address = self.get_request()（就是TCPServer中的self.socket.accept()），然后执行self.process_request(request, client_address)
4、在ThreadingMixIn中找到process_request，开启多线程应对并发，进而执行process_request_thread，执行self.finish_request(request, client_address)
5、上述四部分完成了链接循环，本部分开始进入处理通讯部分，在BaseServer中找到finish_request,触发我们自己定义的类的实例化，去找__init__方法，而我们自己定义的类没有该方法，则去它的父类也就是BaseRequestHandler中找....

源码分析总结：

基于tcp的socketserver我们自己定义的类中的

1.self.server即套接字对象 　

2.self.request即一个链接

3.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)>)

1.self.client_address即客户端地址

2.self.client_address即客户端地址

将之前的服务端改成并发的：

import json
import os
import struct
import socketserver
 
 
class MyFtp(socketserver.BaseRequestHandler):
    coding = 'utf-8'
    server_dir = 'D://test'
    request_size = 5
    max_packet_size = 8000
 
    def handle(self): #所有请求的交互都是在handle里执行的,
        while True:
            try:
                head_struct = self.request.recv(4)
                if not head_struct:
                    break
                head_size = struct.unpack('i', head_struct)[0]
                head_json = self.request.recv(head_size).decode(self.coding)
                head_content = json.loads(head_json)
                cmd = head_content['cmd']
                if hasattr(self, cmd):
                    fuc = getattr(self, cmd)
                    fuc(head_content)
            except Exception:
                break
 
    def put(self, head_content):
        file_path = os.path.normpath(os.path.join(self.server_dir, head_content['file_name']))
        file_size = head_content['file_size']
        recv_size = 0
        with open(file_path, 'wb') as f:
            while recv_size < file_size:
                file_content = self.request.recv(self.max_packet_size)
                f.write(file_content)
                recv_size += len(file_content)
                print(recv_size)
 
 
obj = socketserver.ThreadingTCPServer(('192.168.1.1', 8089), MyFtp)
obj.serve_forever()

UDP的并发

客户端：

import socket
 
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sever_address = ('192.168.1.1', 8089)
while True:
    inp = input(">>>>>>")
    sock.sendto(inp.encode('utf-8'), sever_address)
    data, server = sock.recvfrom(1024)
    print(data.decode('utf-8'))
    print(server)

服务端

import socketserver
 
class MyUdpServer(socketserver.BaseRequestHandler):
    def handle(self):
        print(self.request[0])  # 得到的是客户端发来的信息
        print(self.request[1])  # 得到一个对象
        self.request[1].sendto('草拟吗'.encode('utf-8'), self.client_address)
 
if __name__ == '__main__':
    obj = socketserver.ThreadingUDPServer(('192.168.1.1', 8089), MyUdpServer)
    obj.serve_forever()