Activemq如何配置消费者监听器（Java中）

Question

如果有人能分享一个在 Spring 中基于 xml 的消费者侦听器配置的简单示例，我会很高兴。提前致谢。

编辑；

我只是想听听消费者的监听器，而不是消费者的实现，因为我已经在我的应用程序中实现了 active-mq。它运行良好，但是我无法确定生产者同步发送的消费项目的顺序。 问题是由于并发消费者一次异步执行方法（将一些对象保存到数据库以记录它们）而导致的不一致和数据操作。

编辑2： 让我澄清一下这种复杂性。我有一个由两个基本独立部分组成的应用程序。第一个是同步执行的Producer，向db询问新来的产品，然后通过active-mq提供的“jmsTemplate.send”方法“一个一个”发送它们。这是从 Cron/Timer 同步执行的操作。换句话说，生产者是从计时器/cron 执行的。现在的问题是消费者本身。当生产者“一个接一个”发送产品时，异步消费者（启用并发）接收产品并异步消费它们。

问题就从这里开始。因为该方法是消费者刚收到产品时执行的，它会执行一些数据库持久化操作。当相同的产品被不同的并发消费者接收时（这是因为我们的系统而发生的，而不是 jms 问题，不要注意这一点），然后对同一实体执行相同的持久性操作，会发生一些易于预测的异常。如何防止产品的这种异步操作或管理此类应用程序中消费产品的订单。

谢谢。

Answer 1

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xmlns:jms="http://www.springframework.org/schema/jms"
   xmlns:p="http://www.springframework.org/schema/p"
   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
                       http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd">

<!-- A simple and usual connection to activeMQ -->  
<bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>                

 <!-- A POJO that implements the JMS message listener -->
<bean id="simpleMessageListener" class="MyJMSMessageListener" />


<!-- Cached Connection Factory to wrap the ActiveMQ connetion -->
<bean id="cachedConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">     
    <property name="targetConnectionFactory" ref="activeMQConnectionFactory"></property>
    <property name="sessionCacheSize" value="10"></property>
    <property name="reconnectOnException" value="true"></property>
</bean>


<!-- The Spring message listener container configuration -->
<jms:listener-container container-type="default" connection-factory="cachedConnectionFactory" acknowledge="auto">
    <jms:listener destination="FOO.TEST" ref="simpleMessageListener" method="onMessage" />
</jms:listener-container>

</beans>

侦听消息的 Java 类 itslef:

import javax.jms.Message;
import javax.jms.MessageListener;
public class MyJMSMessageListener implements MessageListener{

    @Override
    public void onMessage(Message message) {
    // Do your work here
    }

}

启动此侦听器只需获取应用程序上下文，一旦执行此操作，它将自动启动 JMS 侦听器。

根据其他问题进行编辑：

那么您的系统可能会生成（例如）2条甚至更多条消息，这些消息传递给具有相同productID的消费者？首先，这不是您的问题，而是应用程序的问题。即使你以某种方式修复了它，它也不是真正的修复，而是隐藏问题本身的一种方法。然而，如果被迫提供解决方案，现在我只能想到一个，最简单的，禁用并发消费之类的。这是我要做的：接收队列中的消息，并且该队列上只有一个消费者。在这个 Consumer 中，我会尽可能少地处理消息 - 仅获取 ProductID 并将其放入其他队列中。在此之前，您必须始终检查 ProductID 是否已不在该队列中。如果只是默默返回，如果不是，则意味着它从未被处理过，因此将此消息放置在另一个队列中：例如 Queue2，然后在第二个队列 Queue2 上启用并发消费者。但这仍然有缺陷：首先，productID 队列应该以某种方式偶尔清理一次，否则它将永远增长，但这就是那么困难。棘手的部分：如果您在 ProductID 队列中有一个 ProductID，但该产品是在数据库中进行更新而不是插入，该怎么办？那你就不应该拒绝...