ActiveMQ與Spring消息接收方式

同步接收

jmsTemplate.receive()

一個線程在工作，沒接收到就等待，接收到了就往下執(zhí)行直到程序結(jié)束;

如果想循環(huán)不斷地接收，那么就寫個while true循環(huán)。

異步接收

使用監(jiān)聽器監(jiān)聽ActiveMQ目的地，當有消息的時候，回調(diào)onMessage方法對消息進行處理，ActiveMQ與Spring集成異步接收消息的步驟如下：

1、創(chuàng)建普通的maven項目，異步接收消息模塊12-activemq-spring-receiver-async

2、在pom.xml文件中添加依賴(可以從前面receiver項目中拷貝)

3、配置applicationContext.xml

這里不需要掃描包了，只需要導(dǎo)入jms的配置即可

<import resource="applicationContext-jms.xml"/>

4、配置applicationContext-jms.xml

JmsTemplate只給我們提供了同步接收的方法，所以這里我們不需要對其進行配置。

!-- 配置一個連接工廠 -->
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="tcp://192.168.235.128:61616"/>
</bean>
<!-- 配置一個sping監(jiān)聽器的容器 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <!--引用連接工廠-->
    <property name="connectionFactory" ref="connectionFactory"/>
    <!--指定監(jiān)聽的目的地-->
    <property name="destinationName" value="springQueue"/>
    <!--監(jiān)聽到消息后，會回調(diào)onMessage方法，我們在自定義的監(jiān)聽器中對onMessage方法進行重寫，完成消息的接收-->
    <property name="messageListener" ref="myMessageListener" />
</bean>
<!-- 我們自定義的一個消息監(jiān)聽器 -->
<bean id="myMessageListener" class="com.bjpowernode.activemq.listener.MyMessageListener" />

5、創(chuàng)建自定義監(jiān)聽器，實現(xiàn)MessageListener接口，并在實現(xiàn)的onMessage方法中接收消息

ublic class MyMessageListener implements MessageListener{
    public void onMessage(Message message) {
        if(message instanceof TextMessage){
            try {
                String text = ((TextMessage) message).getText();
                System.out.println("監(jiān)聽器異步接收到的消息為：" + text);
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }
}

6、編寫測試類Test進行測試

public class Test {
    public static void main(String[] args) {
        //這里只需要啟動Spring容器，就會創(chuàng)建監(jiān)聽器對象
        new ClassPathXmlApplicationContext("classpath:applicationContext.xml");
    }
}

7、運行測試

程序啟動后，會一直處于監(jiān)聽狀態(tài)，堅挺到消息，會對其進行處理。