springboot怎么支持ibmmq消息队列

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了springboot怎么支持ibmmq消息队列相关的知识,希望对你有一定的参考价值。

参考技术A springboot支持ibmmq消息队列步骤如下:
springboot只有在当前这个项目调用才会创建ibmmq队列,并不是项目启动就会创建,但是实际的开发中队列创建和发送应该是两个项目。

如何在 Jmeter 中使用 JMS Point-to-Point Sampler 将消息发送到 IBM MQ 队列

【中文标题】如何在 Jmeter 中使用 JMS Point-to-Point Sampler 将消息发送到 IBM MQ 队列【英文标题】:How can JMS Point-to-Point Sampler be used in Jmeter to send messages to an IBM MQ queue 【发布时间】:2021-12-12 12:10:31 【问题描述】:

我有一个设置了一些默认队列的本地 IBM MQ 实例。

使用 JMeter 5.4.1,我首先想向其中一个队列发送消息以测试连接是否有效。

1.是否可以与 IBM MQ 一起使用,还是只能与 Active MQ 一起使用?

我希望实现的测试场景是这样的:

JMeter 将一些 ID 为 1 的消息发送到名为“DEV.QUEUE.1”的队列 被测系统从“DEV.QUEUE.1”获取消息,进行一些处理并将响应放在“DEV.QUEUE.2”上 JMeter 检查并断言已在 X 秒内收到对名为“DEV.QUEUE.2”的队列中 ID1 的消息的响应 在汇总报告中查看结果

2。这可以通过 JMS 点对点采样器实现吗?

我查看了 JMeter 官方文档,但我不明白我需要在每个采样器的配置字段中放置哪些连接详细信息。

JMS Resources
QueueConnection Factory:
JNDI name Request queue:
JNDI name Receive queue:
Number of samples to aggregate
JMS Selector
....
etc...

我能够使用 JSR223 采样器中的自定义代码连接到一个队列并发送消息。 这些是我用来创建连接的连接详细信息:

def hostName = "127.0.0.1"
def hostPort = 1414
def channelName = "DEV.APP.SVRCONN"
def queueManagerName = "QM1"
def queueName = "DEV.QUEUE.1"

def ff = JmsFactoryFactory.getInstance(WMQConstants.WMQ_PROVIDER)
def cf = ff.createConnectionFactory()

cf.setStringProperty(WMQConstants.WMQ_HOST_NAME, hostName)
cf.setIntProperty(WMQConstants.WMQ_PORT, hostPort)
cf.setStringProperty(WMQConstants.WMQ_CHANNEL, channelName)
cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT)
cf.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, queueManagerName)

def connInboundQueue = cf.createConnection("mquser", "secretpassword")
def sessInboundQueue = connInboundQueue.createSession(false, Session.AUTO_ACKNOWLEDGE)
def destinationInboundQueue = sessInboundQueue.createQueue(queueName)
connInboundQueue.start()

我猜我可以将这些连接凭据映射到这个 JMS 点对点采样器,以便我可以实现相同的连接,我只是不知道如何。

总结一下:

1a。如何使用 JMS 点对点采样器连接到我的两个队列?

2a。如何为我上面描述的场景配置 JMS 点对点采样器?

我将不胜感激。

【问题讨论】:

【参考方案1】:

我认为目前不可能,选项在:

    使用mqmeter - MQ JMeter Extension,它将提供一个自定义的Java Request采样器 继续使用 JSR223 测试元素,示例生产者和消费者代码 sn-ps 可以在 IBM MQ testing with JMeter - Learn How 文章中找到

【讨论】:

以上是关于springboot怎么支持ibmmq消息队列的主要内容,如果未能解决你的问题,请参考以下文章

activemq消息队列和kafka有啥区别

IBM WebSphere MQ安装集成

IBM WebSphere MQ安装集成

MQ服务

ibm的mq创建管理器时间太长

delphi客户端连接IBM MQ