快捷導(dǎo)航

Python實現(xiàn)可設(shè)置持續(xù)運行時間、線程數(shù)及時間間隔的多線程異步post請求功能

更新時間：2018年01月11日 11:41:45 作者：壞蛋是我

這篇文章主要介紹了Python實現(xiàn)可設(shè)置持續(xù)運行時間、線程數(shù)及時間間隔的多線程異步post請求功能,涉及Python網(wǎng)絡(luò)請求的創(chuàng)建、發(fā)送、響應(yīng)、處理等相關(guān)操作技巧,需要的朋友可以參考下

本文實例講述了Python實現(xiàn)可設(shè)置持續(xù)運行時間、線程數(shù)及時間間隔的多線程異步post請求功能。分享給大家供大家參考，具體如下：

#coding=utf8
'''
random.randint(a, b):用于生成一個指定范圍內(nèi)的整數(shù)。
其中參數(shù)a是下限，參數(shù)b是上限，生成的隨機數(shù)n: a <= n <= b
random.choice(sequence)：從序列中獲取一個隨機元素
參數(shù)sequence表示一個有序類型（列表，元組，字符串）
'''
import httplib,json
import time
import threading
from random import randint,choice
#創(chuàng)建請求函數(shù)
def postRequest(threadNum):
  postJson={
        }
  #定義需要進行發(fā)送的數(shù)據(jù)
  postData=json.dumps(postJson)
  #定義一些文件頭
  headerdata = {
    "content-type":"application/json",
     }
  #接口
  requrl ="/v1/query"
  #請求服務(wù),例如：www.baidu.com
  hostServer=""
  #連接服務(wù)器
  conn = httplib.HTTPConnection(hostServer)
  #發(fā)送請求
  conn.request(method="POST",url=requrl,body=postData,headers=headerdata)
  #獲取請求響應(yīng)
  response=conn.getresponse()
  #打印請求狀態(tài)
  if response.status in range(200,300):
    print u"線程"+str(threadNum)+u"狀態(tài)碼："+str(response.status)
  conn.close()
def run(threadNum,internTime,duration):
  #創(chuàng)建數(shù)組存放線程
  threads=[]
  try:
    #創(chuàng)建線程
    for i in range(1,threadNum):
      #針對函數(shù)創(chuàng)建線程
      t=threading.Thread(target=postRequest,args=(i,))
      #把創(chuàng)建的線程加入線程組
      threads.append(t)
  except Exception,e:
    print e
  try:
    #啟動線程
    for thread in threads:
        thread.setDaemon(True)
        thread.start()
        time.sleep(internTime)
    #等待所有線程結(jié)束
    for thread in threads:
        thread.join(duration)
  except Exception,e:
      print e
if __name__ == '__main__':
  startime=time.strftime("%Y%m%d%H%M%S")
  now=time.strftime("%Y%m%d%H%M%S")
  duratiion=raw_input(u"輸入持續(xù)運行時間:")
  while (startime+str(duratiion))!=now:
    run(10,1,int(duratiion))
    now=time.strftime("%Y%m%d%H%M%S")

運行結(jié)果：