Java-使用MQ的JMS多线程概念

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Java-使用MQ的JMS多线程概念，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1976字，纯文字阅读大概需要3分钟。

内容图文

我最近开始学习JMS,到目前为止已经了解了一些概念.但是,我想知道IBM MQ或任何队列提供者如何处理来自多线程应用程序的请求.例如

考虑一个具有多线程并配置为使用MQ将消息发送到大型机主机的应用程序.此应用程序配置了一个放置队列和获取队列.想象一下,每个要从主机获取数据的请求都被处理了10个.由于Queue只是其中一个,因此所有这10条消息都同时放入队列中,主机会处理这些消息并将答复发送给客户端(即应用程序).回复消息如何不混淆,每个线程如何获得自己正确的回复消息？

通信时会使用一些ID,它是否特定于所发送消息的特定线程？是否需要为每个新的执行线程建立JMS会话？什么是相同的会话用于所有10个请求？将不胜感激任何详细解释此概念的示例或链接.

解决方法:

JMS通过以下几个功能支持此功能：

首先,JMSCorrelationId是一个JMS头,用于将请求与响应相关联.即每个消息都包含一个全局唯一(GUUID)JMSMessageId.大型机应用程序应该简单地将消息ID从请求复制到响应消息上的JMSCorrelationId,然后发送回共享响应队列.

因此,只需通过以下方式发送请求：

(psuedo code - in one thread, do the following when you need to request data over JMS)
myMessage = session.createTextMessage("My nice request");
messageProducer.send(myMessage); // using some previously setup producer
// commit if needed

mc = session.createConsumer(queue,"JMSCorrelationId='"+myMessage.getMessageId()+"'");
responseMessage = mc.receive(TIMEOUT);
if( responseMessage != null){
  //got OUR response data
}
// close down consumer here.

允许多个使用者线程(或应用程序)的诀窍是使用者中的选择器. JMS选择器类似于SQL或类似查询语言的子集.在这种情况下,只需选择JMSCorrelationId与请求中的id相同的消息,就可以发送一些时间.

这是您可以对具有一个固定的共享队列的约束进行的唯一“安全”设置,并且请求必须返回到与它所请求的线程相同的线程.

为了避免JMS选择器的开销,您可以另外使用临时队列进行答复,每个请求一个临时队列,然后将没有其他线程在侦听特定的响应.获得性能的另一个选择是使应用程序更加异步. JMS实际上促进了这一点,触发了一个请求,并让使用者线程池处理任何异步响应-每个线程都具有处理任何响应的能力-就像处理数据并将其放入数据库(或类似数据库)一样.我不知道这种设计范例是否适用于您的情况,但是至少您应该意识到这一点.

内容总结

以上是互联网集市为您收集整理的Java-使用MQ的JMS多线程概念全部内容，希望文章能够帮你解决Java-使用MQ的JMS多线程概念所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端