开源的是一个测试客户端，可以用来检验服务器端程序的并发处理能力。

使用方法为：

python epolltest.py --host=192.168.15.128 --port=8809 --degree=200

其中degree为并发线程数

python 版本为2.6

代码如下

from Queue import Queue

from threading import Thread

from subprocess import check_call

from os import *

import socket

import threading

import exceptions

import sys

import getopt

 

def do_stuff(q,host,port):

s = socket.socket() # Create a socket object

s.connect((host, int(port)))

while True:

try:

value=q.get()

except:

return

# call(["telnet", "192.168.15.128", "8088" , "<" , "echo.txt"])

# check_call("sh" +" autosend.sh" , shell=True)

s.send("suck me\n")

# print threading.current_thread(), value

s.close # Close the socket when done

q.task_done()

def main(argv):

try:

opts, args = getopt.getopt(argv,"h:p:d:",["host=","port=","degree="])

except getopt.GetoptError:

print "python epolltest.py --host=<ip> --port=<port> --degree=<degree>"

sys.exit(2)

for opt, arg in opts:

if opt=="--host":

host=arg

elif opt=="--port":

port=arg

elif opt=="--degree":

degree=arg

q = Queue(maxsize=0)

print degree

for i in range(int(degree)):

worker = Thread(target=do_stuff, args=(q,host,port ))

worker.setDaemon(True)

worker.start()

x=0

while x<=10000000:

q.put(x)

x+=1

q.join()

print "finish"

if __name__ == "__main__":

main(sys.argv[1:])