spring结合activemq使用

我就是我 2022-05-12 06:18 195阅读 0赞

### spring结合activemq使用 ###

依赖如下：

<dependency>
        <groupId>${spring.groupId}</groupId>
        <artifactId>spring-jms</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-all</artifactId>
        <version>5.9.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-pool</artifactId>
        <version>5.9.0</version>
    </dependency>
    <dependency>
        <groupId>xml-apis</groupId>
        <artifactId>xml-apis</artifactId>
        <version>1.4.01</version>
    </dependency>

### 发送和接收队列消息的配置： ###

发送和接收消息都是通过JmsTemplate类操作的。在JmsTemplate中有defaultDestination属性，表示默认的目的地，可以是队列也可以是Topic。当你配置了默认的destination后，在使用jmsTemplate发送消息不指定destination时就使用默认的destination。

发送消息的代码：

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    import org.springframework.jms.core.JmsTemplate;
    import org.springframework.jms.core.MessageCreator;
    import org.springframework.stereotype.Component;
    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.Session;
    import javax.jms.TextMessage;
    /** * @author j.tommy * @date 2017-04-06 17:59. */
    @Component
    public class QueueSendTest { 
        @Autowired
        private JmsTemplate jmsTemplate;
        public static void main(String[] args) {
            ApplicationContext ac = new ClassPathXmlApplicationContext("application*.xml");
            QueueSendTest qst = ac.getBean(QueueSendTest.class);
            qst.jmsTemplate.send(new MessageCreator() {
                @Override
                public Message createMessage(Session session) throws JMSException {
                    TextMessage msg = session.createTextMessage("Spring msg ===");
                    return msg;
                }
            });
        }
    }

接收消息的代码为：

先启动发送端，再启动接收端就可以接收到消息了。

### 发送和接收topic消息 ###

发送端的代码与队列一样。  
接收端：

import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.MessageListener;
    import javax.jms.TextMessage;
    /** * @author j.tommy * @date 2017-04-07 09:25. */
    public class MyMessageListener implements MessageListener { 
        @Override
        public void onMessage(Message message) {
            if (message instanceof TextMessage) {
                TextMessage tm = (TextMessage) message;
                try {
                    System.out.println("接收到消息：" + tm.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        }
    }

启动发送端就可以了。

说明：  
1.在JmsTemplate中配置了defaultDestination属性后，在发送时如果不指定destination将使用默认的。建议在发送时指定Destionation。  
如图：  
![15286607-file_1491529867099_167d1.png][]

2.最佳实践  
![4945873-file_1491530798315_4a18.png][]

3.最好不要使用failover，使用failover在broker异常时会阻塞住。使用spring的DefaultMessageListenerContainer会自动重连，如图：  
![1176236-file_1491546575125_62fb.png][]。failover能够在你配置了多个activemq时自动选择可用的broker，但broker异常会导致线程阻塞。如果一定要使用failover，比如就配置了一个activemq，建议数据放到队列，同时队列设置一定的容量，有专门的线程从队列取数据放入mq。

4.log4j日志级别不能配置error，否则spring和activemq的日志显示不了。

[15286607-file_1491529867099_167d1.png]: http://omh46px9n.bkt.clouddn.com/17-4-7/15286607-file_1491529867099_167d1.png
[4945873-file_1491530798315_4a18.png]: http://omh46px9n.bkt.clouddn.com/17-4-7/4945873-file_1491530798315_4a18.png
[1176236-file_1491546575125_62fb.png]: http://omh46px9n.bkt.clouddn.com/17-4-7/1176236-file_1491546575125_62fb.png