1

我们正在使用 Spring JMSTemplate 3.0.1RELEASE 将 JMS 消息发送到 ActiveMQ 集群。

我正在使用 useAsynSend=true 来发送异步请求，因为这些都是 Fire and Forget。但是它们仍然是持久的，我可以确认它们确实首先在 AMQ Kaha-DB 上持久化，然后转发到消息侦听器。没有 CorelationID 或 JMSReplyTo，因为我没有回听任何响应。

   <amq:connectionFactory id="amqJmsFactory"
    brokerURL="failover:(tcp://MY-SERVER-01:61616,tcp://MY-SERVER-02:61616)?randomize=true&jms.useAsyncSend=true" />

<!-- JMS Producer Configuration -->
<bean id="jmsProducerTemplate" class="org.springframework.jms.core.JmsTemplate"
    p:connectionFactory-ref="amqJmsFactory" />

  <bean id="activeMQBinding" class="com.my.company.activemq.ActiveMQProductBinding">
    <property name="template" ref="jmsProducerTemplate" />
</bean>

在 ActiveMQProductBinding 类中，我们有以下方法

  public void sendActiveMQMessageAsync(final Object message, String qName) {
    log.info("About to send message");
    template.send(qName, new MessageCreator() {
        public Message createMessage(Session session) throws JMSException {
            ObjectMessage objectMessage = session.createObjectMessage((Serializable) message);

            log.info("Sending message: " + objectMessage);

            return objectMessage;
        }
    });
}

现在我可以在日志中看到正在打印日志。不抛出异常。仍然有些消息完全丢失了。它可能没有达到 ActiveMQ。我已将 Mule JMS 侦听器配置为侦听上面由“qName”定义的 ActiveMQ 队列上的消息。大多数消息都可以很好地传递到 AMQ，Mule 会在几分之一秒内接收到它们。然而，丢失的只是一些消息。当我检查 ActiveMQ 上的队列时，我可以看到收到的所有消息都已发送到 Mule。因此，我怀疑消息根本没有到达 ActiveMQ，或者 AMQ 正在拒绝。但是在 JMSTemplate spring 或 ActiveMQ 上没有日志。

创建的消息如下所示（在上面的方法中打印）。

   2013-03-11 16:33:11,752 INFO [com.my.company.activemq.ActiveMQProductBinding$1] Sending message: ActiveMQObjectMessage {commandId = 0, responseRequired = false, messageId = null, originalDestination = null, originalTransactionId = null, producerId = null, destination = null, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent = false, type = null, priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@61408493, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false}

我在 JMSTemplate 配置或 AMQ 上的某些行为中遗漏了什么？请帮忙！

有帮助吗？

4

1 回答 1

1

2 我能想到的可能原因。1）我们使用了错误的连接工厂。我们应该使用带有 JMSTemplate 的池连接工厂来发送消息。org.apache.activemq.pool.PooledConnectionFactory

2) 我们使用 useAsyncSend=true - 即发送者发送消息并且不等待确认并且有消息丢失的机会。这似乎更有可能，但不确定。

仍然不接受这是答案，因为有人可能有更具体的解释。与此同时，如果有人偶然发现这个问题，可能会从这个线索中受益。

于 2013-03-27T16:55:57.427 回答