Gatling 3.9及最新版本是否支持JMS消息仅消费功能？

Gatling官方提供的JMS模块确实只支持request-reply和send两种核心模式，截至最新版本（如3.10.x），也没有原生的“仅消费”（单向接收）功能，你没有遗漏文档内容。

要实现仅消费JMS消息的场景，可以通过以下两种方式：

1. 自定义Gatling Action #

基于Gatling的扩展机制，编写自定义Action封装JMS消费逻辑，适合需要复用消费逻辑的场景：

• 提前初始化JMS连接工厂、会话和消费者
• 在Action的execute方法中实现消息接收逻辑
• 将消费结果存入Gatling Session，方便后续断言或统计

示例代码框架：

import io.gatling.core.action.Action
import io.gatling.core.session.Session
import javax.jms._

class JmsConsumeAction(next: Action, connectionFactory: ConnectionFactory, queueName: String) extends Action {
  private val connection = connectionFactory.createConnection()
  private val jmsSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
  private val destination = jmsSession.createQueue(queueName)
  private val consumer = jmsSession.createConsumer(destination)

  override def execute(session: Session): Unit = {
    val message = consumer.receive(5000) // 设置接收超时时间，避免阻塞
    val updatedSession = message match {
      case textMsg: TextMessage => session.set("jmsReceivedMsg", textMsg.getText)
      case _ => session.set("jmsReceivedMsg", "收到非文本类型消息")
    }
    next.execute(updatedSession)
  }

  override def name: String = "JmsConsumeAction"
}

在Simulation中调用自定义Action：

import io.gatling.core.Predef._
import scala.concurrent.duration._

class JmsConsumeSimulation extends Simulation {
  val jmsConnFactory = // 初始化你的JMS连接工厂（如ActiveMQConnectionFactory）
  val jmsConsumeAction = new JmsConsumeAction(next = ???, jmsConnFactory, "test-queue")

  val scn = scenario("JMS仅消费场景")
    .exec(jmsConsumeAction)
    .pause(1 second)

  setUp(scn.inject(constantUsersPerSec(10) during (1 minute)))
}

2. 在exec块中直接调用JMS API #

如果场景简单，可直接在Gatling的exec块中嵌入标准JMS API实现消费，轻量化且快速：

import io.gatling.core.Predef._
import javax.jms._
import scala.concurrent.duration._

class JmsConsumeSimulation extends Simulation {
  // 提前初始化JMS资源，放在before钩子中避免重复创建
  private var connection: Connection = _
  private var jmsSession: Session = _
  private var consumer: MessageConsumer = _

  before {
    val connFactory = // 你的JMS连接工厂实例
    connection = connFactory.createConnection()
    connection.start()
    jmsSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
    val destination = jmsSession.createQueue("test-queue")
    consumer = jmsSession.createConsumer(destination)
  }

  // 测试结束后释放资源
  after {
    consumer.close()
    jmsSession.close()
    connection.close()
  }

  val scn = scenario("JMS仅消费场景")
    .exec(session => {
      val message = consumer.receive(3000)
      val msgContent = message match {
        case tm: TextMessage => tm.getText
        case _ => "未知消息类型"
      }
      session.set("receivedMsg", msgContent)
    })
    .pause(500 milliseconds)
    .exec(session => {
      // 可在此添加自定义断言，比如检查消息内容
      val receivedMsg = session("receivedMsg").as[String]
      // 示例：如果消息包含指定内容则标记成功
      if (receivedMsg.contains("expected-content")) session.markAsSucceeded else session.markAsFailed
    })

  setUp(scn.inject(rampUsers(50) during (10 seconds)))
}

注意事项 #

• 务必妥善管理JMS连接、会话和消费者的生命周期，避免资源泄漏
• 设置合理的消息接收超时时间，防止场景因等待消息长时间阻塞
• 可结合Gatling的统计API，自定义消费成功/失败的指标，方便监控

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