• 1
  • 1
分享

1、什么是 FastHttpUser

在介绍FastHttpUser之前,我们先看一下,Locust默认客户端使用的是啥?

Locust 默认客户端使用的是python-requests。

>> 如果不了解 python-requests,可以看一下小鱼的这篇:《requests库常用到的7个主要方法及控制访问参数》

或者官方文档,如果有足够耐心的话:《Requests》

我们接着说,使用requests是Pyhton维护非常方便的包,并且在python应用中非常广泛,栗如:爬虫,接口等。

所以,官网是非常推荐我们使用HttpUser。

但是,如果我们的测试规模非常大,数据量非常大,那么这个时候,我们就可以使用 Http客户端,该客户端使用的是geventhttpclient 而不是请求,好处呢,就是进行HTTP请求的性能提高了5~6倍,是不是很厉(尿)害(性) !!!

注:

1、提高 5~6倍,这并不意味着每个CPU内核可以模拟的用户数量将自动增加到5至6倍,因为这不去取决于负载测试脚本的其他功能;

2、如果locust脚本在执行HTTP请求时花费大量的CPU时间,那么将会得到显著的性能提升!

1.1、 geventhttpclient厉害之处

1.1.1 初识 geventhttpclient

    1、geventhttpclient专门为高并发、流传输和支持HTTP 1.1持久连接而设计。

    2、它旨在有效地从REST API和Twitter之类的流API中提取信息。

    3、默认情况下,提供SSL支持。

    >>>① geventhttpclient取决于证书CA Bundle。

    >>>② 这是与Requests代码库一起提供的相同的CA Bundle,它是从Mozilla Firefox的规范集衍生而来的。

    4、支持Python 2.7和Python 3.4+。不再支持Python 2.6。

注:

    官方不建议将SSL / TLS与python 2.7.9一起使用。

1.1.2 geventhttpclient实例展示

很简答的一段代码,就是通过geventhttpclient 来获取 请求,响应信息,状态码等数据。 

老规矩,上代码

# -*- coding:utf-8 -*-
# @Time   : 2022-05-28
# @Author : Carl_奕然

from geventhttpclient import HTTPClient
from geventhttpclient.url import URL
url  = URL('http://baidu.com')
http =HTTPClient(url.host)
#获取一个请求
response  = http.get(url.request_uri)
#读取状态码
response.status_code 
#读取返回内容
body = response.read()
#关闭链接
http.close()

1.1.3 高并发 代码实战

HTTPClient具有内置的连接池,可以在多个并发线程中使用同一个实例。

上代码,

# -*- coding:utf-8 -*-
# @Time   : 2022-05-28
# @Author : Carl_奕然

import gevent.pool
import json
from geventhttpclient import HTTPClient
from geventhttpclient.url import URL
#获取某网站的token
Token = '<go to http://developers.xxx.com/tools/explorer and copy the access token>'
url = URL('https://xxx.com/me/friends')
url['access_token'] = Token
#设置 10个并发和10和连接数
http = HTTPClient.from_url(url,concurrency =10)
#设置响应请求
response = http.get(url.request_uri)
#抛出 状态
assert response.status_code == 200
#将读取的信息流,传递到json解析器中
data = json.loads(response)['data']
#定义方法,来打印friend_username
def print_friend_username(http,friend_id):
    #设置 http,friend_id 两个参数
    #url地址拼接
    fiend_url = URL('/'+str(friend_id))
    fiend_url['access_token'] = Token
    #在链接之前,线程会处于阻塞状态
    response = http.get(fiend_url.request_uri)
    assert response.status_code ==200
    
    friend = json.load(response)
    #判断是否存在username 
    if friend.has_key('username'):
        print (f"{firend['username']} :{friend['name']}")
    else:
        print(f"{friend['name'] has no username}")
    #设置一次运行20个线程
    pool = gevent.pool.Pool(20)
    #循环读取
    for item in data:
        friend_id = item['id']
        pool.spawn(print_friend_username,http,friend_id)
    pool.json()
    #关闭 
    http.close()

这里小鱼在强调几点:

1、信息最好是使用json解析器,快捷方便;

2、线程数根据自己是实际业务量来编写;

3、每次执行完,在最后,需要关闭http,不然耗资源。

4、小鱼自认为,注释还算明白,不明白的,可要补基础知识了!

1.1.4 数据流 代码实战

geventhttpclient支持流,这是一大特色,

响应状态具有:read(),readline()方法,他们都是以增量的方式读取。

我们来个例子,看看牛在啥地方

# -*- coding:utf-8 -*-
# @Time   : 2022-05-28
# @Author : Carl_奕然

from geventhttpclient import HTTPClient
from geventhttpclient.url import URL
#本地的文件地址
url = URL('http://127.0.0.1:80/100.dat')
#获取请求
http = HTTPClient.from_url(url)
#获取响应信息
response = http.get(url.query_string)
#抛出200的说明OK的
assert response.status_code == 200
#文件的大小
CHUNK_SIZE = 1024 * 16 # 16KB
#with方法打开文件
with open('/data/100.dat', 'w') as f:
while  data:
f.write(data)
data = response.read(CHUNK_SIZE)

小屌丝:鱼哥,这不就是一个下载大文件的方法吗?

小鱼:是啊,

小屌丝:那这有啥稀奇的,我到没看出来啥道道。

小鱼:那你知道,下载大文件的方法那么多,我为啥偏偏喜欢用 gevent 来下载?

小屌丝:因为你现在不就是在讲 geventhttpclient嘛!(很装叉的样子)

小鱼:还有呢??

小屌丝:额…

小鱼:因为 使用geventhttpclient ,可以节省内存啊 !!!!

小屌丝:挖草~ 这也可以!!

2、如何使用FastHttpUser

我们直接上代码,

在代码中,理解如何使用

# -*- coding:utf-8 -*-
# @Time   : 2022-05-28
# @Author : Carl_奕然

from locust import task,between
from locust.contrib.fasthttp import FastHttpUser
class MyUser(FastHttpUser):
#设置时间间隔在 1~5秒之间
wite_time = (1,5)
@task
def index(self):
response = self.client.get("/")

看到没有,就是这么简单,

如果没理解@task的用法,可以参照小鱼的上一篇文章,

《深聊性能测试,从入门到放弃之:Locust性能自动化(二)代码实战》

这里有详细介绍 @task的用法,在本篇不多阐述。

注: 

因为 FastHttpUser 使用的是不同的客户端(geventhttpclient)及API来实现,所以, 并不总能代替HttpUser,但是偶尔可以代替一下!!!!

3、FastHttp 的API 类

3.1、FastHttpUser类

刚刚小鱼也提到了, FastHttpUser与HttpUser(python-requests)相比,

使用的是 (geventhttpclient) 这个客户端,所以:

    ① 速度比HttpUser 快;

    ②功能比HttpUser 弱。

由于该用户的行为由其任务定义,可以通过使用 @task decorator 方法或通过设置来直接在类上声明 ,takss attribute。

此类在实例化时创建一个客户端属性,该属性是一个HTTPClient,支持在请求之间保持用户会话。

接下来,详细看一下:

1、定义FastHttpUser 类

#定义FastHttpUser 类
 class FastHttpUser(environment)

2、参数及定义

# 传递给FastHttpSession的参数
connection_timeout: float= 60.0
#参数传递给FastHttpSession。默认值为True,表示不进行SSL验证。
insecure: bool= True
#参数传递给FastHttpSession。默认值5,表示4次重定向。
max_retries: int= 1
#参数传递给FastHttpSession。默认值1,表示零重试。
max_redirects: int= 5
#传递给FastHttpSession的参数
network_timeout: float= 60.0

3.2、 FastHttpSession类

关于 FastHttpSession类的内容,我们直接代码中解析:

1、定义FastHttpSession 类

#定义FastHttpSession 类
 class FastHttpUser(environment,base_url,insecure = True,** kwargs)

2、参数及定义

# 发送get请求
get(Path,**kwargs)
# 发送head请求
head(Path,**kwargs)
# 发送option请求
option(Path,**kwargs)
# 发送patch请求
patch(Path,data = None,**kwargs)
# 发送post请求
post(Path,data = None,**kwargs)
# 发送put请求
put(Path,data = None,**kwargs)
#发送http请求并返回loucst.contrib.fasthttp.FastResponse 对象
request(method, path, name=None, data=None, catch_response=False, stream=False, headers=None, auth=None, json=None, allow_redirects=True, **kwargs)

这里我们单独解析一下 request方法里面的参数:

    ①method: 新的request 方法;

    ②path:请求主机地址,url;

    ③name:可选参数,可以指定为在Locust的统计信息中用作标签,而不是URL路径;

    ④data:可选参数,要在请求正文中发送的字符串/字节;

    ⑤catch_response:可选参数,如果已设置,则可用于发出请求,以返回上下文管理器以用作with语句的参数。可自行进行标记,例如200可以设置Success,也可以设置成Fail。

    ⑥stream:可选参数,

    >>>>如果设置成Ture,则不会立即使用响应主体,而是可以通过访问Response对象上的stream属性来使用它;

    >>>>如果设置成False,在Locust报告的请求时间中不会考虑下载响应内容的时间。

    ⑦headers:与请求一起发送的HTTP headers字典;

    ⑧auth:可选参数,身份认证(用户名、密码等);

    ⑨json:可选参数,在请求正文中发送的字典。

3.3、FastResponse类

1、定义FastResponse 类

#定义FastResponse 类
 classFastResponse(ghc_response, request=None, sent_request=None)

2、参数及定义

    ① content属性:

    必要时解压缩并缓冲接收到的正文。注意大文件的情况!

    ②headers:

    包含响应标头的类对象字典;

    ③json():

    将响应解析为json并返回一个dict;

    ④text属性:

    以解码的字符串形式返回响应的文本内容。 

 


  • 【留下美好印记】
    赞赏支持
登录 后发表评论
+ 关注

热门文章

    最新讲堂

      • 推荐阅读
      • 换一换
          • 安装Python3.7.1此处不再赘述安装过程,作为记录安装Anaconda3.5.3Anaconda3-5.3.0-Windows-x86_64.exe方案1:可以直接从官网https://www.anaconda.com/distribution/,默认下载最新版本,19年3月27日为python3.7.1版本方案2:清华镜像https://mirrors.tuna.tsinghua.edu.cn/anaconda/archive/,速度快很多安装完成之后,在Anaconda里新建一个虚拟环境machinelearn(这里是图形界面创建环境)切换仓库地址命令窗口里输入如下代码,载入清华镜像...
            0 1 2399
            分享
          •   一、什么是敏捷测试?  敏捷测试是一种在敏捷开发中进行软件测试的方法。它强调快速、迭代和协作,以确保软件的质量和交付速度。  在敏捷测试中,测试人员需要与开发人员密切合作,尽早参与到项目中,并在整个开发过程中持续测试。测试人员不仅要测试软件的功能,还要关注软件的性能、可用性和安全性等方面。  敏捷测试强调测试的自动化,以提高测试效率和覆盖范围。测试人员通常会使用自动化测试工具来编写和执行测试用例,以便在短时间内获得反馈。同时,敏捷测试也鼓励测试人员采用探索性测试等方法,发现软件中可能存在的问题。  另外,敏捷测试还注重团队的沟通和协作。测试人员需要与开发人员、产品经理和其他相关人员保持良好...
            0 0 257
            分享
          • 新浪科技讯北京时间11月16日早间消息,据报道,知情人士透露,亿万富翁埃隆·马斯克(Elon Musk)旗下的SpaceX正在进行谈判,该准备在新一轮融资中筹集近10亿美元,这将使这家火箭发射和卫星的估值达到1500亿美元左右。知情人士称,在正在进行中的谈判中,SpaceX的每股价格约为85美元,并将该今年早些时候的1205亿美元估值进一步推高。其中一位知情人士补充说,该公司的本轮融资可能会获得近10亿美元的资金。这表明,投资者对该的兴趣很高,而与此同时,其他一些处于后期融资的初创企业却不得不面临削减估值的情况。对此,SpaceX没有立即对置评请求做出回应。据悉,SpaceX与亚马逊创始人杰夫...
            0 0 1034
            分享
          • 软件测试也是近几年才火爆起来,由于其入门低、容易上手、对学历要求低等特点,使其迅速蓬勃发展起来。但俗话"入门容易成才难",软件测试包罗万象从文档静态测试、手工测试、自动化测试、单元测试、集成测试、安全测试、兼容性测试等各种形态或阶段测试,这些阶段都需要极强的理论基础和扎实技术功底。由于近年来大数据、云计算、物联网、人工智能、区块链等技术的兴起与使用,软件测试面临的挑战也越来越多,软件测试工程师遇到的机遇与挑战也越来越多。借用一句话“物竞天择,适者生存”,那如何在软件测试行业保持自己的核心竞争力呢?个人认为保持个人核心竞争的一个前提是要有“终身学习的理念”。你从事软件测试可能...
            0 0 2105
            分享
          •   并发测试和持续性压测都是评估系统性能的常用方法,它们可以帮助开发人员发现并解决系统中的性能问题。本文来详细介绍下。  概念  并发测试:旨在评估系统在同时处理多个用户请求时的性能。在这种 测试 中,系统会暴露于一定数量的用户负载下,并且会记录系统的响应时间、吞吐量和资源利用率等指标。这些指标可以用来确定系统的性能瓶颈,以及在不同负载下系统的表现。  持续性压测:旨在评估系统在长时间运行或高负载下的性能。在这种测试中,系统会暴露于一定数量的用户负载下,并且会持续一段时间运行,通常在几个小时或几天。这种测试可以用来确定系统在长时间运行下的表现,以及在高负载下系统是否具有可扩展性。  并发测试 ...
            0 0 128
            分享
      • 51testing软件测试圈微信