ActiveMq - Kaha - 商店已锁定...等待 10 秒商店解锁

Question

我的应用程序有两个队列（Spring3-Hibernate-ActiveMq）。感谢您提前发表评论。如果您帮助我避免以下错误，我将很高兴：

10:02:41,541 INFO KahaStore:463 - Kaha Store using data directory \tmp\kahadb 10:02:41,542 信息 KahaPersistenceAdapter:185 - 商店已锁定...等待 10 秒以解锁商店。 10:02:51,542 信息 KahaStore:463 - 使用数据目录 \tmp\kahadb 的 Kaha 存储 10:02:51,543 信息 KahaPersistenceAdapter:185 - 商店已锁定...等待 10 秒以解锁商店。 10:03:01,543 信息 KahaStore:463 - 使用数据目录 \tmp\kahadb 的 Kaha 存储 .. 。

这是我的 applicationContext.xml

<amq:connectionFactory id="amqConnectionFactory"
    brokerURL="vm://localhost" />

<bean id="connectionFactory"
    class="org.springframework.jms.connection.CachingConnectionFactory">
    <constructor-arg ref="amqConnectionFactory" />  
    <property name="sessionCacheSize" value="100" />
</bean>

<bean id="jmsTemplateForProduct" class="org.springframework.jms.core.JmsTemplate"
    p:defaultDestinationName="Click.Queue.Product">
    <constructor-arg ref="connectionFactory" /> 
</bean>

<bean id="jmsTemplateForPayment" class="org.springframework.jms.core.JmsTemplate"
    p:defaultDestinationName="Click.Queue.Payment">
    <constructor-arg ref="connectionFactory" /> 
</bean>

<jms:listener-container concurrency="10">
    <jms:listener id="ProductListener" destination="Click.Queue.Product"
        ref="productListener" />
</jms:listener-container>

<jms:listener-container concurrency="10">
    <jms:listener id="PaymentListener" destination="Click.Queue.Payment"
        ref="paymentListener" />
</jms:listener-container>
<!-- ActiveMQ ends -->

Answer 1

嗯，我自己解决了这个问题。顺便说一句，感谢 jkysam 的评论。

该问题是由于多次加载applicationContext而发生的。因此，每当加载 applicationContext 时，都会创建 kaha db 的新实例并导致锁定。

我所做的是将jms相关配置从applicationContext中分离出来。因此，我创建了一个名为 jmsContext.xml 的新上下文 xml 文件，并将 jms（以及 activemq）相关配置行移至该文件。然后在我的测试类中，我加载了不同的上下文 xml，具体取决于它是否是 jmsTest。

例如;我有两个 GenericUnitTest 类来分隔上下文配置。第一个是：

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"/jmsContext.xml"})
public abstract class GenericJmsUnitTest {  
}   

第二个是：

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"/applicationContext.xml"})
public abstract class GenericUnitTest { 
}   

然后我根据测试用例扩展这些类。这是例子；

public class ProductQueueTest extends GenericJmsUnitTest{  
@Autowired
private ProductQueueService productQueueService;

@Test
    public void productTest() {   
     productQueueService.sendProduct(); 
    }
}

非jms测试类示例是：

public class SchedularTest extends GenericUnitTest {
    @Autowired
    private Processor schedulerProcessor;

    @Test
     public void scheduleForProduct() {
        schedulerProcessor.processForProducts();
    }
}

顺便说一句，我在applicationContext.xml中排除了与队列有关的组件扫描过滤器，并将它们包含在jmsContext.xml中。这是例子；

applicationContext xml如下

  <上下文：排除过滤器类型=“正则表达式”表达式=“com.project.queue.*”/>
  <上下文：排除过滤器类型=“正则表达式”表达式=“com.project.test.queue.*”/>

jmsContext xml如下

 >
 >

Answer 2

Kaha 是 ActiveMQ 的持久性存储，它有一个锁定文件，可防止多个 AMQ 进程访问它同时。在干净退出时，此锁将始终被删除，但如果由于任何原因该过程未正确完成，则可能不会删除该锁。此外，如果您运行多个代理，它们可能会默认为相同的 Kaha 位置（在您的情况下为 \tmp\kahadb），并且其中之一将无法到达商店。有关重新配置位置的方法，请参阅 Kaha 链接。

如果这些场景都不适合您的情况，您可能会遇到代理的合法问题，但您需要提供有关如何使锁定检查代码失败的更多详细信息。