python多线程实现http请求

#!/usr/bin python2.6

# -*- coding: utf-8 -*-

import threading, datetime, time, httplib

# 初始最大并发数

START_THEAD_COUNT = 200

# 递增并发数

THREAD_INCREASE_STEP = 10

# 域名

DOMAIN = 'www.baidu.com'

# 默认http请求

METHOD = 'get'

# 默认访问的web路径

PATH = '/'

# 请求发送间隔 整数

INTERVAL = 5  # 5秒

'''Factory'''

class biz :

    '''Main'''

    def run(self) :

        start = datetime.datetime.now()

        global FAILED_COUNT

        FAILED_COUNT = 0

        threads = []

        

        # thread instance initialization

        for i in range(START_THEAD_COUNT) :

            t=threading.Thread(target=self.execute, args=())

            threads.append(t)

        # activate threads

        for i in range(START_THEAD_COUNT) :

            threads[i].start()

        # wait for all ends

        for i in range(START_THEAD_COUNT) :

            threads[i].join()

        delta = datetime.datetime.now() - start

        writeline('INFO', 'Total is \'' + str(START_THEAD_COUNT) + '\' while failed \'' + str(FAILED_COUNT) + '\' in ' + str(delta.seconds) + str(delta.microseconds / 1000) + 'ms.')

        return (True, None)

    '''Execute http request and get response status'''

    def execute(self) :

        global FAILED_COUNT

        conn = httplib.HTTPConnection(DOMAIN)

        conn.request(METHOD, PATH)

        r = conn.getresponse()

        if r.status not in (200, 302) : FAILED_COUNT = FAILED_COUNT + 1

        conn.close()

        return (True, None)

'''Log writer'''

def writeline(status, msg) :

    line = time.strftime('%Y-%m-%d %X', time.localtime(time.time())) + ' [' + status + '] ' + msg

    print line

    return (True, line)

if __name__ == '__main__' :

    o = biz()

    while True :

        r, c = o.run()

        if not r : writeline('FAILED-', c)

        

        time.sleep(INTERVAL)

        

        # update max threads

        START_THEAD_COUNT = START_THEAD_COUNT + THREAD_INCREASE_STEP