今天上來(lái)分享一下昨天實(shí)現(xiàn)的一個(gè)多線程網(wǎng)頁(yè)下載器。

這是一個(gè)有著真實(shí)需求的實(shí)現(xiàn)，我的用途是拿它來(lái)通過(guò) HTTP 方式向服務(wù)器提交游戲數(shù)據(jù)。把它放上來(lái)也是想大家?guī)兔μ舸?#xff0c;找找 bug，讓它工作得更好。

keywords:python,http,multi-threads,thread,threading,httplib,urllib,urllib2,Queue,http pool,httppool

廢話少說(shuō)，上源碼：

# -*- coding:utf-8 -*- import urllib, httplib import thread import time from Queue import Queue, Empty, Full HEADERS = {"Content-type": "application/x-www-form-urlencoded",'Accept-Language':'zh-cn','User-Agent': 'Mozilla/4.0 (compatible; MSIE 6.0;Windows NT 5.0)',"Accept": "text/plain"} UNEXPECTED_ERROR = -1 POST = 'POST' GET = 'GET' def base_log(msg):print msg def base_fail_op(task, status, log):log('fail op. task = %s, status = %d'%(str(task), status)) def get_remote_data(tasks, results, fail_op = base_fail_op, log = base_log):while True:task = tasks.get()try:tid = task['id']hpt = task['conn_args'] # hpt <= host:port, timeoutexcept KeyError, e:log(str(e))continuelog('thread_%s doing task %d'%(thread.get_ident(), tid))#log('hpt = ' + str(hpt))conn = httplib.HTTPConnection(**hpt)try:params = task['params']except KeyError, e:params = {}params = urllib.urlencode(params)#log('params = ' + params)try:method = task['method']except KeyError:method = 'GET'#log('method = ' + method)try:url = task['url']except KeyError:url = '/'#log('url = ' + url)headers = HEADERStry:tmp = task['headers']except KeyError, e:tmp = {}headers.update(tmp)#log('headers = ' + str(headers))headers['Content-Length'] = len(params)try:if method == POST:conn.request(method, url, params, headers)else:conn.request(method, url + params)response = conn.getresponse()except Exception, e:log('request failed. method = %s, url = %s, params = %s headers = %s'%(method, url, params, headers))log(str(e))fail_op(task, UNEXPECTED_ERROR, log)continueif response.status != httplib.OK:fail_op(task, response.status, log)continuedata = response.read()results.put((tid, data), True)class HttpPool(object):def __init__(self, threads_count, fail_op, log):self._tasks = Queue()self._results = Queue()for i in xrange(threads_count):thread.start_new_thread(get_remote_data, (self._tasks, self._results, fail_op, log))def add_task(self, tid, host, url, params, headers = {}, method = 'GET', timeout = None):task = {'id' : tid,'conn_args' : {'host' : host} if timeout is None else {'host' : host, 'timeout' : timeout},'headers' : headers,'url' : url,'params' : params,'method' : method,}try:self._tasks.put_nowait(task)except Full:return Falsereturn Truedef get_results(self):results = []while True:try:res = self._results.get_nowait()except Empty:breakresults.append(res)return resultsdef test_google(task_count, threads_count):hp = HttpPool(threads_count, base_fail_op, base_log)for i in xrange(task_count):if hp.add_task(i,'www.google.cn','/search?',{'q' : 'lai'}, # method = 'POST'):print 'add task successed.'while True:results = hp.get_results()if not results:time.sleep(1.0 * random.random())for i in results:print i[0], len(i[1]) # print unicode(i[1], 'gb18030')if __name__ == '__main__':import sys, randomtask_count, threads_count = int(sys.argv[1]), int(sys.argv[2])test_google(task_count, threads_count)

from:?http://blog.csdn.net/gzlaiyonghao/article/details/4083852

總結(jié)

以上是生活随笔為你收集整理的用 python 实现一个多线程网页下载器的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。