python利用多線程讓http請求異步返回

有時我們可能會碰到這樣一種情況，我們有一個功能，這個功能對外提供了一個http接口，我們需要對這個http接口發起請求才能啟動這個服務，但是這個服務功能可能會執行很久，這樣如果等功能執行結束再返回請求結果，那這個請求可能就超時了，

 

發起請求的客戶端

import requests
 
req = requests.get("http://127.0.0.1:9898/register?username=aaa&pwd=232323")
print(req.content)

 

服務端

# coding=utf-8
import flask
from flask import jsonify
from flask import request

from gevent import pywsgi

import sys
reload(sys)
import time
sys.setdefaultencoding('utf-8')

server = flask.Flask(__name__)

@server.route('/register', methods=['get', 'post'])
def registerPost():
    # post請求獲取請求的參數，返回結果類型是str
    username = request.values.get('username')
    pwd = request.values.get('pwd')
    app_id = request.values.get('app_id') 21  dowork(app_id) 22     # confirmpwd = request.values.get('confirmpwd')
    if username and pwd:  # 判斷輸入的用戶名、密碼、確認密碼都不為空
        return ("用戶名為：%s, 密碼為：%s" % (username, pwd))
    else:
        return jsonify({"code": 504, "msg": "必填項不能為空"})


if __name__ == '__main__':
    # port可以指定端口，默認端口是5000
    # host默認是127.0.0.1,寫成0.0.0.0的話，其他人可以訪問，代表監聽多塊網卡上面，
    # server.run(debug=True, port=9898, host='0.0.0.0')
    server = pywsgi.WSGIServer(('0.0.0.0', 9898), server)
    server.serve_forever()

這個就是一個典型的同步返回結果，發起請求后，必須等 dowork() 功能執行完之后才能返回請求結果，如果 dowork() 執行時間較長，則會導致客戶端請求超時

 

這時我們可能就需要一個異步的http接口，收到客戶端的請求后，馬上返回一個請求結果，然后再慢慢的執行要執行的任務，這個過程怎么實現呢，我的做法是通過多線程來實現，在服務端的響應函數中，每次收到一個請求，獲取請求中攜帶的參數，然后用這些參數創建一個會執行我們功能服務的線程，最后返回請求結果，這樣客戶端可以很快獲取到請求結果，從而不會讓客戶端請求超時

 

下面是加入了線程的服務端的響應函數

# coding=utf-8
import flask
from flask import jsonify
from flask import request

from gevent import pywsgi

import sys
reload(sys)
import time
sys.setdefaultencoding('utf-8')

server = flask.Flask(__name__)

import threading
import time

exitFlag = 0

class myThread (threading.Thread):
    def __init__(self, threadID, name, counter, app_id):
        threading.Thread.__init__(self)
        self.threadID = threadID
        self.name = name
        self.counter = counter
        self.app_id = app_id 27     def run(self):
        print ("開始線程：" + self.name)
        print_time(self.name, self.counter, 1, self.app_id)
        print ("退出線程：" + self.name)

def print_time(threadName, delay, counter, app_id):
    while counter:
        if exitFlag:
            threadName.exit()
        time.sleep(delay)
        print ("%s: %s" % (threadName, time.ctime(time.time())))
        dowork(app_id)
        counter -= 1

@server.route('/register', methods=['get', 'post'])
def registerPost():
    # post請求獲取請求的參數，返回結果類型是str
    username = request.values.get('username')
    pwd = request.values.get('pwd')
    app_id = request.values.get('app_id') 47 
    # 創建新線程
    thread1 = myThread(1, "Thread-1", 1, app_id) 50     # 開啟新線程
 thread1.start() 52 
    # confirmpwd = request.values.get('confirmpwd')
    if username and pwd:  # 判斷輸入的用戶名、密碼、確認密碼都不為空
        return ("用戶名為：%s, 密碼為：%s" % (username, pwd))
    else:
        return jsonify({"code": 504, "msg": "必填項不能為空"})


if __name__ == '__main__':
    # port可以指定端口，默認端口是5000
    # host默認是127.0.0.1,寫成0.0.0.0的話，其他人可以訪問，代表監聽多塊網卡上面，
    # server.run(debug=True, port=9898, host='0.0.0.0')
    server = pywsgi.WSGIServer(('0.0.0.0', 9898), server)
    server.serve_forever()

 

因為線程的run()方法和start()方法是不能傳遞參數的，所以如果我們需要從請求中獲取參數然后傳遞給要執行的功能的話，可以在線程的構造方法的參數中加上我們需要傳遞的參數，這樣在run()方法內部我們就能動態獲得請求中傳遞的參數了

 

下面是菜鳥教程里面的多線程模板

#!/usr/bin/python3

import threading
import time

class myThread (threading.Thread):
    def __init__(self, threadID, name, counter):
        threading.Thread.__init__(self)
        self.threadID = threadID
        self.name = name
        self.counter = counter
    def run(self):
        print ("開啟線程： " + self.name)
        # 獲取鎖，用於線程同步
        threadLock.acquire()
        print_time(self.name, self.counter, 3)
        # 釋放鎖，開啟下一個線程
        threadLock.release()

def print_time(threadName, delay, counter):
    while counter:
        time.sleep(delay)
        print ("%s: %s" % (threadName, time.ctime(time.time())))
        counter -= 1

threadLock = threading.Lock()
threads = []

# 創建新線程
thread1 = myThread(1, "Thread-1", 1)
thread2 = myThread(2, "Thread-2", 2)

# 開啟新線程
thread1.start()
thread2.start()

# 添加線程到線程列表
threads.append(thread1)
threads.append(thread2)

# 等待所有線程完成
for t in threads:
    t.join()
print ("退出主線程")

執行以上程序，輸出結果為：

開啟線程： Thread-1
開啟線程： Thread-2
Thread-1: Wed Apr  6 11:52:57 2016
Thread-1: Wed Apr  6 11:52:58 2016
Thread-1: Wed Apr  6 11:52:59 2016
Thread-2: Wed Apr  6 11:53:01 2016
Thread-2: Wed Apr  6 11:53:03 2016
Thread-2: Wed Apr  6 11:53:05 2016

參考：

Python3 多線程