Java 测试 15：JMeter Java 自定义采样器（实现复杂业务逻辑）

Ne0inhk

— 26 min read
Java 测试 15：JMeter Java 自定义采样器（实现复杂业务逻辑）
在这里插入图片描述
👋 大家好，欢迎来到我的技术博客！
💻 作为一名热爱 Java 与软件开发的程序员，我始终相信：清晰的逻辑 + 持续的积累 = 稳健的成长。
📚 在这里，我会分享学习笔记、实战经验与技术思考，力求用简单的方式讲清楚复杂的问题。
🎯 本文将围绕一个常见的开发话题展开，希望能为你带来一些启发或实用的参考。
🌱 无论你是刚入门的新手，还是正在进阶的开发者，希望你都能有所收获！

Java 测试 15：JMeter Java 自定义采样器（实现复杂业务逻辑） 🚀

在性能测试的世界里，Apache JMeter 是一款广为人知且功能强大的开源工具。它能够模拟大量用户并发访问应用程序，从而帮助我们评估系统的性能和稳定性。虽然 JMeter 提供了丰富的内置采样器（如 HTTP 请求、FTP、JDBC 等），但在面对特定的、复杂的业务场景时，这些内置采样器可能无法满足需求。

这时，自定义 Java 采样器就显得尤为重要了。通过编写自己的 Java 代码来实现特定的业务逻辑，我们可以将任何复杂的操作封装成 JMeter 可以使用的采样器。这不仅极大地扩展了 JMeter 的能力，也让我们能够更精确地模拟真实世界的用户行为。

本篇文章将深入探讨如何在 JMeter 中开发和使用自定义的 Java 采样器，重点在于实现复杂的业务逻辑。我们将从基础概念讲起，逐步引导你完成一个完整的自定义采样器的创建、编译、部署以及在 JMeter 中的使用。我们还将讨论一些最佳实践和注意事项，帮助你构建稳定可靠的自定义采样器。

什么是 JMeter 自定义采样器？ 🤔

在 JMeter 中，采样器（Sampler）是执行实际“工作”的组件。它负责向目标系统发送请求并接收响应。内置的采样器（如 HTTP Request Sampler）已经能够处理大多数常见的请求类型。然而，当你的测试场景涉及到特定的协议、复杂的认证流程、或者需要执行一些特殊的业务逻辑时，就需要用到自定义采样器了。

自定义采样器本质上是一个实现了 org.apache.jorphan.interfaces.Sampler 接口或继承了 org.apache.jmeter.samplers.AbstractSampler 类的 Java 类。通过实现特定的方法，你可以控制采样器的行为，包括：

  • 执行逻辑：定义如何构造请求、发送请求、处理响应。
  • 参数配置：允许用户在 JMeter GUI 或脚本中设置参数。
  • 结果处理：决定如何记录和报告采样结果。

为什么需要自定义采样器？ 💡

1. 处理特殊协议或格式

有时，你的应用可能使用了 JMeter 内置采样器不支持的协议或数据格式。例如，一个基于 WebSocket 的实时通信系统，或者需要发送特定格式的二进制数据。

2. 实现复杂的业务逻辑

内置采样器通常只提供基本的请求/响应功能。如果你的应用需要先登录获取会话信息，然后进行一系列操作（如购物车管理、订单提交等），这些步骤之间的依赖关系和状态管理就难以仅靠内置采样器完成。自定义采样器可以将这些复杂的业务流程封装起来。

3. 集成外部服务或库

你的业务逻辑可能依赖于第三方库或内部自定义的服务。通过自定义采样器，可以直接调用这些库的功能，实现更贴近实际业务的测试场景。

4. 数据驱动与动态生成

某些测试场景需要根据前一次采样的结果动态生成下一次请求的数据。自定义采样器提供了最大的灵活性来实现这类动态行为。

5. 特定的错误处理和断言

内置采样器的错误处理机制可能不够精细。自定义采样器可以实现更细致的错误捕获、重试逻辑或特定的失败条件判断。

准备工作 🛠️

在开始编写自定义采样器之前，我们需要做一些准备工作。

1. 安装 JMeter

确保你已经安装了 Apache JMeter。可以从官网下载最新版本：https://jmeter.apache.org/download_jmeter.cgi。

2. 理解 JMeter 架构

了解 JMeter 的核心组件，特别是 Sampler、TestElement 和 SampleResult。这些是自定义采样器的基础。

3. 编程环境

你需要一个 Java 开发环境（如 IntelliJ IDEA、Eclipse）和一个构建工具（如 Maven 或 Gradle）来管理项目依赖和构建。

4. JMeter API 依赖

为了编写自定义采样器，你需要引入 JMeter 的核心库。如果你使用 Maven，可以在 pom.xml 文件中添加以下依赖：

<dependencies><!-- JMeter Core --><dependency><groupId>org.apache.jmeter</groupId><artifactId>ApacheJMeter_core</artifactId><version>5.6.3</version><!-- 使用你实际使用的 JMeter 版本 --><scope>provided</scope><!-- 注意 scope 为 provided，因为 JMeter 会提供这些类 --></dependency><!-- JMeter Components (如果需要使用其他组件，如 HTTP) --><!-- <dependency> <groupId>org.apache.jmeter</groupId> <artifactId>ApacheJMeter_http</artifactId> <version>5.6.3</version> <scope>provided</scope> </dependency> --><!-- 如果你的自定义采样器需要处理 XML 或 JSON --><!-- <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.15.2</version> </dependency> --></dependencies>

注意：<scope>provided</scope> 表示这些依赖在编译时需要，但打包时由 JMeter 运行时环境提供，避免打包冲突。

5. 项目结构

建议采用标准的 Maven 项目结构，例如：

my-jmeter-sampler/ ├── pom.xml └── src/ └── main/ └── java/ └── com/ └── example/ └── MyCustomSampler.java

实现一个简单的自定义采样器 🧱

让我们从一个非常简单的例子开始，实现一个计算两个数字相加结果的自定义采样器。这个例子虽然简单，但它展示了核心概念。

1. 创建采样器类

创建一个名为 MyCustomSampler.java 的文件。

packagecom.example;importorg.apache.jmeter.samplers.AbstractSampler;importorg.apache.jmeter.samplers.Entry;importorg.apache.jmeter.samplers.SampleResult;importorg.apache.jorphan.util.JMeterError;/** * 自定义采样器：执行两个数字的加法运算 */publicclassMyCustomSamplerextendsAbstractSampler{// 定义属性名称常量publicstaticfinalStringNUM1="num1";publicstaticfinalStringNUM2="num2";/** * 构造函数 */publicMyCustomSampler(){super();}/** * 生成采样结果 * @param e 当前采样上下文 * @return SampleResult 采样结果对象 */@OverridepublicSampleResultsample(Entry e){SampleResult res =newSampleResult();// 创建结果对象 res.setSampleLabel(getName());// 设置采样标签// 开始采样计时 res.sampleStart();try{// 获取用户输入的参数int num1 =Integer.parseInt(getPropertyAsString(NUM1));int num2 =Integer.parseInt(getPropertyAsString(NUM2));// 执行业务逻辑：计算加法int result = num1 + num2;// 设置结果信息 res.setSuccessful(true);// 标记为成功 res.setResponseCodeOK();// 设置响应码为 OK res.setResponseMessage("加法运算成功: "+ num1 +" + "+ num2 +" = "+ result); res.setDataType(SampleResult.TEXT);// 设置响应数据类型// 将结果作为响应数据返回 res.setResponseData(("计算结果: "+ result).getBytes());// 结束采样计时 res.sampleEnd();}catch(NumberFormatException ex){// 处理参数解析错误 res.setSuccessful(false); res.setResponseCode("400"); res.setResponseMessage("参数错误: "+ ex.getMessage()); res.setDataType(SampleResult.TEXT); res.setResponseData(("错误: 参数必须是整数").getBytes()); res.sampleEnd();// 在日志中记录错误 log.error("参数解析错误", ex);}catch(Exception ex){// 处理其他异常 res.setSuccessful(false); res.setResponseCode("500"); res.setResponseMessage("服务器内部错误: "+ ex.getMessage()); res.setDataType(SampleResult.TEXT); res.setResponseData(("错误详情: "+ ex.toString()).getBytes()); res.sampleEnd(); log.error("采样过程中发生未知错误", ex);}return res;// 返回采样结果}// Getter 和 Setter 方法（可选，用于在 GUI 中显示）publicvoidsetNum1(String value){setProperty(NUM1, value);}publicStringgetNum1(){returngetPropertyAsString(NUM1);}publicvoidsetNum2(String value){setProperty(NUM2, value);}publicStringgetNum2(){returngetPropertyAsString(NUM2);}}

2. 解释代码关键点

  • 继承 AbstractSampler：这是 JMeter 中采样器的标准基类。它提供了许多便利方法和默认实现。
  • 属性常量：NUM1 和 NUM2 是我们定义的属性名，用于在 JMeter GUI 中配置参数。
  • sample() 方法：这是采样器的核心方法。每当 JMeter 执行该采样器时，都会调用此方法。我们必须在此方法中实现具体的业务逻辑。
  • SampleResult 对象：用于封装采样过程的结果，包括是否成功、响应码、响应消息、响应数据等。
  • setProperty() 和 getPropertyAsString()：用于读取和设置采样器的配置属性。这些属性在 JMeter GUI 中可以通过界面上的字段进行修改。
  • 异常处理：良好的自定义采样器应该包含健壮的错误处理机制。我们捕获了 NumberFormatException（用于处理非数字输入）和其他通用异常。
  • 计时：使用 res.sampleStart() 和 res.sampleEnd() 来准确测量采样耗时。

3. 编译和打包

使用 Maven 编译项目：

mvn clean compile

生成 JAR 包：

mvn package

这将在 target/ 目录下生成一个名为 my-jmeter-sampler-1.0-SNAPSHOT.jar 的 JAR 文件。

4. 部署到 JMeter

将生成的 JAR 文件复制到 JMeter 的 lib/ext 目录下。

/path/to/jmeter/lib/ext/my-jmeter-sampler-1.0-SNAPSHOT.jar

重启 JMeter 应用程序，使其加载新的插件。

5. 在 JMeter 中使用

启动 JMeter，在测试计划中添加一个线程组。右键点击线程组 -> 添加 -> 采样器 -> Java 请求（或者在某些版本中是自定义采样器）。选择我们刚刚创建的 MyCustomSampler。

在弹出的对话框中，设置 num1 和 num2 的值，例如 10 和 20。运行测试计划，你应该能在结果树中看到采样器的输出。

实现一个更复杂的自定义采样器 - 模拟电商下单流程 🛒

现在让我们实现一个更复杂的例子：模拟一个电商网站的下单流程。这个流程包括：

  1. 登录用户。
  2. 查询商品详情。
  3. 将商品加入购物车。
  4. 提交订单。
  5. 确认订单支付状态。

这个例子将展示如何在采样器中处理多个步骤、依赖关系以及状态管理。

1. 设计思路

  • 模拟用户行为：我们需要一个采样器来代表一次完整的下单操作。
  • 状态管理：由于下单涉及多个步骤，我们需要在采样器内部管理用户的状态（如会话 ID、购物车信息）。
  • 模拟外部服务调用：我们假设有一个外部的 RESTful API 用于处理登录、商品查询、购物车和订单。在实际项目中，这将是真实的后端服务。
  • 模拟网络延迟：为了更接近真实情况，我们可以加入随机延迟。
  • 错误处理：模拟各种可能的错误情况，如用户未登录、库存不足等。

2. 创建模拟服务

首先，我们创建一个简单的模拟服务类，用于模拟外部 API 调用。这个类将包含模拟的登录、查询商品、添加购物车、提交订单等方法。

// file: src/main/java/com/example/SimulationService.javapackagecom.example;importjava.util.*;importjava.util.concurrent.ThreadLocalRandom;/** * 模拟外部服务调用 * 这个类用于模拟真实的后端 API，提供登录、商品查询、购物车管理、订单提交等功能 */publicclassSimulationService{// 模拟数据库存储用户信息privatestaticfinalMap<String,String>USERS=newHashMap<>();// 模拟数据库存储商品信息privatestaticfinalMap<String,Product>PRODUCTS=newHashMap<>();// 模拟用户的购物车privatestaticfinalMap<String,List<CartItem>>USER_CARTS=newHashMap<>();// 模拟订单 ID 到订单状态的映射privatestaticfinalMap<String,OrderStatus>ORDERS=newHashMap<>();static{// 初始化模拟数据USERS.put("testuser","password123");// 用户名 -> 密码USERS.put("admin","adminpass");PRODUCTS.put("P001",newProduct("P001","iPhone 15 Pro",9999.00,100));// 商品ID -> 商品信息PRODUCTS.put("P002",newProduct("P002","MacBook Air M2",12999.00,50));PRODUCTS.put("P003",newProduct("P003","iPad Pro",7999.00,200));// 初始化购物车为空USER_CARTS.put("testuser",newArrayList<>());USER_CARTS.put("admin",newArrayList<>());}/** * 模拟用户登录 * @param username 用户名 * @param password 密码 * @return 如果登录成功，返回会话 ID；否则返回 null */publicstaticStringlogin(String username,String password){System.out.println("模拟登录请求: 用户名="+ username +", 密码="+ password);// 模拟网络延迟simulateNetworkDelay(100,500);if(USERS.containsKey(username)&&USERS.get(username).equals(password)){// 生成一个模拟的 Session IDString sessionId ="session_"+UUID.randomUUID().toString().substring(0,8);System.out.println("模拟登录成功，会话 ID: "+ sessionId);return sessionId;}else{System.out.println("模拟登录失败，用户名或密码错误");returnnull;}}/** * 模拟查询商品详情 * @param productId 商品 ID * @param sessionId 会话 ID (用于验证用户权限) * @return 商品详情对象，如果查询失败则返回 null */publicstaticProductgetProductById(String productId,String sessionId){System.out.println("模拟查询商品详情: 商品ID="+ productId +", 会话ID="+ sessionId);// 模拟网络延迟simulateNetworkDelay(50,200);// 简单的会话验证 (实际项目中应更复杂)if(sessionId ==null|| sessionId.isEmpty()){System.out.println("模拟查询商品失败: 未提供有效的会话 ID");returnnull;}Product product =PRODUCTS.get(productId);if(product !=null){System.out.println("模拟查询商品成功: "+ product.getName());return product;}else{System.out.println("模拟查询商品失败: 商品不存在");returnnull;}}/** * 模拟将商品添加到购物车 * @param productId 商品 ID * @param quantity 数量 * @param sessionId 会话 ID * @return true 表示添加成功，false 表示失败 */publicstaticbooleanaddToCart(String productId,int quantity,String sessionId){System.out.println("模拟添加商品到购物车: 商品ID="+ productId +", 数量="+ quantity +", 会话ID="+ sessionId);// 模拟网络延迟simulateNetworkDelay(100,300);if(sessionId ==null|| sessionId.isEmpty()){System.out.println("模拟添加购物车失败: 未提供有效的会话 ID");returnfalse;}Product product =PRODUCTS.get(productId);if(product ==null){System.out.println("模拟添加购物车失败: 商品不存在");returnfalse;}if(quantity <=0){System.out.println("模拟添加购物车失败: 数量必须大于 0");returnfalse;}if(product.getStock()< quantity){System.out.println("模拟添加购物车失败: 库存不足");returnfalse;}// 检查用户购物车List<CartItem> cartItems =USER_CARTS.computeIfAbsent(sessionId, k ->newArrayList<>());CartItem existingItem = cartItems.stream().filter(item -> item.getProductId().equals(productId)).findFirst().orElse(null);if(existingItem !=null){// 更新已存在的商品数量 existingItem.setQuantity(existingItem.getQuantity()+ quantity);}else{// 添加新商品到购物车 cartItems.add(newCartItem(productId, quantity));}System.out.println("模拟添加购物车成功");returntrue;}/** * 模拟提交订单 * @param sessionId 会话 ID * @param shippingAddress 收货地址 * @return 订单 ID，如果失败则返回 null */publicstaticStringsubmitOrder(String sessionId,String shippingAddress){System.out.println("模拟提交订单: 会话ID="+ sessionId +", 地址="+ shippingAddress);// 模拟网络延迟simulateNetworkDelay(200,600);if(sessionId ==null|| sessionId.isEmpty()){System.out.println("模拟提交订单失败: 未提供有效的会话 ID");returnnull;}// 检查购物车是否有商品List<CartItem> cartItems =USER_CARTS.get(sessionId);if(cartItems ==null|| cartItems.isEmpty()){System.out.println("模拟提交订单失败: 购物车为空");returnnull;}// 检查库存并扣减for(CartItem item : cartItems){Product product =PRODUCTS.get(item.getProductId());if(product ==null|| product.getStock()< item.getQuantity()){System.out.println("模拟提交订单失败: 商品 "+ item.getProductId()+" 库存不足");returnnull;}// 扣减库存 product.setStock(product.getStock()- item.getQuantity());}// 生成订单 IDString orderId ="ORDER_"+UUID.randomUUID().toString().substring(0,8);// 记录订单状态为待支付ORDERS.put(orderId,OrderStatus.PENDING_PAYMENT);// 清空购物车USER_CARTS.put(sessionId,newArrayList<>());System.out.println("模拟提交订单成功，订单 ID: "+ orderId);return orderId;}/** * 模拟确认订单支付状态 * @param orderId 订单 ID * @param paymentStatus 支付状态 * @return true 表示更新成功，false 表示失败 */publicstaticbooleanconfirmPayment(String orderId,String paymentStatus){System.out.println("模拟确认订单支付状态: 订单ID="+ orderId +", 状态="+ paymentStatus);// 模拟网络延迟simulateNetworkDelay(100,200);if(orderId ==null|| orderId.isEmpty()){System.out.println("模拟确认支付失败: 无效的订单 ID");returnfalse;}OrderStatus status =OrderStatus.fromString(paymentStatus);if(status ==null){System.out.println("模拟确认支付失败: 无效的支付状态");returnfalse;}// 更新订单状态if(ORDERS.containsKey(orderId)){ORDERS.put(orderId, status);System.out.println("模拟确认支付成功，订单状态更新为: "+ status);returntrue;}else{System.out.println("模拟确认支付失败: 订单不存在");returnfalse;}}/** * 模拟网络延迟 * @param min 最小延迟毫秒数 * @param max 最大延迟毫秒数 */privatestaticvoidsimulateNetworkDelay(int min,int max){try{int delay =ThreadLocalRandom.current().nextInt(min, max +1);Thread.sleep(delay);}catch(InterruptedException e){Thread.currentThread().interrupt();// 重新设置中断状态}}// 用于存储商品信息的内部类publicstaticclassProduct{privatefinalString id;privatefinalString name;privatefinaldouble price;privateint stock;publicProduct(String id,String name,double price,int stock){this.id = id;this.name = name;this.price = price;this.stock = stock;}// GetterspublicStringgetId(){return id;}publicStringgetName(){return name;}publicdoublegetPrice(){return price;}publicintgetStock(){return stock;}publicvoidsetStock(int stock){this.stock = stock;}}// 用于存储购物车项的内部类publicstaticclassCartItem{privatefinalString productId;privateint quantity;publicCartItem(String productId,int quantity){this.productId = productId;this.quantity = quantity;}// Getters and SetterspublicStringgetProductId(){return productId;}publicintgetQuantity(){return quantity;}publicvoidsetQuantity(int quantity){this.quantity = quantity;}}// 订单状态枚举publicenumOrderStatus{PENDING_PAYMENT("待支付"),PAID("已支付"),SHIPPED("已发货"),DELIVERED("已完成");privatefinalString description;OrderStatus(String description){this.description = description;}publicstaticOrderStatusfromString(String status){for(OrderStatus s :values()){if(s.name().equalsIgnoreCase(status)){return s;}}returnnull;}@OverridepublicStringtoString(){return description;}}}

3. 创建复杂的自定义采样器

现在，我们创建一个名为 ECommerceOrderSampler.java 的类，它将实现上述的电商下单流程。

// file: src/main/java/com/example/ECommerceOrderSampler.javapackagecom.example;importorg.apache.jmeter.config.Arguments;importorg.apache.jmeter.samplers.AbstractSampler;importorg.apache.jmeter.samplers.Entry;importorg.apache.jmeter.samplers.SampleResult;importorg.apache.jorphan.util.JMeterError;importjava.util.UUID;/** * 自定义采样器：模拟电商下单流程 * 包括登录、查询商品、添加购物车、提交订单和确认支付 */publicclassECommerceOrderSamplerextendsAbstractSampler{// 定义属性名称常量publicstaticfinalStringUSERNAME="username";publicstaticfinalStringPASSWORD="password";publicstaticfinalStringPRODUCT_ID="productId";publicstaticfinalStringQUANTITY="quantity";publicstaticfinalStringSHIPPING_ADDRESS="shippingAddress";// 用于存储会话 ID 和订单 ID 的实例变量 (在实际应用中，可能需要考虑线程安全和共享状态)privateString currentSessionId =null;privateString currentOrderId =null;/** * 构造函数 */publicECommerceOrderSampler(){super();}/** * 生成采样结果 * @param e 当前采样上下文 * @return SampleResult 采样结果对象 */@OverridepublicSampleResultsample(Entry e){SampleResult res =newSampleResult(); res.setSampleLabel(getName()); res.sampleStart();// 开始采样计时try{// 获取用户输入的参数String username =getPropertyAsString(USERNAME);String password =getPropertyAsString(PASSWORD);String productId =getPropertyAsString(PRODUCT_ID);String quantityStr =getPropertyAsString(QUANTITY);String shippingAddress =getPropertyAsString(SHIPPING_ADDRESS);// 参数验证if(username ==null|| username.isEmpty()){thrownewIllegalArgumentException("用户名不能为空");}if(password ==null|| password.isEmpty()){thrownewIllegalArgumentException("密码不能为空");}if(productId ==null|| productId.isEmpty()){thrownewIllegalArgumentException("商品 ID 不能为空");}if(quantityStr ==null|| quantityStr.isEmpty()){thrownewIllegalArgumentException("数量不能为空");}int quantity;try{ quantity =Integer.parseInt(quantityStr);}catch(NumberFormatException ex){thrownewIllegalArgumentException("数量必须是整数: "+ quantityStr);}if(quantity <=0){thrownewIllegalArgumentException("数量必须大于 0");}if(shippingAddress ==null|| shippingAddress.isEmpty()){thrownewIllegalArgumentException("收货地址不能为空");}// 步骤 1: 用户登录 res.addSubResult(createSubResult("登录","开始登录..."));String sessionId =SimulationService.login(username, password);if(sessionId ==null){ res.setSuccessful(false); res.setResponseCode("401"); res.setResponseMessage("登录失败，请检查用户名和密码"); res.setResponseData("登录失败".getBytes()); res.sampleEnd();return res;} currentSessionId = sessionId;// 保存会话 ID res.addSubResult(createSubResult("登录","登录成功，会话 ID: "+ sessionId));// 步骤 2: 查询商品详情 res.addSubResult(createSubResult("查询商品","开始查询商品详情..."));SimulationService.Product product =SimulationService.getProductById(productId, sessionId);if(product ==null){ res.setSuccessful(false); res.setResponseCode("404"); res.setResponseMessage("查询商品失败，商品不存在或无权访问"); res.setResponseData("查询商品失败".getBytes()); res.sampleEnd();return res;} res.addSubResult(createSubResult("查询商品","商品查询成功: "+ product.getName()+" (价格: ¥"+ product.getPrice()+")"));// 步骤 3: 添加商品到购物车 res.addSubResult(createSubResult("添加购物车","开始添加商品到购物车..."));boolean addedToCart =SimulationService.addToCart(productId, quantity, sessionId);if(!addedToCart){ res.setSuccessful(false); res.setResponseCode("400"); res.setResponseMessage("添加购物车失败"); res.setResponseData("添加购物车失败".getBytes()); res.sampleEnd();return res;} res.addSubResult(createSubResult("添加购物车","商品已成功添加到购物车"));// 步骤 4: 提交订单 res.addSubResult(createSubResult("提交订单","开始提交订单..."));String orderId =SimulationService.submitOrder(sessionId, shippingAddress);if(orderId ==null){ res.setSuccessful(false); res.setResponseCode("400"); res.setResponseMessage("提交订单失败"); res.setResponseData("提交订单失败".getBytes()); res.sampleEnd();return res;} currentOrderId = orderId;// 保存订单 ID res.addSubResult(createSubResult("提交订单","订单提交成功，订单 ID: "+ orderId));// 步骤 5: 确认支付状态 (模拟支付成功) res.addSubResult(createSubResult("确认支付","模拟支付成功，确认订单状态..."));boolean confirmed =SimulationService.confirmPayment(orderId,"PAID");if(!confirmed){ res.setSuccessful(false); res.setResponseCode("500"); res.setResponseMessage("确认支付失败"); res.setResponseData("确认支付失败".getBytes()); res.sampleEnd();return res;} res.addSubResult(createSubResult("确认支付","订单状态已更新为已支付"));// 所有步骤都成功 res.setSuccessful(true); res.setResponseCodeOK(); res.setResponseMessage("电商下单流程成功完成"); res.setDataType(SampleResult.TEXT); res.setResponseData(("订单号: "+ orderId +" | 用户: "+ username +" | 商品: "+ product.getName()+" | 数量: "+ quantity).getBytes()); res.sampleEnd();}catch(IllegalArgumentException ex){// 处理参数验证错误 res.setSuccessful(false); res.setResponseCode("400"); res.setResponseMessage("参数错误: "+ ex.getMessage()); res.setDataType(SampleResult.TEXT); res.setResponseData(("错误: "+ ex.getMessage()).getBytes()); res.sampleEnd(); log.error("参数错误", ex);}catch(Exception ex){// 处理其他异常 res.setSuccessful(false); res.setResponseCode("500"); res.setResponseMessage("服务器内部错误: "+ ex.getMessage()); res.setDataType(SampleResult.TEXT); res.setResponseData(("错误详情: "+ ex.toString()).getBytes()); res.sampleEnd(); log.error("采样过程中发生未知错误", ex);}return res;}/** * 创建子采样结果，用于在主结果中展示详细的步骤信息 * @param stepName 步骤名称 * @param message 步骤消息 * @return SampleResult 子结果 */privateSampleResultcreateSubResult(String stepName,String message){SampleResult subRes =newSampleResult(); subRes.setSampleLabel(stepName); subRes.sampleStart(); subRes.setSuccessful(true); subRes.setResponseCodeOK(); subRes.setResponseMessage(message); subRes.setDataType(SampleResult.TEXT); subRes.setResponseData(message.getBytes()); subRes.sampleEnd();return subRes;}// Getter 和 Setter 方法（可选）publicvoidsetUsername(String value){setProperty(USERNAME, value);}publicStringgetUsername(){returngetPropertyAsString(USERNAME);}publicvoidsetPassword(String value){setProperty(PASSWORD, value);}publicStringgetPassword(){returngetPropertyAsString(PASSWORD);}publicvoidsetProductId(String value){setProperty(PRODUCT_ID, value);}publicStringgetProductId(){returngetPropertyAsString(PRODUCT_ID);}publicvoidsetQuantity(String value){setProperty(QUANTITY, value);}publicStringgetQuantity(){returngetPropertyAsString(QUANTITY);}publicvoidsetShippingAddress(String value){setProperty(SHIPPING_ADDRESS, value);}publicStringgetShippingAddress(){returngetPropertyAsString(SHIPPING_ADDRESS);}/** * 获取采样器的参数列表，用于在 JMeter GUI 中显示 * @return Arguments 参数列表 */@OverridepublicArgumentsgetArgumentPrototypes(){Arguments args =newArguments(); args.addArgument(USERNAME,"testuser"); args.addArgument(PASSWORD,"password123"); args.addArgument(PRODUCT_ID,"P001"); args.addArgument(QUANTITY,"1"); args.addArgument(SHIPPING_ADDRESS,"北京市朝阳区某某街道123号");return args;}}

4. 解释代码关键点

  • 状态管理：在这个简单的示例中，我们使用了实例变量 currentSessionId 和 currentOrderId 来跟踪当前采样器执行过程中的状态。在实际应用中，如果多个线程同时运行，这种做法可能会导致问题。更好的方式是使用线程本地变量（ThreadLocal）或者将状态存储在 SampleResult 中。
  • 步骤化执行：我们将整个下单流程分解为五个清晰的步骤，并为每个步骤创建了子采样结果（createSubResult），这样在 JMeter 的结果树视图中可以看到每个步骤的详细信息。
  • 模拟服务调用：我们调用了 SimulationService 类中的方法来模拟外部 API 调用。这些方法包含了模拟的延迟、参数校验、数据操作等。
  • 详细的错误处理：对每一步都进行了参数验证和错误检查，并设置了相应的响应码和消息。
  • getArgumentPrototypes() 方法：这是一个可选但非常有用的重写方法。它定义了采样器在 JMeter GUI 中显示的默认参数值，方便用户快速开始测试。

5. 编译和打包

再次运行 Maven 命令来编译和打包：

mvn clean compile package

6. 部署和使用

将生成的 JAR 文件复制到 JMeter 的 lib/ext 目录下，并重启 JMeter。

在 JMeter 中添加一个新的线程组。右键点击 -> 添加 -> 采样器 -> Java 请求（或自定义采样器），选择 ECommerceOrderSampler。

在配置界面中，你可以修改以下参数：

  • Username: 用户名，默认为 testuser。
  • Password: 密码，默认为 password123。
  • Product ID: 商品 ID，默认为 P001。
  • Quantity: 购买数量，默认为 1。
  • Shipping Address: 收货地址，默认为 北京市朝阳区某某街道123号。

运行测试计划，观察结果树中的详细步骤和最终的响应数据。

使用 JMeter 的高级特性增强自定义采样器 🌟

除了基本的实现，我们还可以利用 JMeter 提供的一些高级特性来进一步增强我们的自定义采样器。

1. 支持 JMeter 属性和变量

JMeter 允许在测试计划中使用变量（Variables）和属性（Properties）。自定义采样器可以读取这些值，使其更加灵活。

// 在 ECommerceOrderSampler.java 中添加// ...// 在 sample 方法中String username =getPropertyAsString(USERNAME);// 替换为读取 JMeter 变量String username =getVariableValue(USERNAME);// 读取变量if(username ==null|| username.isEmpty()){// 如果变量不存在，则使用属性值或默认值 username =getPropertyAsString(USERNAME);}// ...// 读取变量的辅助方法privateStringgetVariableValue(String variableName){// 注意：这里简化了获取变量的逻辑。实际中，你可能需要访问 JMeter 的变量管理器。// 更复杂的方式是通过 JMeterContextService 或者使用 JMeter 的上下文。// 这里只是一个示例，实际应用中可能需要更复杂的处理。returnnull;// 简化示例}

2. 实现更复杂的断言

虽然 JMeter 的断言（Assertion）是独立于采样器的，但你可以在自定义采样器中实现类似的功能。例如，检查响应数据是否符合预期。

// 在 sample 方法中，检查订单信息// ...// 假设我们希望订单金额等于商品价格乘以数量double expectedAmount = product.getPrice()* quantity;// 假设响应数据中包含了金额信息String responseData =newString(res.getResponseData(),StandardCharsets.UTF_8);if(!responseData.contains("订单号: "+ orderId)){ res.setSuccessful(false); res.setResponseMessage("响应数据不符合预期"); res.setResponseCode("400");}// ...

3. 使用 JMeter 的配置元件

你可以让自定义采样器依赖于 JMeter 的配置元件（Config Element），比如全局的 HTTP 请求头或认证信息。这需要在采样器中显式地获取这些配置。

4. 性能优化和资源管理

对于长时间运行的自定义采样器，需要注意：

  • 内存管理：避免在采样器内部创建大量的临时对象。
  • 线程安全：确保你的采样器在多线程环境下是安全的。
  • 连接池：如果采样器需要频繁连接外部服务，考虑使用连接池。

最佳实践与注意事项 📝

开发高质量的自定义 JMeter 采样器需要遵循一些最佳实践：

1. 保持简单和专注

自定义采样器应该专注于单一职责。如果一个采样器需要处理太多不同的业务逻辑，考虑将其拆分为多个更小的采样器。

2. 异常处理至关重要

JMeter 本身不会捕获所有异常。确保你的采样器能够优雅地处理各种异常情况，并提供有意义的错误信息。

3. 日志记录

使用 JMeter 提供的日志记录机制 (log) 来记录关键事件和调试信息。这对于排查问题非常有用。

4. 参数验证

始终验证输入参数的有效性。不合理的参数可能导致采样器崩溃或产生不可预测的行为。

5. 使用 SampleResult 的完整功能

充分利用 SampleResult 对象提供的所有功能，如 setStartTime(), setEndTime(), addSubResult() 等，以便更好地分析测试结果。

6. 文档和注释

为你的自定义采样器添加清晰的文档和注释，说明其用途、参数含义和预期行为。

7. 版本兼容性

确保你的自定义采样器与所使用的 JMeter 版本兼容。API 可能会随着版本变化而调整。

8. 测试自定义采样器

像测试任何其他代码一样，测试你的自定义采样器。确保它在各种条件下都能正确工作。

总结 🎯

通过本文的学习，我们深入了解了如何在 JMeter 中创建和使用自定义 Java 采样器。从一个简单的加法计算器到一个复杂的电商下单流程模拟，我们展示了如何利用 Java 的强大功能来扩展 JMeter 的测试能力。

自定义采样器为我们提供了前所未有的灵活性，使得我们可以精确地模拟各种复杂的业务场景。无论是处理特殊的协议、集成外部服务、还是实现复杂的业务逻辑，自定义采样器都是不可或缺的工具。

记住，构建高质量的自定义采样器需要良好的编程习惯、清晰的设计思路和对 JMeter 架构的深入理解。不断实践和优化，你将能够创造出满足各种复杂测试需求的强大工具。

附录：相关链接 📚

希望这篇博客对你理解和实践 JMeter 自定义采样器有所帮助！🚀

🙌 感谢你读到这里！
🔍 技术之路没有捷径，但每一次阅读、思考和实践，都在悄悄拉近你与目标的距离。
💡 如果本文对你有帮助，不妨 👍 点赞、📌 收藏、📤 分享 给更多需要的朋友！
💬 欢迎在评论区留下你的想法、疑问或建议，我会一一回复，我们一起交流、共同成长 🌿
🔔 关注我，不错过下一篇干货！我们下期再见！✨

Read more

开发兜不住？让数据库来兜底：金仓 SQL 防火墙的工程化实践

开发兜不住？让数据库来兜底：金仓 SQL 防火墙的工程化实践

开发兜不住？让数据库来兜底：金仓 SQL 防火墙的工程化实践 在真实的生产环境中，数据库安全从来不是“写完代码就结束”的问题，而是一个贯穿系统生命周期的持续对抗过程。哪怕你已经严格执行参数化查询、ORM 框架封装、输入校验等规范，仍然无法保证系统绝对无注入风险——遗留系统、动态 SQL、第三方组件、甚至临时脚本，都会成为潜在突破口。 这也是为什么越来越多企业开始将防线下沉到数据库层：既然应用层不可控，那就让数据库成为最后一道“强制执行的安全边界”。 本文结合 KingbaseES 的 SQL 防火墙机制，从原理、模式设计到性能表现，讲清楚它是如何在工程上解决 SQL 注入问题的。 一、SQL 注入的本质：语义劫持，而不是“字符串拼接问题” 很多人对 SQL 注入的理解还停留在“拼接字符串不安全”，但从数据库视角来看，本质其实是： 攻击者篡改了 SQL 的语义结构（

By Ne0inhk

Go语言的主流框架和解决超高并发的三高微服务框架对比分析

在Go语言生态中，主流的Web框架和应对“三高”（高并发、高可用、高可扩展）场景的微服务框架，经过多年的发展已经非常清晰。简单来说，Gin 是目前应用最广泛的通用Web框架，而像 go-zero、Kratos、KiteX 等则是专为“三高”微服务架构设计的“全家桶”式解决方案。 下面为你详细拆解这两大类框架。 一、主流通用Web框架：轻量、灵活、高性能 这类框架主要解决API构建、路由和中间件管理等Web层问题，是构建单体应用或微服务API层的良好基础。 Gin：目前的“默认选项”，性能高、社区庞大、中间件丰富，极易上手。如果你刚开始接触Go或项目需求明确，选择Gin会非常稳妥。 Fiber：受Express.js启发，语法对Node.js开发者很友好。它基于fasthttp构建，在性能基准测试中表现极为出色。适合追求极致性能、且不介意与标准库net/http不完全兼容的场景。 Echo：一个成熟且平衡的框架，

By Ne0inhk
必收藏！小白也能懂：Agent、Skills、MCP和A2A大模型架构完全指南

必收藏！小白也能懂：Agent、Skills、MCP和A2A大模型架构完全指南

文章详解AI Agent四大核心概念：Agent作为智能决策主体，Skills提供原子化能力封装，MCP实现标准化工具调用，A2A支持Agent间协作。这些技术共同构建了从单Agent自主执行到多Agent协同工作的完整技术栈，解决了智能体的自主性、模块化能力、工具调用和互操作等核心问题，助力开发者快速构建专业级AI应用。 一、Agent、Skills、MCP和A2A的核心概念总览 1、Agent (代理/智能体)：自主决策与执行的“大脑”。 AI Agent是2026年AI生态的核心概念，是基于人工智能技术构建的、具备感知环境、理解信息、自主推理决策、自主规划与执行动作并持续与环境/其他主体交互，以自主达成预设或动态生成目标的数字智能实体。2026年的智能体不是在回答问题，而是在完成任务。其突破了传统问答式、生成式AI的能力边界，可像人类员工一样独立处理复杂综合性任务。它以大模型为核心引擎，整合规划、记忆、工具调用与行动执行四大能力，形成「感知 - 认知 - 决策 - 执行 - 反馈」的完整智能闭环，

By Ne0inhk
超越Tomcat的Spike （一）：使用netty搭建Http服务器

超越Tomcat的Spike （一）：使用netty搭建Http服务器

超越Tomcat的Spike （一）：使用netty搭建Http服务器 * 🏆 引言 * 🚀 Netty的魅力所在 * 什么是Netty？ * Netty vs 传统服务器 * 🏗️ Spike项目架构设计 * 项目结构 * 核心组件架构 * 💻 核心代码实现 * 服务器初始化与启动 * 请求处理逻辑 * ⚡ 性能测试与对比 * 并发处理能力测试 * 内存占用对比 * 📱 应用案例 * 案例一：高并发API网关 * 案例二：实时数据推送服务 * 🎯 核心优势分析 * 1. 非阻塞异步模型 * 2. 零拷贝技术 * 3. 可扩展性强 * 🔮 未来展望 * Spike 2.0 规划 * 应用场景扩展 * 📝 代码优化建议 * 1. 事件循环组优化 * 2. 内存管理优化 * 🏁 总结 🏆 引言 在现代Web应用开发中，HTTP服务器是构建任何网络服务的基础。传统的Tomcat、Jetty等服务器虽然功能强大，但在高性能场景下往往显得力不从

By Ne0inhk