ActiveMQ进阶篇-整合Spring

谁借莪１个温暖的怀抱￠ 2023-07-04 08:36 19阅读 0赞

### spring整合activemq ###

#### 添加pom文件 ####

<dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context</artifactId>
    </dependency>

添加spring的配置文件 application.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    
        <bean id="getConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
            <property name="brokerURL" value="tcp://127.0.0.1:61616" />
        </bean>
    
        
        <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
            
            <property name="targetConnectionFactory" ref="getConnectionFactory" />
        </bean>
    
    
        
        
        <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
            
            <property name="connectionFactory" ref="connectionFactory" />
        </bean>
    
    
        
        <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
            <constructor-arg>
                <value>spring-queue-demo</value>
            </constructor-arg>
        </bean>
    
    
        
        
        <bean id="queueConsumer" class="com.zero.day3.QueueConsumer" />
        
        <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="connectionFactory" />
            <property name="destination" ref="queueDestination" />
            <property name="messageListener" ref="queueConsumer" />
        </bean>
    
    
    </beans>

#### 生产者 ####

package com.zero.day3;
    
    import org.apache.xbean.spring.context.ClassPathXmlApplicationContext;
    import org.springframework.jms.core.JmsTemplate;
    import org.springframework.jms.core.MessageCreator;
    
    import javax.jms.*;
    
    /** * spring整合ActiveMQ 生产者 */
    public class QueueProducer{ 
    
    
    
    
    
    
        public static void main(String[] args) { 
    
                QueueProducer queueProducer = new QueueProducer();
                queueProducer.producerQueue();
    
        }
    
        public  void producerQueue () { 
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("application.xml");
            JmsTemplate jmsTemplate = context.getBean(JmsTemplate.class);
            Destination queueDestination = (Destination)context.getBean("queueDestination");
            jmsTemplate.send(queueDestination, new MessageCreator() { 
                public Message createMessage(Session session) throws JMSException { 
    
                    TextMessage textMessage = session.createTextMessage();
                    textMessage.setText("hello spring整合actviceMQ");
                    System.out.println("生产者启动成功,发送的消息为:" + textMessage.getText());
                    return textMessage;
                }
            });
    
        }
    
    
    }

#### 消费者 ####

package com.zero.day3;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.MessageListener;
    import javax.jms.TextMessage;
    import javax.xml.soap.Text;
    import java.io.IOException;
    
    /**
     * spring整合ActviceMQ 消费者
     */
    public class QueueConsumer implements MessageListener {
        public void onMessage(Message message) {
            TextMessage textMessage = (TextMessage)message;
            try {
                System.out.println("消费者接收到的消息：" + textMessage.getText());
            } catch (JMSException e) {
                e.printStackTrace();
            }
    
        }
    
        public static void main(String[] args) {
            //初始化spring容器
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("application.xml");
            //等待
            try {
                System.in.read();
    
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

#### 查看生产消费情况 ####

![在这里插入图片描述][20200209141814721.png]

#### 后台管理系统查看消费情况 ####

![在这里插入图片描述][20200209141839562.png]

#### 结语 ####

小编是一枚Java Coder，业余写文章，现主营微信公众号《Java患者》，喜欢的话关注我的公众号或者加我微信我们一起学习Java  
![在这里插入图片描述][2020020914110598.jpg]

[20200209141814721.png]: https://img-blog.csdnimg.cn/20200209141814721.png
[20200209141839562.png]: https://img-blog.csdnimg.cn/20200209141839562.png
[2020020914110598.jpg]: https://img-blog.csdnimg.cn/2020020914110598.jpg