一、socket是什么
- socket是电脑网络中进程间数据流的端点
- socket操作系统的通信机制
- 应用程序通过socket进行网络数据的传输
二、socket通信方式
- socket分为UDP和TCP两种不同的通信方式
注意：
-
最大连接数listen：socket进行监听之后的传入连接。比如说
socket.listen(5),这里的5不是说同一时间会有5个程序进行处理，而是同一时间只有一个程序会被处理，剩下四个是被阻塞状态。也就是说，socket可以被挂起的最大连接数是5。同时有5个请求来时，可以进行同时回应，但正在处理的程序只有一个，其他四个程序处于等待状态，等待之前处理的程序完成。如果多余5个的请求进入进来，服务器会直接拒绝。 -
循环接收数据：是从
socket.accept()开始的，同时循环里也有conn.close()。 -
在一次连接中不断接收数据：在上一个while循环中，再增加一个while循环，里面写
conn.recv()。 - recv()函数的参数：表示每次从缓冲区读取多少字节的数据。
三、socket实例化参数含义
-
第一个参数
family：地址簇
1）socket.AF_INET IPv4（默认）表示我们定义的socket是通过IPv4连接的。
2）socket.AF_INET IPv6
3）socket.AF_UNIX只能够用于单一的Unix系统进程间通信。 -
第二个参数
type：类型
1）socket.SOCK_STREAM数据流式socket，for TCP（默认）
2）socket.SOCK_DGRAM数据报式socket，for UDP
3）socket.SOCK_RAW原始套接字
4）socket.SOCK_RDM可靠的UDP形式
5）socket.SOCK_SEQPACKET可靠的连续数据包服务 -
第三个参数
proto：协议号
1）0：默认，可以忽略
2）CAN_RAW或CAN_BCM：地址簇为AF_CAN时
四、udp和tcp的不同
1）udp是socket.sendto()函数，tcp是socket.send()函数
2）udp可以进行多次数据发送和多客户端的连接，头层皮不可以进行多客户端的连接，因为套接字稚嫩恶搞一对一。
五、socket的非阻塞
server端：
import socketserver
import random
#定义一个类,这个类继承了BaseRequestHandler这个子类
class MyServer(Socketserver.BaseRequestHandler):
#子类的三个方法
#首先执行setup
def setup(self):
pass
#然后执行handle,如果handle报错，则会进行跳过，那客户端就会进行报错，而无法进行数据的连接
def handle(self):
#定义连接变量
conn = self.request()
#发送消息定义
msg = “hello world”
#消息发送
conn.send(msg.encode())
#进入循环，不断接收客户端消息
while True:
data = conn.recv(1024)
#打印消息
print(data.decode())
if data == b'exit':
break
conn.send(data)
conn.send(str(random.randint(1, 1000)).encode())
#循环结束，将获得的连接对象进行关闭
conn.close()
#最后执行finish方法
def finish(self):
pass
#定义主函数
if __name__ == "__main__":
#使用socketserver模块时，需要使用多线程实例,第二个参数是多线程类定义
server = socketserver.ThreadingTCPServer(("127.0.0.1", 8888), MyServer)
#开启异步多线程，等待客户端的连接
server.serve_forever()
socketserver库源码
每进行一次连接，就会启用一个线程，通过这个方式来实现socket模块与多个客户端连接的目的。
客户端的代码可以与socket阻塞式的一致。
六、文件上传信息的编写
文件发送客户端：
import socket
sk = socket.socket()
ip_port = ('127.0.0.1', 9999)
#服务器连接
sk.connect(ip_port)
#文件上传操作
#将所需要上传的文件打开，通过分块上传到服务器端
#socket上传是byte类型的，所以我们用byte类型打开
with open('文件路径(可以相对)', 'rb') as f:
for i in f: #以整个文件为对象，一段一段读取，再进行服务器的上传
sk.send(i) #已经是byte类型，不需要再编码
data = sk.recv() #等待接收完成
if data != b'success':
break
#文件全部发完后，给服务器端发送结束信号
sk.send('quit'.encode())
文件接收服务端：
import socket
sk = socket.socket()
ip_port = ('127.0.0.1', 9999)
sk.bind(ip_port)
sk.listen(5)
while True:
conn, address = sk.accept()
#要一直使用当前连接进行数据发送,直到标志出现
while True:
with open(“定义的文件名” , “ab“) as f: #将文件定义为二进制可添加模式
data = conn.recv(1024)
if data == b'quit':
break
f.write(data)
#接收完成标志 防粘包
conn.send('success'.encode())
sk.close() #整个循环结束，关闭连接
使用同样的原理，可以实现服务器端发送文件，客户端接收文件。
