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相关内容可查看本站专题：《python socket编程技巧总结》、《python数据结构与算法教程》、《python函数使用技巧总结》、《python字符串操作技巧汇总》、《python入门与进阶经典教程》及《python文件与目录操作技巧汇总》

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