java – 简单的spring应用程序终止,除非调用Thread.sleep(…)

2019-07-08 18:27:56 阅读：240 来源： 互联网

标签：java multithreading spring apache-camel

我看到一些使用Spring和Apache Camel的非常简单的Java应用程序的奇怪行为.

我在我的应用程序上下文中定义了下面的spring bean：

<camel:camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">
    <camel:endpoint id="incoming" uri="activemq:queue:${myqueue}?jmsMessageType=Text" />
    <camel:route id="handleIncomingEvents" autoStartup="true" trace="true">
        <camel:from ref="incoming" />
        <camel:bean ref="transform" method="toEvent" />
        <camel:bean ref="eventConsumer" method="consumeEvent" />
    </camel:route>
</camel:camelContext>

这是一个单一路线的驼峰环境.据我所知,当创建bean时,将启动一个新线程,该线程侦听传入的消息并将它们路由到我的eventConsumer.

我的应用程序的起点很简单：

public static void main(String[] args) {     
    ApplicationContext context = new ClassPathXmlApplicationContext("application-context.xml");
}

问题是：

当我运行上面的简单应用程序时,日志输出显示camel上下文和路由已成功初始化,但随后应用程序立即终止.

但是,如果在初始化应用程序上下文后添加Thread.sleep(1000),则应用程序永远不会终止.这是我期望的行为,因为创建了一个新线程来监听传入的消息.

为什么我需要调用Thread.sleep来实现预期的行为？

这显然不是正确的方法 – 我做错了什么？

编辑[1]：日志中没有任何异常.无论是否调用Thread.sleep(1000),都会生成以下日志输出.

29 [main] INFO org.apache.camel.spring.handler.CamelNamespaceHandler - OSGi environment not detected.
1473 [main] INFO org.apache.camel.spring.SpringCamelContext - Apache Camel 2.9.0 (CamelContext: camelContext) is starting
1474 [main] INFO org.apache.camel.management.ManagementStrategyFactory - JMX enabled. Using ManagedManagementStrategy.
1541 [main] INFO org.apache.camel.management.DefaultManagementLifecycleStrategy - StatisticsLevel at All so enabling load performance statistics
1618 [main] INFO org.apache.camel.impl.converter.AnnotationTypeConverterLoader - Found 3 packages with 15 @Converter classes to load
1637 [main] INFO org.apache.camel.impl.converter.DefaultTypeConverter - Loaded 168 core type converters (total 168 type converters)
1650 [main] INFO org.apache.camel.impl.converter.AnnotationTypeConverterLoader - Found 2 packages with 3 @Converter classes to load
1651 [main] WARN org.apache.camel.impl.converter.DefaultTypeConverter - Overriding type converter from: StaticMethodTypeConverter: public static org.apache.activemq.command.ActiveMQDestination org.apache.activemq.camel.converter.ActiveMQConverter.toDestination(java.lang.String) to: StaticMethodTypeConverter: public static org.apache.activemq.command.ActiveMQDestination org.apache.camel.component.activemq.ActiveMQConverter.toDestination(java.lang.String)
1664 [main] INFO org.apache.camel.impl.converter.DefaultTypeConverter - Loaded additional 3 type converters (total 171 type converters) in 0.025 seconds
1946 [main] INFO org.apache.camel.spring.SpringCamelContext - Route: handleIncomingEvents started and consuming from: Endpoint[activemq://queue:myqueue?jmsMessageType=Text]
1958 [main] INFO org.apache.camel.spring.SpringCamelContext - Total 1 routes, of which 1 is started.
1958 [main] INFO org.apache.camel.spring.SpringCamelContext - Apache Camel 2.9.0 (CamelContext: camelContext) started in 0.485 seconds

编辑[2]：我正在使用这个ActiveMQ配置：

<bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager">
    <property name="connectionFactory" ref="pooledConnectionFactory" />
</bean>

<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
    destroy-method="stop">
    <property name="maxConnections" value="8" />
    <property name="maximumActive" value="500" />
    <property name="connectionFactory">
        <bean class="org.apache.activemq.ActiveMQConnectionFactory">
            <property name="brokerURL" value="tcp://localhost:61616" />
            <property name="closeTimeout" value="10" />
        </bean>
    </property>
</bean>

<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory" />
    <property name="transacted" value="true" />
    <property name="transactionManager" ref="jmsTransactionManager" />
    <property name="concurrentConsumers" value="10" />
</bean>

<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="configuration" ref="jmsConfig" />
</bean>

<bean id="jmsConfigRetry" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory" />
    <property name="transacted" value="true" />
    <property name="transactionManager" ref="jmsTransactionManager" />
    <property name="concurrentConsumers" value="1" />
</bean>

<bean id="activemqretry" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="configuration" ref="jmsConfigRetry" />
</bean>

解决方法:

您没有在问题中提供ActiveMQ设置.对于测试,我使用以下设置：

<!-- This creates an embedded ActiveMQ broker -->
<broker xmlns="http://activemq.apache.org/schema/core" useJmx="true" persistent="false">
    <transportConnectors>
        <transportConnector uri="tcp://localhost:61616" />
    </transportConnectors>
</broker>

<!-- Lets connect the Camel ActiveMQ component to the embedded broker -->
<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="brokerURL" value="failover:tcp://localhost:61616" />
</bean>

如果配置成功,您应该看到以下日志：

[ActiveMQ Task-1] FailoverTransport INFO  Successfully connected to tcp://localhost:61616

也许,您可以尝试此设置并测试它是否有效.

标签：java,multithreading,spring,apache-camel
来源： https://codeday.me/bug/20190708/1404881.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java – 简单的spring应用程序终止,除非调用Thread.sleep(…)