一、创建一个java工程

• 1、新建一个java Project

 File->new->Java Project

•  2、在Eclipse下导入$\jmeter\lib\ext\下的所有jar包；

导入额外的5个jar包，在 $\jmeter\lib\ 下

还有被测的接口的jar包也要导入

• 创建class，将新建的类extends AbstractJavaSamplerClient 类

   继承"getDefaultParameters","setupTest","runTest"和"teardownTest"四个方法：

public Arguments getDefaultParameters();设置可用参数及的默认值；

public void setupTest(JavaSamplerContext arg0)：每个线程测试前执行一次，做一些初始化工作；

public SampleResult runTest(JavaSamplerContext arg0)：开始测试，从arg0参数可以获得参数值；

public void teardownTest(JavaSamplerContext arg0)：测试结束时调用；

private String getResponseData(ApplyResult rs)：将返回进行json格式化

二、继承类AbstractJavaSamplerClient（代码示例为接口getApplyProcess）

• 1、getDefaultParameters: 获取默认参数以及参数值

（这里只有一个参数 certi_code，接口getApplyProcess 只有一个入参，如果多个入参，应全部都添加上）

• 2、setupTest： 测试方法运行之前的工作（初始化记录结果；从参数列表中获取对应变）

    （如果是有多个入参，也应都添加）

• 3、runTest：运行测试方法（初始化记录结果，设定开始/结束记录时间，测试调用Service的主方法，测试成功与否的判断方法）

(1)配置获取：（setUrl提供的url，所在的系统地址而定；setInterface是接口的 实现类名）

(2)请求、返回记录：（setSamplerData为请求数据，getResponseData为返回数据）

• 4、teardownTest 固定写法

• 5、返回进行json的格式化

三、导出jar

• 右键点击项目：Export… 直接导出为 jar包就可以

• export后的jar包放在$/jmeter/lib/ext/下（$/jmeter为jmeter的安装路径）

四、运行java请求

1、在$\jmeter\bin\下执行jmeter.bat

2、右键点击“测试计划”添加一个Thread Group（线程组）

3、右键点击线程组，添加一个Java Request费用状态查询

五、接口getApplyProcess示例java文件

 java文件放在了“文件”页签

备注：JsonFormatTool.java为json格式转换代码

package salesLoad;

import org.apache.jmeter.config.Arguments;
import org.apache.jmeter.protocol.java.sampler.AbstractJavaSamplerClient;
import org.apache.jmeter.protocol.java.sampler.JavaSamplerContext;
import org.apache.jmeter.samplers.SampleResult;

import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ReferenceConfig;
import com.alibaba.dubbo.config.utils.ReferenceConfigCache;
import com.google.gson.Gson;
import com.ulic.agent.ws.enter.FreshManEnterInterface;
import com.ulic.agent.ws.enter.model.ApplyResult;
import com.ulic.im.client.vo.AppInfo;


public class GetApplyProcess extends AbstractJavaSamplerClient{

    
    private FreshManEnterInterface enterService;
    private ReferenceConfig<FreshManEnterInterface> reference;
    private ReferenceConfigCache cache;
    
    private String certiCode;
    
    // 这个方法是用来自定义java方法入参的。  
    // params.addArgument("num1","");表示入参名字叫num1，默认值为空。  
    public Arguments getDefaultParameters() {
        Arguments params = new Arguments();
        params.addArgument("certi_code", "");
        return params;
    }
    
    //每个线程测试前执行一次，做一些初始化工作；  
    public void setupTest(JavaSamplerContext arg0) {
        certiCode = arg0.getParameter("certi_code");
    }

    @Override
    public SampleResult runTest(JavaSamplerContext arg0) {
        setupTest(arg0);
        reference = new ReferenceConfig<FreshManEnterInterface>();
        reference.setApplication(new ApplicationConfig("letmetest"));
        reference.setTimeout(300000);
        reference.setUrl("dubbo://10.10.1.11:20881");
        reference.setInterface("com.mims.agent.ws.enter.FreshManEnterInterface");
        cache = ReferenceConfigCache.getCache();
        enterService = cache.get(reference);
        
        AppInfo app = new AppInfo();
        app.setAppCode("MAP");
        app.setAppIP("10.51.4.9");
        ApplyResult rs = null;
        
        SampleResult sr = new SampleResult(); 
        try {  
            sr.sampleStart();
            sr.setSamplerData("请求参数certi_code："+certiCode);
            rs = enterService.getApplyProcess(app, certiCode);
            
            sr.setResponseData(getResponseData(rs), null);
            sr.setDataType(SampleResult.TEXT);
            sr.setResponseCode("0000");
            
            Thread.sleep(10);
            sr.setSuccessful(true);
        }catch(Exception e){
            e.printStackTrace();
            sr.setResponseCode("0001");
            sr.setSuccessful(false);
        }finally{
            sr.sampleEnd();
        }
        return sr;
    }
    
    private String getResponseData(ApplyResult rs) {
        Gson gson = new Gson();
        String s = gson.toJson(rs, ApplyResult.class);
        JsonFormatTool jft = new JsonFormatTool();        
        return jft.formatJson(s);
    }
    
    public void teardownTest(JavaSamplerContext arg0){  
        super.teardownTest(arg0);  
    }
}

  1 package com.ulic.loadtest.esales;
  2 
  3 import java.math.BigDecimal;
  4 
  5 import org.apache.jmeter.config.Arguments;
  6 import org.apache.jmeter.protocol.java.sampler.AbstractJavaSamplerClient;
  7 import org.apache.jmeter.protocol.java.sampler.JavaSamplerContext;
  8 import org.apache.jmeter.samplers.SampleResult;
  9 
 10 import com.alibaba.dubbo.config.ApplicationConfig;
 11 import com.alibaba.dubbo.config.ReferenceConfig;
 12 import com.alibaba.dubbo.config.utils.ReferenceConfigCache;
 13 import com.ulic.esales.ws.EsalesServiceInterface;
 14 import com.ulic.esales.ws.vo.AoPolicyProductVO;
 15 import com.ulic.im.client.vo.AppInfo;
 16 import com.ulic.loadtest.util.JsonFormatTool;
 17 
 18 public class CheckAoProductRule extends AbstractJavaSamplerClient {
 19     
 20     private EsalesServiceInterface esalesService;
 21     private ReferenceConfig<EsalesServiceInterface> reference;
 22     private ReferenceConfigCache cache;
 23     
 24     private AoPolicyProductVO vo;
 25     
 26     // 这个方法是用来自定义java方法入参的。  
 27     // params.addArgument("num1","");表示入参名字叫num1，默认值为空。  
 28     public Arguments getDefaultParameters() {
 29         Arguments params = new Arguments();
 30         params.addArgument("item_id", "0");
 31         params.addArgument("policy_id", "0");
 32         params.addArgument("product_id", "0");
 33         params.addArgument("product_num", "");
 34         params.addArgument("master_id", "0");
 35         params.addArgument("main_rider", "");
 36         params.addArgument("amount", "0");
 37         params.addArgument("period_prem", "0");
 38         params.addArgument("unit", "0");
 39         params.addArgument("relation_1", "0");
 40         params.addArgument("insurant_1", "0");
 41         params.addArgument("age_1", "0");
 42         params.addArgument("bonus_choice", "0");
 43         params.addArgument("charge_period", "");
 44         params.addArgument("charge_year", "0");
 45         params.addArgument("coverage_period", "");
 46         params.addArgument("coverage_year", "0");
 47         params.addArgument("pay_year", "0");
 48         params.addArgument("insert_id", "0");
 49         return params;
 50     }
 51 
 52     @Override
 53     public SampleResult runTest(JavaSamplerContext arg0) {
 54         vo = new AoPolicyProductVO();
 55         vo.setItemId(Long.parseLong(arg0.getParameter("item_id")));
 56         vo.setPolicyId(Long.parseLong(arg0.getParameter("policy_id")));
 57         vo.setProductId(Long.parseLong(arg0.getParameter("product_id")));
 58         vo.setProductNum(arg0.getParameter("product_num"));
 59         vo.setMasterId(Long.parseLong(arg0.getParameter("master_id")));
 60         vo.setMainRider(arg0.getParameter("main_rider"));
 61         vo.setAmount(new BigDecimal(Float.parseFloat(arg0.getParameter("amount"))));
 62         vo.setPeriodPrem(new BigDecimal(Float.parseFloat(arg0.getParameter("period_prem"))));
 63         vo.setUnit(new BigDecimal(arg0.getParameter("unit")));
 64         vo.setRelation1(Long.parseLong(arg0.getParameter("relation_1")));
 65         vo.setInsurant1(Long.parseLong(arg0.getParameter("insurant_1")));
 66         vo.setAge1(Long.parseLong(arg0.getParameter("age_1")));
 67         vo.setBonusChoice(Long.parseLong(arg0.getParameter("bonus_choice")));
 68         vo.setChargePeriod(arg0.getParameter("charge_period"));
 69         vo.setChargeYear(Long.parseLong(arg0.getParameter("charge_year")));
 70         vo.setCoveragePeriod(arg0.getParameter("coverage_period"));
 71         vo.setCoverageYear(Long.parseLong(arg0.getParameter("coverage_year")));
 72         vo.setPayYear(Long.parseLong(arg0.getParameter("pay_year")));
 73         vo.setInsertId(Long.parseLong(arg0.getParameter("insert_id")));
 74         
 75         reference = new ReferenceConfig<EsalesServiceInterface>();
 76         reference.setApplication(new ApplicationConfig("letmetest"));
 77         reference.setTimeout(300000);
 78         reference.setUrl("dubbo://10.181.3.16:21889");
 79         //reference.setRegistry(registry);
 80         reference.setInterface("com.ulic.esales.ws.EsalesServiceInterface");
 81         cache = ReferenceConfigCache.getCache();
 82         esalesService = cache.get(reference);
 83         //moaQueryService = reference.get();
 84         
 85         AppInfo app = new AppInfo();
 86         app.setAppCode("ESALES");
 87         app.setAppIP("10.51.40.4");
 88         String rs = null;
 89         
 90         SampleResult sr = new SampleResult(); 
 91         try {  
 92             sr.sampleStart();
 93             
 94             rs = esalesService.checkAoProductRule(app, vo);
 95             
 96             sr.setResponseData(getResponseData(rs), null);
 97             sr.setDataType(SampleResult.TEXT);
 98             sr.setResponseCode("0000");
 99             
100             Thread.sleep(10);
101             sr.setSuccessful(true);
102         }catch(Exception e){
103             e.printStackTrace();
104             sr.setResponseCode("0001");
105             sr.setSuccessful(false);
106         }finally{
107             sr.sampleEnd();
108         }
109         return sr;
110     }
111     
112     private String getResponseData(String rs) {
113         JsonFormatTool jft = new JsonFormatTool();
114         
115         return jft.formatJson(rs);
116     }
117     
118     //每个线程测试前执行一次，做一些初始化工作；  
119     public void setupTest(JavaSamplerContext arg0) {
120         super.setupTest(arg0);
121     }
122     
123     //每个线程测试结束后执行一次
124     public void teardownTest(JavaSamplerContext arg0){  
125         super.teardownTest(arg0);  
126     }
127 
128 }