0

问题

我需要使用 JMeter 在 IBM MQ 中注入消息。

格式应为 RFH2。我需要将Format字段设置为空并更改标题的内容。

我应该使用哪种 JMeter 对象来做到这一点？

你能帮我吗？非常感谢。

更新 n°1

感谢@DmitriT 的回答，我可以在队列中发送消息。

但是，似乎标题内容不是放在标题中而是放在消息之前。请在下面找到一个示例：

带有使用 MQ Visual Edit 发送的消息的服务器日志

标题

 2020-04-21 11:07:59.913 DEBUG 48093 --- [DefaultMessageListenerContainer-2] 
 c.b.i.c.listeners.AbstractAgiListener    : Receive message on MQ with header : {someargs, 
 jms_destination=queue:///myqueue, someargs, Sender=mysender, someargs, jms_type=mcd://jms_byte,
 someargs}

信息

 <Document ...>...</Document>

带有使用 JMeter 发送的消息的服务器日志

标题

 2020-04-21 11:07:59.913 DEBUG 48093 --- [DefaultMessageListenerContainer-2] 
 c.b.i.c.listeners.AbstractAgiListener    : Receive message on MQ with header : {someargs}

信息

 RFH ¨ÿÿÿþ        ¸ <mcd><Msd>jms_bytes</Msd></mcd> 8<jms><Dst>queue:///myqueue</Dst>
<Pri>0</Pri></jms>    <usr><Sender>mysender</Sender></usr><Document ...>...</Document>

知道如何解决吗？谢谢你。

4

1 回答 1

1

您应该使用的“JMeter 对象”是JSR223 Sampler

  1. 下载com.ibm.mq.allclient库的相关版本（带有依赖项）并将其拖放到JMeter Classpath
  2. 重新启动 JMeter 以获取库
  3. 将 JSR223 采样器添加到您的测试计划中

  4. 根据您的要求创建消息并将其发布到队列中。参考代码：

    import com.ibm.mq.MQAsyncStatus
import com.ibm.mq.MQMessage
import com.ibm.mq.MQPutMessageOptions
import com.ibm.mq.MQQueueManager
import com.ibm.mq.constants.CMQC
import com.ibm.mq.constants.MQConstants
import com.ibm.mq.headers.MQRFH2

def mqProps = new Hashtable<String, Object>()
mqProps.put(MQConstants.CHANNEL_PROPERTY, 'DEV.APP.SVRCONN')
mqProps.put(MQConstants.PORT_PROPERTY, 1414)
mqProps.put(MQConstants.HOST_NAME_PROPERTY, '192.168.99.100')

def qManager = 'QM1'
def queueName = 'DEV.QUEUE.1'


def qMgr = new MQQueueManager(qManager, mqProps)
def openOptions = MQConstants.MQOO_OUTPUT | MQConstants.MQOO_INPUT_AS_Q_DEF
def queue = qMgr.accessQueue(queueName, openOptions)

def pmo = new MQPutMessageOptions()
pmo.options = MQConstants.MQPMO_ASYNC_RESPONSE
def message = new MQMessage()
def rfh2 = new MQRFH2()
rfh2.setEncoding(CMQC.MQENC_NATIVE)
rfh2.setCodedCharSetId(CMQC.MQCCSI_INHERIT)
rfh2.setFormat(CMQC.MQFMT_STRING)
rfh2.setNameValueCCSID(1208)
rfh2.setFieldValue('your', 'data', 'here')
rfh2.write(message)

queue.put(message, pmo)
queue.close()

MQAsyncStatus asyncStatus = qMgr.getAsyncStatus()
log.info('Successfully published: ' + asyncStatus.putSuccessCount + ' message(s)')

参考：

于 2020-04-20T15:40:16.637 回答