1

我正在使用以下代码块将 JMS 消息发布到队列，并在响应队列中获取响应消息。（以下代码运行 100 条消息，每线程 20 条，同时运行 5 个线程）

    for(int i=0;i<=20;i++)
            {
                msg=myMessages.get(i); // myMessages is an array of TextMessages 
                qsender = qsession.createSender((Queue)msg.getJMSDestination());
                qreceiver=qsession.createReceiver((Queue)msg.getJMSDestination());

                tempq = qsession.createTemporaryQueue();
                responseConsumer = qsession.createConsumer(tempq);
                msg.setJMSReplyTo(tempq);
                responseConsumer.setMessageListener(new Listener());

                msg.setJMSCorrelationID(msg.getJMSCorrelationID()+i);
                qsender.send(msg);   
            }

监听器实现：

public class Listener 
implements MessageListener
{
    public void onMessage(Message msg)
    {
        TextMessage tm = (TextMessage) msg;
        // to calculate the response time

    }
}

要求是获取每条消息的响应时间并将其存储。我该怎么做？考虑在消息的属性中设置时间/日期，然后使用 Correlation id 计算 Listener 中的时间。

还有其他方法吗？

4

1 回答 1

1

您可以Map<String, Long>将 CorrelationID 映射到发送的时间，然后从侦听器中查找它们。发送响应的进程必须将正确的 CorrelationID 放在响应消息上才能正常工作。

对于此示例，假设timemap是 aMap<String, Long>并且它在发送者和响应侦听器的范围内（您希望如何完成这取决于您）。

上面的循环体，已修改：

            msg=myMessages.get(i); // myMessages is an array of TextMessages 
            qsender = qsession.createSender((Queue)msg.getJMSDestination());
            qreceiver=qsession.createReceiver((Queue)msg.getJMSDestination());

            tempq = qsession.createTemporaryQueue();
            responseConsumer = qsession.createConsumer(tempq);
            msg.setJMSReplyTo(tempq);
            responseConsumer.setMessageListener(new Listener());

            msg.setJMSCorrelationID(msg.getJMSCorrelationID()+i);
            /* MODIFICATIONS */  
            synchronzied(timemap){
               timemap.put(msg.getJMSCorrelationID(), System.currentTimeMillis());
            } /* END MODIFICATIONS */
            qsender.send(msg);

您的听众，已修改：

public void onMessage(Message msg)
{
    TextMessage tm = (TextMessage) msg;
    long now = System.currentTimeMillis();
    long responseTime = 0;
    synchronized(timemap){
         Long sent = timemap.get(msg.getJMSCorrelationID());
         if(sent != null){
             /* Store this value, this is the response time in milliseconds */
             responseTime = now - sent; 
         }else{
             /* Error condition. */
         }
    }

}
于 2012-08-14T02:22:10.027 回答