SpringBoot Camel ActiveMQ 嵌入式代理停止并意外重启

Question

我的 SpringBoot Camel 应用程序有问题。

它与非嵌入式代理配合得很好。这是它的配置： URL 作为指向独立 ActiveMQ 服务器或嵌入式代理的字符串给出 URL (vm://dpcgbroker?broker.persistent=false)

@Configuration
public class CamelConfiguration {

@Value("${broker.mqURL}")
String mqURL;


@Bean
CamelContextConfiguration contextConfiguration() {
    return new CamelContextConfiguration() {
        @Override
        public void beforeApplicationStart(CamelContext context) {


            ActiveMQComponent activeMQComponent =  ActiveMQComponent.activeMQComponent(mqURL);
            activeMQComponent.setConfiguration(getJmsConfiguration());

            context.addComponent("jms", activeMQComponent);

            DefaultShutdownStrategy shutdownStrategy = new DefaultShutdownStrategy();
        shutdownStrategy.setTimeUnit(TimeUnit.SECONDS);
            shutdownStrategy.setTimeout(20);
            context.setShutdownStrategy(shutdownStrategy);
        }



        @Override
        public void afterApplicationStart(CamelContext camelContext) {

        }


    };
}


public PooledConnectionFactory getPooledConnectionFactory() {
    PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory(getConnectionFactory());

    pooledConnectionFactory.setMaxConnections(30);

    return pooledConnectionFactory;
}

public ActiveMQConnectionFactory getConnectionFactory() {
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
    connectionFactory.setBrokerURL(mqURL);
    connectionFactory.setTrustAllPackages(true);
    return connectionFactory;
}


public JmsConfiguration getJmsConfiguration() {
    JmsConfiguration jmsConfiguration = new JmsConfiguration();
    jmsConfiguration.setDisableTimeToLive(true);
    jmsConfiguration.setTransacted(true);
    jmsConfiguration.setLazyCreateTransactionManager(false);
    jmsConfiguration.setConnectionFactory(getConnectionFactory());
    jmsConfiguration.setCacheLevelName("CACHE_CONSUMER");
    return jmsConfiguration;
}



@Bean
@Scope(value = ConfigurableBeanFactory.SCOPE_SINGLETON)
public PlatformTransactionManager getTransactionManager() {

    PlatformTransactionManager platformTransactionManager = new JmsTransactionManager(getConnectionFactory());
    return platformTransactionManager;
}

当我切换到嵌入式代理时，行为有所不同，Apache ActiveMQ 启动然后停止，然后重新启动。我不知道为什么，也没有例外

这是日志的摘录

15967 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Using Persistence Adapter: MemoryPersistenceAdapter
15991 INFO  - 5063 -  [JMX connector] org.apache.activemq.broker.jmx.ManagementContext     - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
16106 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Apache ActiveMQ 5.15.2 (dpcgbroker, ID:Greg.local-59246-1525440325893-0:1) is starting
16111 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Apache ActiveMQ 5.15.2 (dpcgbroker, ID:Greg.local-59246-1525440325893-0:1) started
16111 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - For help or more information please see: http://activemq.apache.org
16132 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.TransportConnector     - Connector vm://dpcgbroker started
16205 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.TransportConnector     - Connector vm://dpcgbroker stopped
16205 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Apache ActiveMQ 5.15.2 (dpcgbroker, ID:Greg.local-59246-1525440325893-0:1) is shutting down
16213 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Apache ActiveMQ 5.15.2 (dpcgbroker, ID:Greg.local-59246-1525440325893-0:1) uptime 0.274 seconds
16213 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Apache ActiveMQ 5.15.2 (dpcgbroker, ID:Greg.local-59246-1525440325893-0:1) is shutdown
16618 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.camel.processor.aggregate.AggregateProcessor     - Defaulting to MemoryAggregationRepository
16621 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.camel.processor.aggregate.AggregateProcessor     - Using CompletionTimeout to trigger after 10 millis of inactivity.
16647 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.camel.spring.SpringCamelContext     - Skipping starting of route jobStatusRoute as its configured with autoStartup=false
16656 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Using Persistence Adapter: MemoryPersistenceAdapter
16656 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Apache ActiveMQ 5.15.2 (dpcgbroker, ID:Greg.local-59246-1525440325893-0:2) is starting
16657 INFO  - 5063 -  [JMX connector] org.apache.activemq.broker.jmx.ManagementContext     - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
16657 INFO  - 5063 -  [Camel (camel-1) thread #1 - file://conf/DR3/planets/] org.apache.activemq.broker.BrokerService     - Apache ActiveMQ 5.15.2 (dpcgbroker, ID:Greg.local-59246-1525440325893-0:2) started

问题是在代理的第一个实例中发送的一些消息在代理停止时丢失，然后第二个实例以空消息列表开始。我不知道为什么它会停止。

PS：我不想使用持久的嵌入式代理，这是无用的解决方法

Answer 1

过了一会儿我明白发生了什么。整个事情是嵌入式 vm 代理有一个特殊的行为，在 documentation 中描述

Once all VM connections to the broker have been closed, the embedded broker will automatically shutdown.

我的应用程序正在启动，然后发送消息，然后启动消费者。当我发送消息时，连接被关闭，导致代理关闭。

所以解决方案就是先启动消费者，然后让生产者发布消息。

PS：一个可能有用的解决方法是使用 PooledConnectionFactory。我测试过它也可以工作，因为我猜池会保持连接处于活动状态。使用这些技巧，您可以按照您喜欢的任何顺序启动生产者和消费者

SpringBoot Camel ActiveMQ 嵌入式代理停止并意外重启

SpringBoot Camel ActiveMQ Embedded broker stopping and restarting unexpectedly

java

activemq

spring-camel