转载 Jmeter socket的压力测试

socket的压力测试

 

（1）socket测试需要写一个测试jar包。

首先创建一个java工程，导入lib\ext\ApacheJMeter_core.jar，ApacheJMeter_java.jar

然后创建下面的代码：（IP和端口可以根据自己的需要修改）

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 java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.*;

/**
 *
 * @author howsky
 *
 */
public class Test extends AbstractJavaSamplerClient {
 // Sock begin----------------------------------------------
 private Socket sid;
 private PrintWriter out;
 private BufferedReader in;
 private String ip;
    private String port;
 // Sock end------------------------------------------------

    private static String label = "howsky.net";

 // 测试结果
 private SampleResult sr;

 /**
  * 初始化
  */
 public void setupTest(JavaSamplerContext arg0) {
        System.out.println("setupTest");
    }

 /**
  * 设置请求的参数
  */
 public Arguments getDefaultParameters() {
        Arguments params = new Arguments();
        params.addArgument("ip", "127.0.0.1");
        params.addArgument("port", "8888");
        return params;
    }

 /**
  * 运行过程
  */
 public SampleResult runTest(JavaSamplerContext arg0) {
     ip = arg0.getParameter("ip");
        port = arg0.getParameter("port");
        sr = new SampleResult();
        sr.setSampleLabel(label);
        try{
            sr.sampleStart(); //记录程序执行时间，以及执行结果
            //发送数据
            String msg = "welcome to howsky.net";
            System.out.println("begin");
            sendMsg(ip, Integer.parseInt(port), msg);
            sr.setSuccessful(true);
            System.out.println("end");
        }catch(Throwable e){
            sr.setSuccessful(false);
        }finally{
            sr.sampleEnd();
        }
        return sr;
 }

 /**
  * 结束
  */
 public void teardownTest(JavaSamplerContext arg0) {
    }

 /**
  * 发送消息
  * @param ip
  * @param port
  * @param msg
  * @throws Exception
  */
 private void sendMsg(String ip, int port, String msg) throws Exception{
  sid = new Socket(ip, port);
  in = new BufferedReader(new InputStreamReader(sid.getInputStream()));
  out = new PrintWriter(sid.getOutputStream(), true);
  out.println(msg);
  in.readLine();
        System.out.println("success");
    }
}

 

接着点击项目右键Export->jar file->命名.jar

最后将jar包放到lib\ext\下，启动JMeter。

（2）本地写socket服务器端代码如下：

public class SocketSer
{
public static void main(String[] args)
    {
            ServerSocket ss=null;
            OutputStream os=null;
            try {
                    ss = new ServerSocket(8888);
                    while(true){
                        Socket s=ss.accept();
                        String ip=s.getInetAddress().getHostName();
                        os=s.getOutputStream();
                        os.write("ServerSocket回复请求".getBytes());
                        os.flush();
                        s.close();
                        System.out.println(ip+"---"+new String("^_^成功完成一次请求"));
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }finally{
                    try {
                        os.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
    }

然后在本地启动调用该段代码（开启服务端）。

（3）JMeter中创建线程组。设置线程数，Ramp-up Period,循环次数。

（4）JMeter中创建Java请求默认值，如图：

 

然后选择要测试的类：如图

 

（5）JMeter中创建java请求：

 

配置基本和java请求默认值一样。

如图：

 

（6）创建监听：查看结果树

 

结果如下：

 

命令行输出：

 

备注写给自己：  2015年做的kafka生产者消费者行情改造项目test_hq 与此类似

原文：http://blog.csdn.net/a574258039/article/details/19549407