Spring JMS 生产者和消费者交互

Question

如何确定消费者是否已经从生产者那里收到了消息，或者如何通知生产者该消息已经在Spring JMS中发送/消费？

Answer 1

您需要使用请求/回复 在生产者端使用org.springframework.jms.core.JmsTemplate.sendAndReceive(...)，在使用者端，容器中设置的 MessageListener 方法必须返回一个值。

或者通过访问某些属性(如orignalMessageId)使订阅ActiveMQ.Advisory.MessageConsumed.Queue的生产者在消息被使用时收到通知，请查看此处 http://activemq.apache.org/advisory-message.html

你可以这样使用它：

Destination advisoryDestination = org.apache.activemq.advisory.AdvisorySupport
.getMessageConsumedAdvisoryTopic(session.createQueue("yourQueue"));
MessageConsumer consumer = session.createConsumer(advisoryDestination);
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message msg) {
System.out.println(msg);
System.out.println(((ActiveMQMessage) msg).getMessageId());
ActiveMQMessage aMsg = (ActiveMQMessage) ((ActiveMQMessage) msg).getDataStructure();
System.out.println(aMsg.getMessageId());
}
});