推荐一款技术人必备:线上引流神器GoReplay

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: 推荐一款技术人必备:线上引流神器GoReplay

一. 线上引流产生背景


日常大部分的测试工作都是在测试环境下,通过模拟用户的行为来对系统进行验证,包括功能以及性能。在这个过程中,你可能会遇到以下问题:

  • 用户访问行为比较复杂,模拟很难和用户行为一致,模拟不够真实。
  • 线下模拟场景有限,会出现业务覆盖不全的情况。

线上引流方案的出现为上述问题提供了很好的解题思路,线上引流本质是:通过把线上的真实流量复制到线下环境,解决测试环境模拟不够真实,或覆盖不够全面的问题。

二. 线上引流常见方案


目前不少公司都对线上引流方案进行了许多实践探索,常见的有以下4种引流方式(不限):

引流方式 实现方式 优点 缺点
Nginx层流量复制 安装lua-nginx-module、ngxdevelkit、headers-more-nginx-module模块,通过lua脚本实现把请求复制给测试环境。 安装和部署还较为简单。 需要开发lua脚本,且对资源有一定占用。
基于业务代码层的引流 将业务代码的调用封装成请求对象,异步的写入缓存中。引流工具通过读缓存中的请求,向测试环境发起请求。 扩展性好,可定制化高。 需要开发流量复制工具,工作量较大,且对工作本身的性能要求较高。
基于访问日志回放 线上系统记录访问日志,引流工具通过解析日志,向测试环境发起请求。 离线方式,对线上影响小。 需要开发日志解析工具,且解析的开销会较大。
基于TCP/IP层的引流 目前已开源的工具有TcpCopy 安装、部署使用都较为简单。 安装、部署使用都较为简单。

上述的几种引流方式各有利弊,有的是需要自己开发相应的工具来支持。而今天给大家

介绍的是另外一款简单易用,学习成本低的引流工具GoReplay


三. 推荐一款引流工具:GoReplay


Gor,又称为GoReplay,是采用Golang 编写的一个开源的 HTTP 实时流量复制工具。它只需要在 LB 或者 入口服务器上执行一个进程,就可以把生产环境的流量复制到任何地方,比如 Staging 环境、Dev 环境。常用于压测及线上问题复现。

注:Golang 是采用Gor 实现且开源的,意味着可以方便的集成到自己的架构中,可以用在压力测试平台、实时流量分析、应用层防火墙等方面。


四. GoReplay工作流程



下面是goreplay官方之前公布的工作流程图,简单来讲就是goreplay捕捉线上流量,并将捕捉到的释放到指定测试服务器上。

微信图片_20220526114008.png

最新GoReplay 官网上更新了一张更高逼规格的图解说明,如下图所示:

微信图片_20220526114046.png

上述流程图展示的已经很详细了,我就不过多解释。

注:Gor不是代理人,不需要将第三方工具放到关键路径上。相反,Gor只是默默地分析你的应用程序的流量,并不影响本身程序。

五. GoReplay支持的常用功能



  • 1、Gor 支持流量的放大和缩小、频率限制,这样不需要搭建和生产环境一致的服务器集群也可以正确测试。
  • 2、Gor 还支持根据正则表达式过滤流量,这意味着可以单独测试某个 API 服务。
  • 3、Gor还可以修改 HTTP 请求头,比如替换 User-Agent, 或者增加某些 HTTP Header 。
  • 4、Gor 还可以把请求记录到文件,以备回放和分析。Gor 支持和 ElasticSearch 集成,将流量存入 ES 进行实时分析。
  • 5、上线前在预发布环境,使用线上真实的请求,检查是否准备发布的版本,是否具备发布标准。
  • 6、压力测试完成后,用线上真实的请求,加速后回放至测试环境,检查是否有报错等问题。
  • 7、用线上的流量转发到预发布或测试环境,检查相同流量下一些指标的反馈情况,检查核心数据是否需要改善。
  • 8、等等。

六. 下载安装GoReplay


顾名思义,GoReplay是基于go语言实现的,要在目标服务器上安装go环境。安装参考可见 :https://golang.org/doc/install,准备好go语言环境后,GoReplay直接提供了编译好的版本,十分方便,直接解压即可,可参考以下步骤:

#下载包
 wget https://github.com/buger/goreplay/releases/download/v1.0.0/gor_1.0.0_x64.tar.gz
 #解压
 tar xvf gor_1.0.0_x64.tar.gz

也可以进入到官网下载地址:https://github.com/buger/goreplay/releases下载最新的Gor二进制文件(支持Windows,Linux x64和Mac OS提供预编译的二进制文件),或者可以自行编译。

获取gor版本:

https://github.com/buger/goreplay/releases

源码地址:

https://github.com/buger/goreplay

官方使用文档:

https://github.com/buger/gor/wiki

微信图片_20220526114135.png

七. GoReplay 常用命令用法


输入参数:

  • --input-raw  用于捕获HTTP流量,需要指定IP地址或接口和应用程序端口。
  • --input-file   接收通过--output-file保存流量的文件
  • --input-tcp  将多个 Goreplay 实例获取的流量聚集到一个 Goreplay 实例。

输出参数:

  • --output-http  重放HTTP流量到给定的端点,接受基础URL。
  • --output-file  录制流量时指定的存储文件
  • --output-tcp 将获取的流量转移至另外的 Goreplay 实例,并与其一起使用--input-tcp
  • --output-stdout  用于调试,输出所有数据到stdout。

其它参数:

  • --http-allow-method 根据请求方式过滤。
  • --http-allow-url url白名单,其他请求将会被丢弃。
  • --http-disallow-url 遇上一个url相反,黑名单,其他的请求会被捕获到。

八. GoReplay 常用实践场景


1、流量实时复制引流(--input-raw 拦截端口配合--output-http输出),例如将本机80端口的HTTP流量实时复制到targer_server:8080。

gor --input-raw :80 --output-http "http://target_server:8080"

2、控制台输出,获取经过本地8080端口的请求流量,然后打印到控制台。

gor --input-raw :8080 --output-stdout

上述命令将监控8080端口上所有的流量,并通过终端stdout输出。你可以通过浏览器或者curl访问8080端口,然后在终端查看gor输出所有的http请求。

3、先录制后回放,将捕捉流量保存到文件中,然后释放到其它机器,有时候实时同步流量是很难做到的, 所以Goreplay提供了这种先保存后回放的模式:

第一步, 通过--output-file保存流量:

gor --input-raw :8080 --output-file=requests.gor

上述命令将8080端口的流量,保存到requests.gor文件中(必须是.gor后缀,其它后缀经测释放时有问题)。

第二步,回放保存的流量:

gor --input-file requests.gor --output-http="http://localhost:8081"

上述命令将释放所有保存在requests.gor中的请求通过相同的时间顺序释放到服务器[http://localhost:8081](http://localhost:8081

4、过滤指定请求方法,如果目标服务器使用的库与线上机器一样,且只需要引流Get方法的请求。

gor --input-raw :80  --http-allow-method GET --output-http "http://target_server:8080"

5、请求过滤,当你需要捕捉指定路径的请求流量时,可以使用该机制, 如只同步/api路径下的请求

gor --input-raw :8080 --output-http staging.com --http-allow-url /api

只收集请求头中符合 api-version 为 1.0x 的请求

gor --input-raw :8080 --output-http staging.com --http-allow-header api-version:^1\.0\d

6、限速机制,由于生产服务器配置一般远高于测试服务器配置,所以直接将生产服务器全部流量同步到测试服务器是不可行的,goreplay提供了两种策略:

a. 限制每秒的请求数

gor  --input-tcp :28020 --output-http "http://staging.com|10"# (每秒请求数限制10个以内)
gor  --input-raw :80 --output-tcp "replay.local:28020|10%"  # (每秒请求数限制10%以内)

b. 基于Header或Url的参数限制一些请求,为指定的header或者url的请求设定限制的百分比。

gor  --input-raw :80 --output-tcp "replay.local:28020|10%" --http-header-limiter "X-API-KEY: 10%"
gor  --input-raw :80 --output-tcp "replay.local:28020|10%" --http-param-limiter "api_key: 10%"

7、流量加压,当需要对线上服务进行整体性能压测时,可将线上请求扩大N倍,进行引流,将请求扩大1倍,也可缩小,调整"|"后面的百分比即可。

gor --input-raw :80  --http-allow-method GET --output-http "http://target_server:8080|200%"

8、只复制某个URL请求,--http-allow-url参数,-http-allow-url参数可用正则表达式(--output-http-url-regexp在gor 0.16已经过期,使用--http-allow-url代替)。

gor --input-raw :8080 --http-allow-method GET --output-http "http://target_server:8080" --http-allow-url mall.*hotword

9、多目标服务器的流量复制引流,有点类似nginx的mirror。

gor --input-raw :80 --output-http "http://target_server:8080" --output-http "http://target_server2:8080"

10、将流量转发到多个端点,默认情况下,它会将相同的流量发送到所有输出。

gor --input-tcp :28020 --output-http "http://staging.com"  --output-http "http://dev.com"

11、将相同的流量发送到多个站点,并且平分所有流量

gor --input-raw :80 --output-http "http://staging.com"  --output-http "http://dev.com" --split-output true

12、HTTP超时,默认情况下,http请求和响应的超时时间为5秒。你可以像这样覆盖它:

gor --input-tcp replay.local:28020 --output-http http://staging.com --output-http-timeout 30s

13、基本身份验证,如果您的开发或登台环境受基本身份验证保护,那么可以在重放期间注入这些凭据:

gor --input-raw :80 --output-http "http://user:pass@staging.com"

14、性能压力测试,可以将流量复制到文件,然后再对他们进行回放。回放的时候,流量会维持原始的时间间隔。如果你使用了百分比来进行速率限制,那么回放的速率会相应的增加或减少。有了这种速率限制,gor就可以用来进行压力测试。

gor --input-file "requests.gor|200%" --output-http "staging.com"

目前,input-file仅在使用基于百分比的限制器时才支持此功能。与默认限制器不同input-file,它不会降低请求速度,而会减慢速度或加速请求发射。

15 、录制与回放

./gor --input-raw :8000 --output-file=requests.gor

执行录制命令后,将会创建新文件并不断向其写入所有捕获的请求。

16、流量回放,重播来自文件的请求。

./gor --input-file requests.gor --output-http="http://localhost:8001"

您应该看到所有记录到http://localhost:8001的请求,并且它们将以相同的顺序重播,并且与录制的时间完全相同。

GoReplay更多用法可参考官方文档:https://github.com/buger/goreplay/wiki/Getting-Started


相关实践学习
通过日志服务实现云资源OSS的安全审计
本实验介绍如何通过日志服务实现云资源OSS的安全审计。
目录
相关文章
|
应用服务中间件 nginx
nginx优化:URI过长或request header过大导致400或414报错
当出现URI过长或请求头过大导致400或414报错时,可以通过以下方式对Nginx进行优化: 1. 调整client_max_body_size参数:该参数用于限制请求体的大小。默认情况下,Nginx的client_max_body_size参数设置为1M。如果请求体超过这个大小,Nginx会返回400错误。您可以根据实际需求适当增加这个值,例如设置为10M或更大。 ``` http { client_max_body_size 10M; } ``` 2. 调整large_client_header_buffers参数:该参数用于调整请求头缓冲区的大
7001 0
|
前端开发 网络协议 Dubbo
超详细Netty入门,看这篇就够了!
本文主要讲述Netty框架的一些特性以及重要组件,希望看完之后能对Netty框架有一个比较直观的感受,希望能帮助读者快速入门Netty,减少一些弯路。
91381 32
超详细Netty入门,看这篇就够了!
|
Java 数据安全/隐私保护 数据格式
Spring Cloud Gateway 网关整合 Knife4j 4.3 实现微服务接口文档聚合
Spring Cloud Gateway 网关整合 Knife4j 4.3 实现微服务接口文档聚合
|
Unix Linux Go
流量回放工具之 Goreplay 安装及初级使用
【6月更文挑战第2天】流量回放工具之 Goreplay 安装及初级使用
1192 3
|
消息中间件 存储 运维
从 Kafka 2.x 到 Kafka 3.x:升级之旅
从 Kafka 2.x 到 Kafka 3.x:升级之旅
2568 2
|
网络协议 安全
|
10月前
|
人工智能 API 数据库
Browser Use:开源 AI 浏览器助手,自动完成网页交互任务,支持多标签页管理、视觉识别和内容提取等功能
Browser Use 是一款专为大语言模型设计的智能浏览器工具,支持多标签页管理、视觉识别、内容提取等功能,并能记录和重复执行特定动作,适用于多种应用场景。
2659 0
Browser Use:开源 AI 浏览器助手,自动完成网页交互任务,支持多标签页管理、视觉识别和内容提取等功能
|
测试技术 Linux Go
|
监控 Dubbo Java
超详细的Sentinel入门
随着微服务的流行,服务和服务之间的稳定性变得越来越重要。Sentinel 以流量为切入点,从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。
超详细的Sentinel入门
|
存储 缓存 负载均衡
图解一致性哈希算法,看这一篇就够了!
近段时间一直在总结分布式系统架构常见的算法。前面我们介绍过布隆过滤器算法。接下来介绍一个非常重要、也非常实用的算法:一致性哈希算法。通过介绍一致性哈希算法的原理并给出了一种实现和实际运用的案例,带大家真正理解一致性哈希算法。
24663 64
图解一致性哈希算法,看这一篇就够了!