一：首先我们看服务端代码代码架构为：
新建一个maven工程，pom文件为：1
在src/main下新建文件夹assembly，然后在assembly文件夹下新建assembly.xml文件1
在src/main/assembly文件夹下新建conf文件夹，然后在conf文件夹下新建dubbo.properties文件,此处的zookeeper的地址根据实际进行修改1 dubbo.container=log4j,spring 2 dubbo.application.name=demo-caiya 3 dubbo.application.owner=william 4 #dubbo.registry.address=multicast://224.5.x.7:1234 5 dubbo.registry.address=zookeeper://134.xx.xx.xx:2181 6 #dubbo.registry.address=redis://127.0.0.1:6379 7 #dubbo.registry.address=dubbo://127.0.0.1:9090 8 #dubbo.monitor.protocol=registry 9 dubbo.protocol.name=dubbo10 dubbo.protocol.port=2088011 #dubbo.service.loadbalance=roundrobin12 #dubbo.log4j.file=logs/dubbo-demo-consumer.log13 #dubbo.log4j.level=WARN
在src/test/resources包路径下，新建dubbo.properties文件，内容和上面的3中dubbo.properties文件内容相同
编写provider的接口sayHello，新建DemoService.java类
编写sayHello接口的实现类，新建DemoServiceImpl.java类package com.ustc.demo.provider;import java.text.SimpleDateFormat;import java.util.Date;public class DemoServiceImpl implements DemoService{ public String sayHello(String name) { String time = new SimpleDateFormat('HH:mm:ss').format(new Date()); System.out.println('from consumer:'+name); return 'The current time is:'+time; }
编写spring的配置文件，在META-INF/spring文件夹下的demo-provider.xml文件1 2
编写main方法，新建DemoServiceMain.java类1 package com.ustc.demo.provider; 2 public class DemoServiceMain {3 public static void main(String[] args) {4 com.alibaba.dubbo.container.Main.main(args);5 }6 }这样服务端的代码就写好了，实现的功能是当消费者来询问当前时间是几点的时候，返回当前时间
然后我们看消费端代码
新建一个maven工程，pom文件为：1
在src/main下新建文件夹assembly，然后在assembly文件夹下新建assembly.xml文件1
在src/main/assembly文件夹下新建conf文件夹，然后在conf文件夹下新建dubbo.properties文件,此处的zookeeper的地址根据实际进行修改1 dubbo.container=log4j,spring 2 dubbo.application.name=demo-consumer 3 dubbo.application.owner= 4 #dubbo.registry.address=multicast://224.5.6.7:1234 5 dubbo.registry.address=zookeeper://134.64.xx.xx:2181 6 #dubbo.registry.address=redis://127.0.0.1:6379 7 #dubbo.registry.address=dubbo://127.0.0.1:9090 8 dubbo.monitor.protocol=registry 9 dubbo.log4j.file=logs/dubbo-demo-consumer.log10 dubbo.log4j.level=WARN
在src/test/resources包路径下，新建dubbo.properties文件，内容和上面的3中dubbo.properties文件内容相同
编写provider的接口sayHello，新建DemoService.java类1 package com.ustc.demo.provider; 2 3 public interface DemoService {4 public String sayHello(String name);5 }
6：编写消费端请求类调用sayHello方法，新建DemoAction.java类1 package com.ustc.demo.consumer; 2 import com.ustc.demo.provider.DemoService; 3 public class DemoAction { 4 5 private DemoService demoService; 6 7 public void setDemoService(DemoService demoService) { 8 this.demoService = demoService; 9 }10 11 public void start() throws Exception {12 for (int i = 0; i < Integer.MAX_VALUE; i ++) {13 try {14 String hello = demoService.sayHello('hello,How much is the current time?');15 System.out.println('from provider:'+hello);16 } catch (Exception e) {17 e.printStackTrace();18 }19 Thread.sleep(2000);20 }21 }22 }
7：编写spring的配置文件，在META-INF/spring文件夹下的dubbo-demo-action.xml文件1 2
8：编写spring的配置文件，在META-INF/spring文件夹下的dubbo-demo-consumer.xml文件1 2
9：编写main方法，新建DemoServiceMain.java类1 package com.ustc.demo.consumer; 2 public class DemoConsumerMain {3 public static void main(String[] args) {4 com.alibaba.dubbo.container.Main.main(args);5 }6 }
这样我们就完成了本地消费者代码，在编写符合jmeter格式的代码前，我们首先在本地开发工具中运行看看效果：启动服务提供方的main方法，然后启动服务消费方的main方法：服务消费者控制台： 服务提供者控制台：这样调试发现消费端向服务端发送：How much is the current time?，然后服务端返回当前的时间，该dubbo接口的功能正常实现
我们现在想对dubbo接口进行性能测试，可以用jmeter模拟服务消费方并发调用服务提供方因为jmeter支持java请求，故我们可以将服务提供方打包部署到服务器上运行，将服务消费方打成jar包放到jmeter的/lib/ext文件夹中，这样就能实现jmeter模拟消费方去请求服务端，进行性能测试现在我们来讲解如何将上面的服务消费端的代码编写成可以打包放到jmeter中的jar包代码只需要对上面的消费者代码进行3处修改即可：1：pom.xml文件中添加对jmeter的支持，在
在src/main/resources下新建applicationConsumer.xml文件，zookeeper地址根据需要进行修改1
2
在com.ustc.demo.consumer包下新建JmeDemoAction.java类1 package com.ustc.demo.consumer; 2 3 import org.apache.jmeter.protocol.java.sampler.AbstractJavaSamplerClient; 4 import org.apache.jmeter.protocol.java.sampler.JavaSamplerContext; 5 import org.apache.jmeter.samplers.SampleResult; 6 import org.springframework.context.support.ClassPathXmlApplicationContext; 7 8 import com.ustc.demo.provider.DemoService; 9 10 /** 11 * ClassName:JmeDemoAction
12 * Function: TODO ADD FUNCTION.
13 * Reason: TODO ADD REASON.
14 * Date: 2016年12月3日 下午10:12:10
15 * @author meiling.yu
16 * @version 17 * @since JDK 1.718 * @see 19 */20 public class JmeDemoAction extends AbstractJavaSamplerClient{21 ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(22 new String[] { 'applicationConsumer.xml' });23 24 public SampleResult runTest(JavaSamplerContext arg0) {25 SampleResult sr = new SampleResult();26 try {
27 sr.sampleStart();28 context.start();29 DemoService demoService = (DemoService) context.getBean('demoService');30 String hello = demoService.sayHello('hello,How much is the current time?');31 sr.setResponseData('from provider:'+hello, null);32 sr.setDataType(SampleResult.TEXT);33 sr.setSuccessful(true);34 sr.sampleEnd();35 } catch (Exception e) {36 e.printStackTrace();37 }38 return sr;39 }40 41 }这样就完成了jmeter的消费端代码编写
将消费端和服务端打包maven install，打包完成后可以看到消费端的target下生成了两个文件一个consumer-0.0.1-SNAPSHOT-assembly.tar.gz还有一个consumer-0.0.1-SNAPSHOT.jar将consumer-0.0.1-SNAPSHOT-assembly.tar.gz中的lib文件夹下所有的jar包拷贝到jmeter的lib目录下，如果有重复的，则不替换用jmeter原生的jar包将consumer-0.0.1-SNAPSHOT.jar拷贝到jmeter的lib/ext目录下 部署服务端，然后消费端为：启动jmeter，验证该jar功能是否正常，新建一个java请求启动服务端：
新建消费端的java请求：新建消费端的java请求：启动消费端，发现响应结果中返回了服务端的响应：在看服务端的日志：上图为两个线程测试了一下，发现调用通过成功，响应数据正常返回，故该脚本可以正常使用，至此jmeter测试dubbo接口整个的脚本制作过程就讲完了至于如何用这个jmx脚本做性能测试，我就不在重复了，-meter命令行运行-单节点测试或者分布式测试最后给出工程源码，也就是上面的例子的源代码jmeter测试dubbo接口：dubbor.rar中包含两个maven工程，dubbo-consumer和dubbo-provider
上图为两个线程测试了一下，发现调用通过成功，响应数据正常返回，故该脚本可以正常使用，至此jmeter测试dubbo接口整个的脚本制作过程就讲完了 至于如何用这个jmx脚本做性能测试，我就不在重复了，-meter命令行运行-单节点测试或者分布式测试 最后给出工程源码，也就是上面的例子的源代码jmeter测试dubbo接口：dubbor.rar中包含两个maven工程，dubbo-consumer和dubbo-provider