ActiveMQ (三) Spring整合JMS入门

时间：2023-03-09 16:00:03
ActiveMQ (三) Spring整合JMS入门

Spring整合JMS入门

前提：安装好了ActiveMQ  ActiveMQ安装

Demo结构：

ActiveMQ (三) Spring整合JMS入门  ActiveMQ (三) Spring整合JMS入门

生产者项目springjms_producer：

pom.xml

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0"

         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <parent>

        <artifactId>project_demo</artifactId>

        <groupId>com.zy</groupId>

        <version>1.0-SNAPSHOT</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>springjms_producer</artifactId>

    <dependencies>

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-jms</artifactId>

            <version>4.3.2.RELEASE</version>

        </dependency>

        <dependency>

            <groupId>org.apache.activemq</groupId>

            <artifactId>activemq-client</artifactId>

            <version>5.13.4</version>

        </dependency>

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-test</artifactId>

            <version>4.3.2.RELEASE</version>

        </dependency>

        <dependency>

            <groupId>junit</groupId>

            <artifactId>junit</artifactId>

            <version>4.12</version>

        </dependency>

    </dependencies>

    <build>

        <plugins>

            <!-- java编译插件 -->

            <plugin>

                <groupId>org.apache.maven.plugins</groupId>

                <artifactId>maven-compiler-plugin</artifactId>

                <version>3.2</version>

                <configuration>

                    <source>1.8</source>

                    <target>1.8</target>

                    <encoding>UTF-8</encoding>

                </configuration>

            </plugin>

        </plugins>

    </build>

</project>

applicationContext-activemq-producer.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context"

       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

        http://www.springframework.org/schema/context

        http://www.springframework.org/schema/context/spring-context.xsd">

    <!--扫描提供者类 单元测试需要注入-->

    <context:component-scan base-package="com.zy.demo"></context:component-scan>

    <!-- 真正可以产生Connection的ConnectionFactory，由对应的 JMS服务厂商提供-->

    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

        <property name="brokerURL" value="tcp://192.168.25.128:61616"/>

    </bean>

    <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->

    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">

        <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->

        <property name="targetConnectionFactory" ref="targetConnectionFactory"/>

    </bean>

    <!-- Spring提供的JMS工具类，它可以进行消息发送、接收等 -->

    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">

        <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->

        <property name="connectionFactory" ref="connectionFactory"/>

    </bean>

    <!--这个是队列目的地，点对点的  文本信息-->

    <bean id="queueTextDestination" class="org.apache.activemq.command.ActiveMQQueue">

        <constructor-arg value="queue_text"/>

    </bean>

    <!--这个是订阅模式  文本信息-->

    <bean id="topicTextDestination" class="org.apache.activemq.command.ActiveMQTopic">

        <constructor-arg value="topic_text"/>

    </bean>

</beans>

点对点生产者QueueProducer：

package com.zy.demo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jms.core.JmsTemplate;

import org.springframework.jms.core.MessageCreator;

import org.springframework.stereotype.Component;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.Session;

/**

 * 点对点模式 生产者

 */

@Component

public class QueueProducer {

    @Autowired

    private JmsTemplate jmsTemplate;

    @Autowired

    private Destination queueTextDestination;

    /**

     * 发送文本消息

     *

     * @param text

     */

    public void sendTextMessage(final String text) {

        jmsTemplate.send(queueTextDestination, new MessageCreator() {

            public Message createMessage(Session session) throws JMSException {

                return session.createTextMessage(text);

            }

        });

    }

}

发布订阅生产者TopicProducer：

package com.zy.demo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jms.core.JmsTemplate;

import org.springframework.jms.core.MessageCreator;

import org.springframework.stereotype.Component;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.Session;

/**

 * 发布订阅模式 生产者

 */

@Component

public class TopicProducer {

    @Autowired

    private JmsTemplate jmsTemplate;

    @Autowired

    private Destination topicTextDestination;

    /**

     * 发送文本消息

     */

    public void sendTextMessage(String text) {

        jmsTemplate.send(topicTextDestination, new MessageCreator() {

            public Message createMessage(Session session) throws JMSException {

                return session.createTextMessage(text);

            }

        });

    }

}

点对点生产者单元测试QueueProducerTest：

package com.zy.demo;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.io.IOException;

import static org.junit.Assert.*;

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration("classpath:spring/applicationContext-activemq-consumer.xml")

public class QueueMessageListenerTest {

    @Test

    public void onMessage() throws Exception {

        try {

            System.in.read();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

}

发布订阅生产者单元测试TopicProducerTest：

package com.zy.demo;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import static org.junit.Assert.*;

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration("classpath:spring/applicationContext-activemq-producer.xml")

public class TopicProducerTest {

    @Autowired

    private TopicProducer topicProducer;

    @Test

    public void sendTextMessage() throws Exception {

        topicProducer.sendTextMessage("SpringJms发布订阅");

    }

}

消费者项目springjms_consumer：

pom.xml

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0"

         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <parent>

        <artifactId>project_demo</artifactId>

        <groupId>com.zy</groupId>

        <version>1.0-SNAPSHOT</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>springjms_consumer</artifactId>

    <dependencies>

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-jms</artifactId>

            <version>4.3.2.RELEASE</version>

        </dependency>

        <dependency>

            <groupId>org.apache.activemq</groupId>

            <artifactId>activemq-client</artifactId>

            <version>5.13.4</version>

        </dependency>

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-test</artifactId>

            <version>4.3.2.RELEASE</version>

        </dependency>

        <dependency>

            <groupId>junit</groupId>

            <artifactId>junit</artifactId>

            <version>4.12</version>

        </dependency>

    </dependencies>

</project>

applicationContext-activemq-consumer.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">

    <!-- 真正可以产生Connection的ConnectionFactory，由对应的 JMS服务厂商提供-->

    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

        <property name="brokerURL" value="tcp://192.168.25.128:61616"/>

    </bean>

    <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->

    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">

        <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->

        <property name="targetConnectionFactory" ref="targetConnectionFactory"/>

    </bean>

    <!--start-->

    <!--这个是队列目的地，点对点的  文本信息-->

    <bean id="queueTextDestination" class="org.apache.activemq.command.ActiveMQQueue">

        <constructor-arg value="queue_text"/>

    </bean>

    <!-- 我的监听类 -->

    <bean id="queueMessageListener" class="com.zy.demo.QueueMessageListener"></bean>

    <!-- 消息监听容器 -->

    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">

        <property name="connectionFactory" ref="connectionFactory"/>

        <property name="destination" ref="queueTextDestination"/>

        <property name="messageListener" ref="queueMessageListener"/>

    </bean>

    <!--end-->

    <!--start-->

    <!--这个是队列目的地，点对点的  文本信息-->

    <bean id="topicTextDestination" class="org.apache.activemq.command.ActiveMQTopic">

        <constructor-arg value="topic_text"/>

    </bean>

    <!-- 我的监听类 -->

    <bean id="topicMessageListener" class="com.zy.demo.TopicMessageListener"></bean>

    <!-- 消息监听容器 -->

    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">

        <property name="connectionFactory" ref="connectionFactory"/>

        <property name="destination" ref="topicTextDestination"/>

        <property name="messageListener" ref="topicMessageListener"/>

    </bean>

    <!--end-->

</beans>

点对点消费者QueueMessageListener：

package com.zy.demo;

import org.springframework.stereotype.Component;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.TextMessage;

/**

 * 点对点模式 消费者

 */

@Component

public class QueueMessageListener implements MessageListener {

    public void onMessage(Message message) {

        TextMessage textMessage = (TextMessage) message;

        try {

            System.out.println("接收到消息：" + textMessage.getText());

        } catch (JMSException e) {

            e.printStackTrace();

        }

    }

}

发布订阅消费者TopicMessageListener：

package com.zy.demo;

import org.springframework.stereotype.Component;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.TextMessage;

/**

 * 发布订阅模式 消费者

 */

@Component

public class TopicMessageListener implements MessageListener {

    public void onMessage(Message message) {

        TextMessage textMessage = (TextMessage) message;

        try {

            System.out.println("接收到消息：" + textMessage.getText());

        } catch (JMSException e) {

            e.printStackTrace();

        }

    }

}

点对点消费者单元测试QueueMessageListenerTest：

package com.zy.demo;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.io.IOException;

import static org.junit.Assert.*;

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration("classpath:spring/applicationContext-activemq-consumer.xml")

public class QueueMessageListenerTest {

    @Test

    public void onMessage() throws Exception {

        try {

            System.in.read();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

}

发布订阅消费者单元测试TopicMessageListenerTest：

package com.zy.demo;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.io.IOException;

import static org.junit.Assert.*;

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration("classpath:spring/applicationContext-activemq-consumer.xml")

public class TopicMessageListenerTest {

    @Test

    public void onMessage() throws Exception {

        try {

            System.in.read();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

}

相关文章