上篇：https://blog.csdn.net/qq_42489308/article/details/89388112
socket编程
什么是socket？
简称套接字，是进程间通信的一种方式，它与其他进程间通信的一个主要不同是：它能实现不同主机
间的进程间通信，我们网络上各种各样的服务大多数是基于socket来完成通信的。
socket是基于C/S架构的，也就是说socket网络编程，通常需要写两个文件，一个服务端，一个客户端
Python中的socket通信逻辑如下图所示
在python中，用socket.socket()方法来创建套接字
s = socket.socket([family[, type[, proto]]])
参数说明：
family：套接字家族，可以使用AF_UNIX或者AF_INET
type：套接字类型，分为SOCK_STREAM或者SOCK_DGRAM，分别代表TCP和UDP
protocol: 一般不填默认为0
注意
1.python3以后，socket传递的都是bytes类型的数据，字符串需要先转换一下，string.encode()即可；另一端在接收数据的时候需要bytes转换成字符串，只要bytes.decode()一下就可以
2.在正常通信时，accept()和recv()方法都是阻塞的。所谓的阻塞，指的是程序会暂停在哪，一直等数据过来
socket编程思路
1 创建套接字，绑定套接字到本地IP与端口：socket.socket(scoket.AF_INET,socket.SOCK_STREAM), s.bind()
2 开始监听链接:s.listen()
3 进入循环，不断接受客户端的链接请求:s.accept()
4 接收传来的数据,或者发送数据给对方:s.recv() , s.sendall()
5 传输完毕后,关闭套接字:s.close()
客户端
1 创建套接字,连接服务器地址：socket.socket(scoket.AF_INET,socket.SCOK_STREAM),s.connect()
2 连接后发送数据和接收数据: s.sendall(),s.recv()
3 传输完毕后,关闭套接字:s.close()
python的socket编程，通常可以分为TCP和UDP编程两种，前者是连接的可靠传输服务，每次通信都要握手，结束传输也要挥手，数据会被检验，是使用最广的通用模式；后者是不带连接的传输服务，简单粗暴
服务器端：
import socketip_port = ('127.0.0.1', 9999)
sk = socket.socket() # 创建套接字
sk.bind(ip_port) # 绑定服务地址
sk.listen(5) # 监听连接请求
print('启动socket服务，等待客户端连接...')
conn, address = sk.accept() # 等待连接，此处自动阻塞
while True: # 一个死循环，直到客户端发送‘exit’的信号，才关闭连接
client_data = conn.recv(1024).decode() # 接收信息
if client_data == "exit": # 判断是否退出连接
exit("通信结束")
print("来自%s的客户端向你发来信息：%s" % (address, client_data))
conn.sendall('服务器已经收到你的信息'.encode()) # 回馈信息给客户端
conn.close() # 关闭连接
客户端：
import socket
ip_port = ('127.0.0.1', 9999)
s = socket.socket() # 创建套接字
s.connect(ip_port) # 连接服务器
while True: # 通过一个死循环不断接收用户输入，并发送给服务器
inp = input("请输入要发送的信息： ").strip()
if not inp: # 防止输入空信息，导致异常退出
continue
s.sendall(inp.encode())
if inp == "exit": # 如果输入的是‘exit’，表示断开连接
print("结束通信！")
break
server_reply = s.recv(1024).decode()
print(server_reply)
s.close() # 关闭连接
虽然服务器和客户端在一对一的情况下，工作良好，但是，如果有多个客户端同时连接同一个服务器呢？结果可能不太令人满意，因为服务器无法同时对多个客户端提供服务。为什么会这样呢？因为Python的socket模块，默认情况下创建的是单进程单线程，同时只能处理一个连接请求，如果要实现多用户服务，那么需要使用多线程机制
import socket
import threading
def link_handler(link,clinet):
print("服务器开始接收来自%s:%s的请求" %(clinet[0],clinet[1]))
while True:
# 解码为bytes
clinet_data= conn.recv(1024).decode()
if clinet_data== 'exit':
print('通讯结束')
break
print("来自%s的客户端向服务器发来信息: %s"%(clinet,clinet_data))
conn.sendall("服务器已经接收到你的信息了".encode())
IP_PORT= ('127.0.0.1',9999)
s= socket.socket()
s.bind(IP_PORT)
s.listen(5)
print('启迪socket服务，等待客户端连接...')
while True:
conn,address= s.accept()
t= threading.Thread(target=link_handler,args=(conn,address))
t.start()