java - 将 ActiveMQ 与 Tomcat 集成

Question

我正在寻找有关将 activemq 与 tomcat 集成的技巧。

我的架构如下所示，其中每个应用程序都在不同的 jvm/机器上运行，

生产者应用 -> tomcat (activemq) -> 消费者应用

消费者和生产者应该连接到远程机器上的 activemq。我还想启用 Web 控制台。

Answer 1

首先您应该在远程计算机上下载并安装 ActiveMQ，Web 控制台将默认启用。

其次，您应该配置每个 tomcat 节点。

将 activemq-all.jar(5.11 及更高版本，您可以在此处下载 http://mvnrepository.com/artifact/org.apache.activemq/activemq-all )放入 $TOMCAT_HOME/lib 文件夹。ActiveMQ 已为其所有受管理对象准备好 JNDI 资源工厂:ConnectionFactory 和目的地。您必须将其作为资源的参数工厂提供:

添加到$TOMCAT_HOME/CONF/context.xml

<Resource name="jms/activemq-factory" 
        auth="Container" 
        type="org.apache.activemq.ActiveMQConnectionFactory" 
        description="JMS Connection Factory" 
        factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
        brokerURL="tcp://${broker.host}:${broker.port}" 
        brokerName="LocalActiveMQBroker" 
        useEmbeddedBroker="false"/>

<Resource name="jms/activemq-topic" 
            auth="Container" 
            type="org.apache.activemq.command.ActiveMQTopic" 
            factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
            physicalName="activemq-topic"/> 

将 broker.host 和 broker.port 替换为真正的 ActiveMQ 参数。

现在您可以为 activevemq-topic 编写消费者。就这些。