单进程服务器
1. 完成一个简单的TCP服务器
import socket
serv_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
serv_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
address = ('', 8000)
serv_sock.bind(address)
serv_sock.listen(128)
while True:
print('-----主进程,,等待新客户端的到来------')
client_sock, client_addr = serv_sock.accept()
print('-----主进程,接下来负责数据处理[%s]-----' % str(client_addr))
while True:
recv_data = client_sock.recv(1024)
if len(recv_data) > 0:
print('recv[%s]:%s' % (str(client_addr), recv_data.decode()))
else:
print('[%s]客户端已经关闭' % str(client_addr))
break
client_sock.close()
serv_sock.close()
2. 总结
- 同一时刻只能为一个客户进行服务,不能同时为多个客户服务
- 类似于找一个“明星”签字一样,客户需要耐心等待才可以获取到服务
当服务器为一个客户端服务时,而另外的客户端发起了connect,只要服务器listen的队列有空闲的位置,就会为这个新客户端进行连接,并且客户端可以发送数据,但当服务器为这个新客户端服务时,可能一次性把所有数据接收完毕
- 当recv接收数据时,返回值为空,即没有返回数据,那么意味着客户端已经调用了close关闭了;因此服务器通过判断recv接收数据是否为空 来判断客户端是否已经下线