基于JMeter的RocketMQ压测

叁歲伎倆 2023-09-27 22:36 18阅读 0赞

Rocketmq是一款高性能、高可靠的分布式消息中间件，广泛应用于各种场景中。在实际应用中，为了保证Rocketmq的稳定性和可靠性，我们需要对其进行压测。而JMeter是一款常用的压测工具，可以用于测试Web应用、Web服务、数据库以及各种协议。本文将介绍如何使用JMeter进行Rocketmq压测，并通过编写插件来实现对Rocketmq生产者的压测。

### 1. 准备工作 ###

在进行Rocketmq压测前，需要准备好以下内容：

1.  安装并启动Rocketmq服务端，可以参考官方文档进行安装配置；
2.  下载并安装JMeter，可以从官网下载最新版本；
3.  下载并安装Rocketmq JMS 客户端，可以从官网下载最新版本。

### 2. 编写JMeter插件 ###

首先引入依赖：

xml

复制代码

`<dependency> <groupId>org.apache.jmeter</groupId> <artifactId>ApacheJMeter_core</artifactId> <version>5.4.3</version> </dependency> <dependency> <groupId>org.apache.jmeter</groupId> <artifactId>ApacheJMeter_java</artifactId> <version>5.4.3</version> </dependency> <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>5.1.0</version> </dependency>`

为了实现对Rocketmq生产者的压测，我们需要编写一个JMeter插件。下面是一个简单的示例代码：

java

复制代码

`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 org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.common.message.Message; public class RocketmqProducerSampler extends AbstractJavaSamplerClient { private DefaultMQProducer producer; private String serverUrl; private String topic; private String tags; private String keys; private String body; @Override public void setupTest(JavaSamplerContext context) { serverUrl = context.getParameter("serverUrl"); topic = context.getParameter("topic"); tags = context.getParameter("tags"); keys = context.getParameter("keys"); body = context.getParameter("body"); producer = new DefaultMQProducer("jmeter"); producer.setNamesrvAddr(serverUrl); try { producer.start(); } catch (Exception e) { e.printStackTrace(); } } @Override public void teardownTest(JavaSamplerContext context) { producer.shutdown(); } @Override public SampleResult runTest(JavaSamplerContext context) { SampleResult result = new SampleResult(); try { Message msg = new Message(topic, tags, keys, body.getBytes()); result.sampleStart(); SendResult send = producer.send(msg); result.sampleEnd(); result.setSuccessful(true); result.setResponseMessage(send.toString()); result.setSamplerData(body); } catch (Exception e) { //e.printStackTrace(); result.sampleEnd(); result.setSuccessful(false); } return result; } @Override public Arguments getDefaultParameters() { Arguments params = new Arguments(); params.addArgument("serverUrl", "localhost:9876"); params.addArgument("topic", "test_topic"); params.addArgument("tags", "test_tag"); params.addArgument("keys", "test_key"); params.addArgument("body", "test_body"); return params; } }`

该插件是一个Rocketmq生产者的示例代码，它通过JMeter对Rocketmq进行压测。其中，setupTest()方法用于初始化Producer对象，并连接到Rocketmq服务端；runTest()方法用于发送消息；teardownTest()方法用于关闭Producer对象。另外，getDefaultParameters()方法用于设置默认参数，例如Rocketmq服务端的地址等。

### 3. 在JMeter中使用插件 ###

完成插件的编写后，我们需要将其加入到JMeter中进行使用。下面是具体步骤：

1.  将插件的class文件和依赖的jar包放到JMeter的lib/ext目录下；
    
    这里有个地方需要注意将项目打成Jar包，同时需要将Jar依赖的Jar包也需要放到JMeter的lib/ext。
    
    xml
    
    复制代码
    
    `<plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-assembly-plugin</artifactId> <version>3.5.0</version> <configuration> <archive> <manifest> <mainClass>com.xxg.Main</mainClass> </manifest> </archive> <descriptorRefs> <descriptorRef>jar-with-dependencies</descriptorRef> </descriptorRefs> <finalName>${project.name}</finalName> </configuration> <executions> <execution> <id>make-assembly</id> <phase>package</phase> <goals> <goal>single</goal> </goals> </execution> </executions> </plugin> </plugins>`
    
    为了将依赖和代码打成一个jar包
    
    ![format_png][]
    
    ![format_png 1][]
2.  启动JMeter，并创建一个线程组；
3.  在线程组下创建一个Java请求；
    
    ![format_png 2][]
4.  在Java请求中，选择刚才编写的插件类（例如com.example.RocketmqProducerSampler）；
    
    ![format_png 3][]
5.  在Java请求中设置插件的参数，例如Rocketmq服务端的地址等；
6.  运行JMeter即可开始压测。
    
    ![format_png 4][]

### 4. 注意事项 ###

在使用JMeter进行Rocketmq压测时，需要注意以下几点：

1.  确保Rocketmq服务端已经启动，并且正确配置了Broker和NameServer；
2.  确保Rocketmq JMS 客户端已经正确安装，并且可以被JMeter正常调用；
3.  在JMeter中设置好压测的参数，例如消息发送间隔、消息大小等；
4.  在运行JMeter之前，最好先进行一次简单的压测，以确保配置正确，并排除可能存在的问题。

### 5. 总结 ###

本文介绍了如何使用JMeter对Rocketmq进行压测，并通过编写插件来实现对Rocketmq生产者的压测。在实际应用中，可以根据具体需求进行参数设置和插件编写，以满足不同的压测场景。

作者：蚂蚁背大象  
链接：https://juejin.cn/post/7232692422567395387

[format_png]: https://img-blog.csdnimg.cn/img_convert/4f359ee0aaabd586e7d0ad1d64d39868.webp?x-oss-process=image/format,png
[format_png 1]: https://img-blog.csdnimg.cn/img_convert/5b42d8cbd200a69eca1b40c1328f4b27.webp?x-oss-process=image/format,png
[format_png 2]: https://img-blog.csdnimg.cn/img_convert/67460295935e23316b7ad1c0664b59ea.webp?x-oss-process=image/format,png
[format_png 3]: https://img-blog.csdnimg.cn/img_convert/e5268a2877ef9af5e8388a8969f7e1b7.webp?x-oss-process=image/format,png
[format_png 4]: https://img-blog.csdnimg.cn/img_convert/43fecb4b7c5034c202c1eadf27ce0e08.webp?x-oss-process=image/format,png

发表评论取消回复

表情：

评论列表（有 0 条评论，18人围观）

还没有评论，来说两句吧...

相关阅读

相关 JMeter压测

软件： jetty：jetty-io-9.4.22.v20191022.jar，spring-boot-2.2.1.RELEASE.jar，mysql：Ver 8.0.29

た入场券/ 2024年03月25日 09:55/ 0 赞/ 112 阅读

相关基于JMeter的RocketMQ压测

Rocketmq是一款高性能、高可靠的分布式消息中间件，广泛应用于各种场景中。在实际应用中，为了保证Rocketmq的稳定性和可靠性，我们需要对其进行压测。而JMeter是一款

叁歲伎倆/ 2023年09月27日 22:36/ 0 赞/ 19 阅读

相关基于Docker的JMeter分布式压测

一个JMeter实例可能无法产生足够的负载来对你的应用程序进行压力测试。如本网站所示，一个JMeter实例将能够控制许多其他的远程JMeter实例，并对你的应用程序产生更大的负

清疚/ 2023年09月27日 09:16/ 0 赞/ 12 阅读

相关 jmeter压测(JMETER压测设置延迟)

如何使用jmeter进行压力测试在C\里是一个常量表达式，所以可以用在所有要求用编译时常量的地方，例如attribute的参数、方法参数的默认值、switch里的cas

た入场券/ 2023年09月26日 15:05/ 0 赞/ 200 阅读

相关 Jmeter压测

安装[Apache JMeter][]，根据系统选择下载文件，并解压$\{JMeter\} 打开GUI：(mac系统)$\{JMeter\}/bin/jmeter;

落日映苍穹つ/ 2022年12月23日 13:27/ 0 赞/ 189 阅读

相关 Jmeter分布式压测

一、为什么要使用分布式测试按照一般的压力机配置，jmeter的GUI模式下（Windows），最多支持300左右的模拟请求线程，再大的话，容易造成卡顿、无响应等情况，这是限

心已赠人/ 2022年12月10日 10:07/ 0 赞/ 534 阅读

相关 Jmeter接口压测

Jmeter接口压测压测工具 Jmeter 下载链接[https://download.csdn.net/download/eieiei438/127

拼搏现实的明天。/ 2022年11月30日 12:51/ 0 赞/ 195 阅读

相关 Jmeter压测

Jmeter工具使用入门教程添加线程组 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text

男娘i/ 2022年10月10日 06:06/ 0 赞/ 363 阅读

相关 Jmeter压测教程

安装因为JMeter是一款用java编写的负载功能测试和性能测试的开源软件，所以运行的环境前提是，必须本机装有JDK，这里就不再讲解如何安装JDK了。去官网下载JM

╰+哭是因爲堅強的太久メ/ 2022年09月04日 14:58/ 0 赞/ 269 阅读

相关 Jmeter压测数据库

环境准备： 1、下载mysql驱动，并且在测试计划中添加驱动，驱动下载地址驱动下载地址：http://repo.maven.apache.org/maven2/mys

小灰灰/ 2021年05月12日 11:54/ 0 赞/ 558 阅读