如何用JMeter与WebSphere MQ消费队列消息并发送至API端点

1. 准备IBM MQ依赖包 #

• 将IBM MQ客户端核心jar包（如com.ibm.mq.allclient.jar、javax.jms-api.jar）复制到JMeter安装目录的lib文件夹，重启JMeter生效。

2. 创建线程组 #

• 右键测试计划 → 添加 → 线程（用户） → 线程组，根据性能测试需求设置线程数、循环次数等参数。

3. 配置JMS Subscriber获取MQ消息并存储变量 #

• 右键线程组 → 添加 → 取样器 → JMS Subscriber
• 填写MQ连接核心配置：
  • Connection Factory: com.ibm.mq.jms.MQConnectionFactory
  • Initial Context Factory: com.ibm.mq.jms.context.WMQInitialContextFactory
  • Provider URL: MQ服务地址，格式为tcp://[MQ主机IP]:[端口]
  • Destination: 目标队列/主题名称
  • 按需填写MQ认证的用户名和密码
• 添加JSR223后置处理器存储消息：
  • 右键JMS Subscriber → 添加 → 后置处理器 → JSR223 PostProcessor
  • 语言选择Groovy，输入脚本：

    def mqMsg = prev.getResponseDataAsString()
    vars.put("MQ_REQUEST_BODY", mqMsg)
    

  该脚本会将MQ获取的消息存入MQ_REQUEST_BODY变量。

4. 配置HTTP POST请求使用MQ消息作为请求体 #

• 右键线程组 → 添加 → 取样器 → HTTP请求
• 配置应用端点信息：
  • 服务器名称或IP: 应用服务主机地址
  • 端口号: 应用服务端口
  • 路径: 目标API路径（如/api/process-claim）
  • 请求方法: POST
• 在「请求体」区域选择「Body Data」，输入：

  ${MQ_REQUEST_BODY}
  

  这样JMeter会自动将变量中的MQ消息作为POST请求的内容发送。

5. 验证测试流程 #

• 添加「查看结果树」监听器，运行测试后检查：
  • JMS Subscriber的响应数据是否为预期的MQ消息
  • HTTP请求的请求体是否正确加载了MQ消息
  • 应用端点是否返回了正常的处理结果

内容的提问来源于stack exchange，提问作者Randy mangal