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

本文实例讲述了python/' target='_blank'>python实现的服务器。分享给大家供大家参考，具体如下：

Python - 单进程服务器

#coding=utf-8from socket import *#创建套接字serSocket = socket(AF_INET, SOCK_STREAM)#重复使用绑定信息serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)localAddr = ('', 7788)#绑定端口ipserSocket.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-8from 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-8from socket import *from threading import Threadfrom 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-8from socket import *import time# 用来存储所有的新链接的socketg_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-8from socket import *import randomimport timeserverIp = 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相关内容可查看本站专题：《Python Socket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》

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