Apache Camel消息多路复用器集成模式

Question

我正在尝试确定使用ApacheCamel和Spring将来自两个hornetq broker实例的消息流组合成单个流进行处理的最佳方式。这本质上与驼峰接收列表模式相反；但我需要的不是一对多，而是多对一。一个想法是使用direct组件实现此功能：

<?xml version="1.0" encoding="UTF-8"/>
<beans xmlns="..."
       xmlns="...">

    <!-- JMS Connection 1 -->
    <bean id="jndiTemplate1" class="org.springframework.jndi.JndiTemplate">
        <property name="environment">
            <props>
                ...Connection 1 Specific Information...
            </props>
        </property>
    </bean>
    <bean id="jmsTopicConnectionFactory1" 
          class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate">
            <ref bean="jndiTemplate1"/>
        </property>
        <property name="jndiName">
            <value>java:jms/RemoteConnectionFactory</value> 
        </property>
    </bean>
    <bean id="jms1" class="org.apache.camel.component.jms.JmsComponent">
        <property name="connectionFactory" ref="jmsTopicConnectionFactory1"/>
    </bean>

    <!-- JMS Connection 2 -->
    <bean id="jndiTemplate2" class="org.springframework.jndi.JndiTemplate">
        <property name="environment">
            <props>
                ...Connection 2 Specific Information...
            </props>
        </property>
    </bean>
    <bean id="jmsTopicConnectionFactory2" 
          class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate">
            <ref bean="jndiTemplate2"/>
        </property>
        <property name="jndiName">
            <value>java:jms/RemoteConnectionFactory</value> 
        </property>
    </bean>
    <bean id="jms2" class="org.apache.camel.component.jms.JmsComponent">
        <property name="connectionFactory" ref="jmsTopicConnectionFactory2"/>
    </bean>

    <!-- Camel route many to 1 using direct component -->
    <camelContext xmlns="http://camel.apache.org/schema/spring">
        <route id="hornetQ_broker_1">
            <from uri="jms1:topic:testTopic1">
            <to uri="direct:process_message">
        </route>
        <route id="hornetQ_broker_2">
            <from uri="jms2:topic:testTopic2">
            <to uri="direct:process_message">
        </route>
        <route id="message_processor">
            <from uri="direct:process_message">
            <log message="message_processor received message">
        </route>
    </camelContext>
</beans>

问题：在许多情况下，是否建议采用上述方法-

运行时环境：

• HornetQ经纪人是JBoss EAP6

笔记：

• hornetQ代理实例不能集群。
• hornetQ代理实例不包含重复数据。

Answer 1

我认为你的方法适用于你的情况。但是，如果您在不同的JVM中运行，可能direct不是您需要使用的组件。

内部队列有不同的组件：直接、直接虚拟机、SEDA、虚拟机、干扰器...但是我相信如果你在JVM中运行，它们都是（如果你只是在同一个CamelContext中运行，其中一些也是）。有关更多信息：直接、事件、seda和vmendpoint如何比较

如果要在不同的JVM中使用不同的上下文，则需要使用不同的组件。