小屌丝：鱼哥，我想写一个接口订单并发性能，能不能给我讲一下
小鱼：接口订单并发？我前篇文章不是写过常见并发框架
，然后你在追加一个创建订单和生成订单不就可以了？
小屌丝：鱼哥，你说的可轻松，那你能不能来一个？
小鱼：好吧，那我就以我某个项目为例，我们实际的看一下，都需要哪些步骤。
小屌丝： 鱼哥，就你这一点，最招人稀罕。哈哈！
小鱼：挖草了~~
那么我们就来分析一下，订单并发性能，我们想要什么：
>>1.订单并发数
>>2.成功订单数
>>3.订单成功率
>>4.成功订单总响应时间
>>5.成功订单平均响应时间
>>6.TPS
有了上面我们想要的，那么我们就来分析如何获取这些信息：
并发订单数：即自定义的并发数，根据我们的想法，把并发200次，设置为20个线程，每个循环10次
成功订单数：就是获取响应值为成功的请求，先定义一个success_count ，初始值为0，每成功一次，增加1
订单成功率：成功订单数/总的订单数
成功订单总响应时间：每个成功订单的响应时间之和，所以我们定义一个sum_time，初始值为0.00，然后把每次成功的响应时间加起来
成功订单平均响应时间：成功订单总响应时间/成功订单数
TPS：成功并发数/成功订单平均响应时间
订单响应时间：在请求之前，获取一次时间，在断言成功之后，再次获取一次时间，这样二者之差，就是订单的响应时间。
了解了思路之后，我们就看实际源码：
# -*- coding: utf-8 -*-
"""
@ auth : carl_DJ
@ time : 2020-6-11
"""
import hashlib
import threading
from time import *
from datetime import datetime,timedelta
import requests
import json
'''初始化全局变量'''
#自定义全局变量需要的线程数,20
thread_num = 20
#自定义全局变量每个线程需要循环的数量,10
one_worker_num = 10
#设定最开始的总时间
sum_time = 0.00
#设定最开始的成功连接数
success_count = 0
''' 后台登录常规操作'''
username = '13388889999'
password = hashlib.md5(b'123456').hexdigest() #设置密码，且是md5加密方式
url = "http://www.xxx.com/energy/user/login/"
form_data = {"username":username,"password":password}
login_response = requests.post(url,data=form_data)
c = login_response.cookies
'''订单发送请求'''
def order():
#引用全局变量
global c
global sum_time
global success_count
#获取执行发送订单请求前时间
t1 = time()
#设定url、form_data进行创建订单
url1 = "http://www.xxx.com/energy/create_order/"
from_data1 = {"restaurant_id":1136,
"menu_item_total":'12.00',
"menu_item_data": [{'id':2667868,'p':22,'q':3}]
}
make_responst = requests.post(url1,data=from_data1,cookies = c)
#获取请求结果
res = make_responst.text
#结果转换成字典赋值给变量id
id = json.loads(res)['order_id']
#断言判断是否提交成功
assert id != " "
su_time =datetime.now()+ timedelta(hours=1)
#设定url、form_data进行生成订单
url2 = "http://www.xxx.com/energy/place_order/"
from_data2 = {"restaurant_id": id,
"customer_name": 'carl_dj',
"mobile_number":username,
"delivery_address":"address message",
"pay_type":'cash',
"preorder":su_time
}
place_responst = requests.post(url2, data=from_data2, cookies=c)
res = place_responst.text
#追加断言，判断结果是否有"success"，有的话，说明订餐成功
assert res == " success"
print("订餐成功")
#订单成功后，再次获取一下时间
t2 = time()
#获取订单的响应时间
res_time = t2-t1
#把响应时间写入txt文件
result = open("E:\Private Folder\res.txt","a") #路径直接写死，也可用os.path 来写路径
result.write("成功订单响应时间：" + str(res_time)+ '\n')
result.close()
#也可以使用with打开文件，好处是不用关心文件是否关闭
# with open ("E:\Private Folder\res.txt","a") as result1:
# print(result1.read())
#把每次成功订单数累加到全局变量sum_time中
sum_time = sum_time + res_time
#把每次获取的成功订单数做累加，添加到全局变量success_count中
success_count = success_count +1
'''嵌套指定循环次数的order()函数'''
def working()
global one_worker_num
for i in range(0,one_worker_num):
order()
'''自定义main（）函数，来执行多线程'''
def main():
global thread_num
#自定义一个空的数组，用来存放线程组
threads = []
#设置循环次数
for i in range(thread_num):
#将working()函数存放到线程中
t = threading.Thread(target=working,name="T"+ str(i))
#设定守护线程
t.setDaemon(True)
threads.append(t)
#启动循环执行
for t in threads:
t.start()
##设置阻塞线程
for t in threads:
t.join()
if __name__ == "__main__":
main()
total_order = thread_num*one_worker_num
avg_time = sum_time/success_count
'''执行完之后，需要把数据写入到txt文件中'''
#订单并发总数
result.write("并发订单数："+ str(total_order)+ "\n")
#成功并发数
result.write("成功并发数："+ str(success_count) + "\n")
#订单成功率
result.write("订单成功率："+ str(success_count/total_order*100)+ "%" + "\n")
#成功订单响应时间
result.write("成功订单总响应时间："+ str(sum_time)+"\n")
#成功订单平均响应时间
result.write("成功平均响应时间："+str(sum_time/success_count)+"\n")
#TPS事务数/秒
result.write("TPS:"+str(success_count/avg_time) + "\n") #tps = 并发成功数/平均响应时间
result.close()
注：
1.这里运用到了str(),
>>是因为响应时间是数字，而写入文件的时候是字符串类型，所以需要把最后的数字通过str()函数进行转化。
2.这里的文件路径是直接写死的，并没有使用os.path获取。
3.打开文件的方式 ：open () 或者with open() 都可以，这里两种方法都写了。
>使用open()方法，最后别忘了close()，不然消耗资源…
