脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 脚本专栏 → python → python socket服务端并发

python 实现socket服务端并发的四种方式

 更新时间：2020年12月14日 16:57:55   作者：the3times  
这篇文章主要介绍了python 实现socket服务端并发的四种方式，帮助大家更好的理解和使用python，感兴趣的朋友可以了解下

多进程&多线程

服务端：多进程和多线程的开启方式相同。

缺点：<1> 由于Cpython的GIL，导致同一时间无法运行多个线程；<2> 不可能无限开进进程或线程

解决办法：多进程、concurrent.futures.ProcessPoolExecutor、线程池

import socket
from multiprocessing import Process
from threading import Thread


class MyTcpServer:
  def __init__(self, ip, port):
    self.ip = ip
    self.port = port
    self.server = socket.socket()
    self.server.bind((self.ip, self.port))
    self.server.listen(5)

  def wait_accept(self):
    conn, addr = self.server.accept()
    return conn, addr

  def handle_request(self, conn):
    while 1:
      try:
        data = conn.recv(1024)
        if not data: break
        conn.send(data.upper())
      except Exception as e:
        print(e)
        break
    conn.close()


if __name__ == '__main__':
  server = MyTcpServer('127.0.0.1', 8888)
  while 1:
    conn, addr = server.wait_accept()
    p = Process(target=server.handle_request, args=(conn, ))	# 创建一个进程
    p.start()	# 告诉操作提供，开启这个进程

进程池&线程池

异步提交任务，支持异步接收返回结果(submit返回一个futures对象，调用add_done_callback方法)

import socket
from concurrent.futures import ProcessPoolExecutor
# from concurrent.futures import ThreadPoolExecutor


class MyTcpServer:
  def __init__(self, ip, port):
    self.ip = ip
    self.port = port
    self.server = socket.socket()
    self.server.bind((self.ip, self.port))
    self.server.listen(5)

  def wait_accept(self):
    conn, addr = self.server.accept()
    return conn, addr

  def handle_request(self, conn):
    while 1:
      try:
        data = conn.recv(1024)
        if not data: break
        conn.send(data.upper())
      except Exception as e:
        print(e)
        break
    conn.close()


if __name__ == '__main__':
  server = MyTcpServer('127.0.0.1', 8888)
  pool = ProcessPoolExecutor(5)    # 5个进程一直服务

  while 1:
    conn, addr = server.wait_accept()
    pool.submit(server.handle_request, conn)	# 异步提交任务

socketserver

优点：简化socket服务端创建流程。
提供服务端串行和并发两种服务模式（TCPServer，ThreadingTCPServer）
缺点：windows上无法使用多进程实现并发

import socketserver


class MyTcpHandler(socketserver.BaseRequestHandler):
  def handle(self):		# 通信循环
    while 1:
      try:
        data = self.request.recv(1024)
        if not data: break
        self.request.send(data.upper())
      except Exception as e:
        print(e)
        break
    self.request.close()


if __name__ == '__main__':
  ip_port = '127.0.0.1', 8888
  server = socketserver.ThreadingTCPServer(ip_port, MyTcpHandler) # 异步处理 
  server.serve_forever()		# 连接循环

协程

优点：单线程内实现并发，代码级别模拟IO切换，提高程序运行效率

from gevent import spawn, monkey;monkey.patch_all()		# 猴子补丁，补丁:常规IO
import socket


class MyTcpServer:
  def __init__(self, ip, port, my_spawn):
    self.ip = ip
    self.port = port
    self.server = socket.socket()
    self.server.bind((self.ip, self.port))
    self.server.listen(5)
    self.spawn = my_spawn		# 保存spawn本地

  def wait_accept(self):
    while 1:
      conn, addr = self.server.accept()
      self.spawn(self.handle_request, conn)	# 检测 handle_request的io

  def handle_request(self, conn):
    while 1:
      try:
        data = conn.recv(1024)
        if not data: break
        conn.send(data.upper())
      except Exception as e:
        print(e)
        break
    conn.close()


if __name__ == '__main__':
  server = MyTcpServer('127.0.0.1', 8888, spawn)
  g1 = server.spawn(server.wait_accept)	# 检测wait_accept的io
  g1.join()	# 等待g1运行结束，即一直在循环检测io

以上就是python 实现socket服务端并发的四种方式的详细内容，更多关于python socket服务端并发的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • Flask  request 对象介绍

    Flask  request 对象介绍

    本文介绍 Flask  request 对象,一个完整的 HTTP 请求,包括客户端向服务端发送的Request 请求和服务器端发送 Response 响应.为了能方便访问获取请求及响应报文信息,Flask 框架提供了一些内建对象,下面就来说一下 Flask 针对请求提供内建对象reques,需要的朋友可以参考一下
    2021-11-11
  • Python3操作SQL Server数据库(实例讲解)

    Python3操作SQL Server数据库(实例讲解)

    下面小编就为大家带来一篇Python3操作SQL Server数据库(实例讲解)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-10-10
  • python b站视频下载的五种版本

    python b站视频下载的五种版本

    该项目用于Bilibili(b站)视频下载(支持分P多段视频的下载），基于python开发，有此需求的朋友可以参考下
    2021-05-05
  • 在Python中使用HTML模版的教程

    在Python中使用HTML模版的教程

    这篇文章主要介绍了在Python中使用HTML模版的教程,HTML模版也是Python的各大框架下的一个基本功能,需要的朋友可以参考下
    2015-04-04
  • Python中copy和deepcopy的使用分析

    Python中copy和deepcopy的使用分析

    这篇文章主要介绍了Python中copy和deepcopy的使用，浅拷贝等于赋值，也可以通过copy实现，copy仅拷贝对象本身，deepcopy是真正意义上的复制，深拷贝，被复制对象完全复制一遍作为独立的新个体，新开辟一块空间，需要详细了解的朋友可以参考下
    2021-10-10
  • 多个应用共存的Django配置方法

    多个应用共存的Django配置方法

    今天小编就为大家分享一篇多个应用共存的Django配置方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2018-05-05
  • PyPDF2读取PDF文件内容保存到本地TXT实例

    PyPDF2读取PDF文件内容保存到本地TXT实例

    这篇文章主要介绍了PyPDF2读取PDF文件内容保存到本地TXT实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-05-05
  • python 批量将中文名转换为拼音

    python 批量将中文名转换为拼音

    这篇文章主要介绍了python 批量将中文名转换为拼音，帮助大家更好的理解和使用python，感兴趣的朋友可以了解下
    2021-02-02
  • Python后台开发Django的教程详解（启动）

    Python后台开发Django的教程详解（启动）

    这篇文章主要介绍了Python后台开发Django（启动），本文给大家介绍的非常详细，具有一定的参考借鉴价值 ,需要的朋友可以参考下
    2019-04-04
  • python中for循环的多种使用实例

    python中for循环的多种使用实例

    for语句是Python中执行迭代的两个语句之一,另一个语句是while,下面这篇文章主要给大家介绍了关于python中for循环的多种使用方法,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2022-09-09

最新评论