JMS ActiveMQ 和 Netbeans答案

【问题标题】：JMS ActiveMQ and NetbeansJMS ActiveMQ 和 Netbeans
【发布时间】：2019-01-03 04:29:57
【问题描述】：

我来这里是为了询问有关 JMS 的一些信息。我正在使用 Netbeans 和 ActiveMQ 来制作一个简单的主题并订阅

在实验课上，我们只开发了一个消费者（因为教授已经创建了一个服务器），但在我家，我需要生产者和消费者来制作一些东西。

我从这个例子开始https://javainsider.wordpress.com/tag/jms-with-activemq-sample-example/

我在 Netbeans 中为 Producer 创建了一个 Java Web 应用程序并使用它。在我为消费者创建 Java 应用程序之后。我们午餐（服务器和客户端）我只收到这条消息

" INFO | 成功连接到 tcp://localhost:61616"

所以我知道我在创建项目时出错了。如果我在 ActiveMQ 的 localost 中看到，在队列中我什么都没有。

任何人都可以帮助我解决这些问题。谢谢，

【问题讨论】：

标签： netbeans jms

【解决方案1】：

您使用的是哪个框架？

如果您使用的是 spring 框架工作，您需要在应用程序上下文文件中创建连接。

您可以使用以下代码作为参考。（我用的是队列而不是主题）

用于设置生产者：

 <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616"/>
    </bean>
    <bean id="ExportQueue" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg value="ExportQueue"/>
    </bean>
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory"/>
        <property name="receiveTimeout" value="10000"/>
    </bean>  
    <bean id="JMSExportProducer" class="com.krawler.spring.accounting.jms.JMSExportProducer">
        <property name="jmsTemplate" ref="jmsTemplate"/>
    </bean>

对于消费者：

<bean id="JMSExportConsumer" class="com.krawler.spring.accounting.reports.JMSExportConsumer">
        <property name="destination" ref="ExportQueue"/>
        <property name="jmsTemplate" ref="jmsTemplate"/>
 </bean>

    <bean id="jmsExportContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="concurrentConsumers">
            <value>25</value>
        </property>
        <property name="connectionFactory" ref="connectionFactory"/>
        <property name="destination" ref="ExportQueue"/>
        <property name="messageListener" ref="JMSExportConsumer"/>
    </bean>

【讨论】：