Python实现的服务器示例小结【单进程、多进程、多线程、非阻塞式】

本文实例讲述了Python实现的服务器。分享给大家供大家参考，具体如下：

python - 单进程服务器

#coding=utf-8
from socket import *
#创建套接字
serSocket = socket(AF_INET, SOCK_STREAM)
#重复使用绑定信息
serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
localAddr = ('', 7788)
#绑定端口ip
serSocket.bind(localAddr)
#监听
serSocket.listen(5)
while True:
 print('－－－主进程，等待新客户端的到来－－－')
 newSocket,destAddr = serSocket.accept()
 print('－－－主进程，接下来负责数据处理[％s]－－－'％str(destAddr))
 try:
   while True:
     recvData = newSocket.recv(1024)
     if len(recvData)>0:
       print('recv[％s]:％s'％(str(destAddr),recvData))
     else:
       print('[％s]客户端已经关闭')
       break
 finally:
   newSocket.close()
serSocket.close()

总结

同一时刻只能为一个客户进行服务，不能同时为多个客户服务。
当服务器为一个客户端服务时，另外的客户端发起了connect，只要服务器listen的队列有空闲的位置，就会为这个新客户端进行连接，并且客户端可以发送数据，但当服务器为这个新客户端服务时，可能一次性把所有数据接收完毕当recv接收数据时，返回值为空，即没有返回数据，那么意味着客户端已经调用了close关闭了；因此服务器通过判断recv接收数据是否为空 来判断客户端是否已经下线。

python - 多进程服务器

#coding=utf-8
from socket import *
from multiprocessing import *
from time import sleep
#处理客户端的请求并为其服务
def dealWithClient(newSocket,destAddr):
 try:
   while True:
     recvData = newSocket.recv(1024)
     if len(recvData) > 0:
       print('recv[％s]:％s' ％ (str(destAddr), recvData))
     else:
       print('[％s]客户端已经关闭')
       break
 finally:
   newSocket.close()
def main():
 #创建套接字
 serSocket = socket(AF_INET, SOCK_STREAM)
 #重复使用绑定信息
 serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
 localAddr = ('', 7788)
 #绑定端口ip
 serSocket.bind(localAddr)
 #监听
 serSocket.listen(5)
 try:
   while True:
     print('－－－主进程，等待新客户端的到来－－－')
     newSocket,destAddr = serSocket.accept()
     print('－－－主进程，接下来负责数据处理[％s]－－－'％str(destAddr))
     client = Process(target=dealWithClient, args=(newSocket, destAddr))
     client.start()
     # 因为已经向子进程中copy了一份（引用），并且父进程中这个套接字也没有用处了
     # 所以关闭
     newSocket.close()
 finally:
   # 当为所有的客户端服务完之后再进行关闭，表示不再接收新的客户端的链接
   serSocket.close()
if __name__ == '__main__':
 main()

总结

通过为每个客户端创建一个进程的方式，能够同时为多个客户端进行服
务当客户端不是特别多的时候，这种方式还行，如果有成百上千个，就不
可取了，因为每次创建进程的过程需要消耗较多的资源。

python - 多线程服务器

#coding=utf-8
from socket import *
from threading import Thread
from time import sleep
# 处理客户端的请求并执行事情
def dealWithClient(newSocket,destAddr):
 while True:
   recvData = newSocket.recv(1024)
   if len(recvData)>0:
     print('recv[％s]:％s'％(str(destAddr), recvData))
   else:
     print('[％s]客户端已经关闭'％str(destAddr))
     break
 newSocket.close()
def main():
 serSocket = socket(AF_INET, SOCK_STREAM)
 serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR , 1)
 localAddr = ('', 7788)
 serSocket.bind(localAddr)
 serSocket.listen(5)
 try:
   while True:
     print('-----主进程，，等待新客户端的到来------')
     newSocket,destAddr = serSocket.accept()
     print('-----主进程，，接下来创建一个新的进程负责数据处理[％s]----'％str(destAddr))
     client = Thread(target=dealWithClient, args=(newSocket,destAddr))
     client.start()
     #因为线程中共享这个套接字，如果关闭了会导致这个套接字不可用，
     #但是此时在线程中这个套接字可能还在收数据，因此不能关闭
     #newSocket.close()
 finally:
   # 当为所有的客户端服务完之后再进行关闭，表示不再接收新的客户端的链接
   serSocket.close()
if __name__ == '__main__':
 main()

单进程服务器-非堵塞模式

服务器：

#coding=utf-8
from socket import *
import time
# 用来存储所有的新链接的socket
g_socketList = []
def main():
 serSocket = socket(AF_INET, SOCK_STREAM)
 serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR , 1)
 localAddr = ('', 7788)
 serSocket.bind(localAddr)
 #可以适当修改listen中的值来看看不同的现象
 serSocket.listen(1000)
 #将套接字设置为?堵塞
 #设置为?堵塞后，如果accept时，恰巧没有客户端connect，那么accept会
 #产生一个异常，所以需要try来进行处理
 serSocket.setblocking(False)
 while True:
   #?来测试
   #time.sleep(0.5)
   try:
     newClientInfo = serSocket.accept()
   except Exception as result:
     pass
   else:
     print("一个新的客户端到来:％s"％str(newClientInfo))
     newClientInfo[0].setblocking(False)
     g_socketList.append(newClientInfo)
 # 用来存储需要删除的客户端信息
 needDelClientInfoList = []
 for clientSocket,clientAddr in g_socketList:
   try:
     recvData = clientSocket.recv(1024)
     if len(recvData)>0:
       print('recv[％s]:％s'％(str(clientAddr), recvData))
     else:
       print('[％s]客户端已经关闭'％str(clientAddr))
       clientSocket.close()
       g_needDelClientInfoList.append((clientSocket,clientAddr))
   except Exception as result:
     pass
 for needDelClientInfo in needDelClientInfoList:
   g_socketList.remove(needDelClientInfo)
if __name__ == '__main__':
 main()

客户端：

#coding=utf-8
from socket import *
import random
import time
serverIp = input("请输入服务器的ip:")
connNum = input("请输入要链接服务器的次数(例如1000):")
g_socketList = []
for i in range(int(connNum)):
 s = socket(AF_INET, SOCK_STREAM)
 s.connect((serverIp, 7788))
 g_socketList.append(s)
 print(i)
while True:
 for s in g_socketList:
   s.send(str(random.randint(0,100)))
 # 用来测试
 #time.sleep(1)

希望本文所述对大家Python程序设计有所帮助。

来源：https://blog.csdn.net/xuezhangjun0121/article/details/77639544