在Python中使用异步Socket编程性能测试-Python教程-PHP中文网

首页

后端开发

Python教程

在Python中使用异步Socket编程性能测试

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jun 16, 2016 am 08:43 AM

python socket 异步

OK,首先写一个python socket的server段,对开放三个端口:10000,10001,10002.krondo的例子中是每个server绑定一个端口,测试的时候需要分别开3个shell,分别运行.这太麻烦了,就分别用三个Thread来运行这些services.

import optparse 
import os 
import socket 
import time 
from threading import Thread 
import StringIO 
  
txt = '''1111 
2222 
3333 
4444 
''' 
  
  def server(listen_socket): 
  while True: 
    buf = StringIO.StringIO(txt) 
    sock, addr = listen_socket.accept() 
    print 'Somebody at %s wants poetry!' % (addr,) 
    while True: 
        try: 
          line = buf.readline().strip() 
          if not line: 
            sock.close() 
            break 
          sock.sendall(line) # this is a blocking call 
          print 'send bytes to client:%s' % line 
          #sock.close() 
        except socket.error: 
          sock.close() 
          break 
        time.sleep(1) #server和client连接后，server会故意每发送一个单词后等待一秒钟后再发送另一个单词 
  
  def main(): 
  ports = [10000, 10001, 10002] 
  for port in ports: 
    listen_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
    listen_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
    addres = (str('127.0.0.1'), port) 
    listen_socket.bind(addres) 
    listen_socket.listen(5) 
    print "start listen at:%s" % (port,) 
    worker = Thread(target = server, args = [listen_socket]) 
    worker.setDaemon(True) 
    worker.start() 
  
  if __name__ == '__main__': 
  main() 
  while True: 
    time.sleep(0.1) #如果不sleep的话,CPU会被Python完全占用了 
    pass

登录后复制

下面是一个client,没有才用异步网络,连接这个三个端口的server:

import socket 
  
  
if __name__ == '__main__': 
  ports = [10000, 10001, 10002] 
  for port in ports: 
    address = (str('127.0.0.1'), port) 
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
    sock.connect(address) 
    poem = '' 
    while True: 
      data = sock.recv(4) 
      if not data: 
        sock.close() 
        break 
      poem += data 
    print poem

登录后复制

下面用异步的client来读取，代码如下：

import datetime, errno, optparse, select, socket 
  
def connect(port): 
  """Connect to the given server and return a non-blocking socket.""" 
  address = (str('127.0.0.1'), port) 
  sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
  sock.connect(address) 
  sock.setblocking(0) 
  return sock 
  
def format_address(address): 
  host, port = address 
  return '%s:%s' % (host or '127.0.0.1', port) 
  
if __name__ == '__main__': 
  ports = [10000, 10001, 10002] 
  start = datetime.datetime.now() 
  
  sockets = map(connect, ports) 
  poems = dict.fromkeys(sockets, '') # socket -> accumulated poem  
  
  # socket -> task numbers 
  sock2task = dict([(s, i + 1) for i, s in enumerate(sockets)]) 
  sockets = list(sockets) # make a copy 
  
  while sockets: 
    #运用select来确保那些可读取的异步socket可以立即开始读取IO 
    #OS不停的搜索目前可以read的socket，有的话就返回rlist 
    rlist, _, _ = select.select(sockets, [], []) 
    for sock in rlist: 
      data = '' 
      while True: 
        try: 
          new_data = sock.recv(1024) 
        except socket.error, e: 
          if e.args[0] == errno.EWOULDBLOCK: 
            break 
          raise 
        else: 
          if not new_data: 
            break 
          else: 
            print new_data 
            data += new_data 
  
      task_num = sock2task[sock] 
      if not data: 
        sockets.remove(sock) 
        sock.close() 
        print 'Task %d finished' % task_num 
      else: 
        addr_fmt = format_address(sock.getpeername()) 
        msg = 'Task %d: got %d bytes of poetry from %s' 
        print msg % (task_num, len(data), addr_fmt) 
  
      poems[sock] += data 
  
  elapsed = datetime.datetime.now() - start 
  print 'Got poems in %s' % elapsed

登录后复制

结果只需要4秒就完成了读取任务。效率是刚才同步socket的三倍。对客户端的异步改造主要有两点：

同步模式下，客户端分别创建socket；而在异步模式下，client开始就创建了所有的socket。
通过“sock.setblocking(0)”设置socket为异步模式。
通过Unix系统的select俩返回可读取IO
最为核心的是26行和29行。尤其是29行的select操作返回待读取socket的列表。

本站声明

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

热AI工具

热工具

热门话题

gmail邮箱登陆入口在哪里

7316

Java教程

1625

CakePHP 教程

1349

Laravel 教程

1261

PHP教程

1208

显示更多

Related knowledge

怎么下载deepseek 小米 Feb 19, 2025 pm 05:27 PM

如何下载 DeepSeek 小米？在小米应用商店搜索“DeepSeek”，如未找到，则继续步骤 2。确定您的需求（搜索文件、数据分析），并找到包含 DeepSeek 功能的相应工具（如文件管理器、数据分析软件）。

deepseek怎么问他 Feb 19, 2025 pm 04:42 PM

有效使用DeepSeek的关键在于清晰提问：直接、具体地表达问题。提供具体细节和背景信息。对于复杂的询问，包含多个角度和反驳观点。关注特定方面，例如代码的性能瓶颈。对得到的答案保持批判性思维，结合专业知识进行判断。

deepseek该怎么搜索 Feb 19, 2025 pm 05:18 PM

直接使用DeepSeek自带的搜索功能即可，它强大的语义分析算法能准确理解搜索意图，提供相关信息。但对于冷门领域、最新信息或需要思考问题的搜索，需要调整关键词或使用更具体的描述、结合其他实时信息来源，并明白DeepSeek只是一个工具，需要主动、清晰、精细的搜索策略。

deepseek怎么编程 Feb 19, 2025 pm 05:36 PM

DeepSeek并非编程语言，而是深度搜索概念。实现DeepSeek需基于现有语言选择。针对不同应用场景，需要选择合适的语言和算法，并结合机器学习技术。代码质量、可维护性、测试至关重要。根据需求选择合适的编程语言、算法和工具，并编写高质量代码，才能成功实现DeepSeek。

deepseek怎么用来算账 Feb 19, 2025 pm 04:36 PM

问题：DeepSeek是否可用于会计？回答：不是，它是一个数据挖掘和分析工具，可用于分析财务数据，但本身不具备会计软件的账目记录和报表生成功能。使用DeepSeek分析财务数据需要：编写代码来处理数据具备对数据结构、算法和DeepSeek API的了解考虑潜在的问题（例如，编程知识、学习曲线、数据质量）

编码的关键：为初学者释放 Python 的力量 Oct 11, 2024 pm 12:17 PM

Python通过其易学性和强大功能，是初学者的理想编程入门语言。其基础包括：变量：用于存储数据（数字、字符串、列表等）。数据类型：定义变量中数据的类型（整数、浮点数等）。运算符：用于数学运算和比较。控制流：控制代码执行流（条件语句、循环）。

使用 Python 解决问题：作为初学者，解锁强大的解决方案 Oct 11, 2024 pm 08:58 PM

Python 使初学者能够解决问题。其用户友好的语法、广泛的库以及变量、条件语句和循环等功能可实现高效的代码开发。从管理数据到控制程序流程和执行重复任务，Python 提供了

DeepSeekapi怎么接入-DeepSeekapi接入调用教程 Mar 12, 2025 pm 12:24 PM

DeepSeekAPI接入与调用详解：快速上手指南本文将详细指导您如何接入和调用DeepSeekAPI，助您轻松使用强大的AI模型。第一步：获取API密钥访问DeepSeek官方网站，点击右上角的“开放平台”。您将获得一定数量的免费Tokens（用于计量API使用量）。在左侧菜单中，点击“APIKeys”，然后点击“创建APIkey”。为您的APIkey命名（例如，“test”），并立即复制生成的密钥。请务必妥善保存此密钥，因为它只会显示一次

See all articles

在Python中使用异步Socket编程性能测试

热AI工具

Undresser.AI Undress

AI Clothes Remover

Undress AI Tool

Clothoff.io

AI Hentai Generator

热门文章

热工具

记事本++7.3.1

SublimeText3汉化版

禅工作室 13.0.1

Dreamweaver CS6

SublimeText3 Mac版

热门话题