SpringBoot集成JmsTemplate(队列模式和主题模式)及xml和JavaConfig配置详解

一、概述

本文将详细介绍如何在SpringBoot应用程序中使用JmsTemplate集成队列模式和主题模式。本文将提供XML和JavaConfig两种配置方式。我们将从简单的应用程序开始，使用单个生产者和单个队列或主题。然后，我们将更改为多个生产者和多个队列和主题。通过本文，您将了解如何在SpringBoot应用程序中集成消息传递，以便实现单个或分布式系统之间的通信。

二、单个生产者和队列模式

1.添加依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

2.添加Queue

我们添加一个简单的队列，名为“jms.queue”。您可以在ActiveMQ控制台中创建。或者，您可以在您的应用程序中使用以下XML配置创建：

<bean id="queue" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg value="jms.queue"/>
</bean>

3.配置ConnectionFactory

@Bean
public ActiveMQConnectionFactory connectionFactory(){
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
    connectionFactory.setBrokerURL("tcp://localhost:61616");
    connectionFactory.setUserName("admin");
    connectionFactory.setPassword("admin");
    return connectionFactory;
}

4.配置JmsTemplate

@Bean
public JmsTemplate jmsTemplate(){
    JmsTemplate jmsTemplate = new JmsTemplate();
    jmsTemplate.setConnectionFactory(connectionFactory());
    jmsTemplate.setDefaultDestinationName("jms.queue");
    return jmsTemplate;
}

在JmsTemplate中配置ConnectionFactory和队列。这是使用队列传输消息的基本配置。您现在可以使用@Autowire标记将JmsTemplate注入您的任何SpringBean中。

5.编写测试类

@SpringBootTest
class JmsConfigTest {

    @Autowired
    JmsTemplate jmsTemplate;

    @Test
    void testSend() {
        jmsTemplate.convertAndSend("Hello, JMS!");
    }
}

这个测试将发送“Hello, JMS！”消息并在控制台上打印出“INFO”级别的消息。

三、单个生产者和主题模式

1.添加Topic

我们添加一个简单的主题，名为“jms.topic”。您可以在ActiveMQ控制台中创建。或者，您可以在您的应用程序中使用以下XML配置创建：

<bean id="topic" class="org.apache.activemq.command.ActiveMQTopic">
    <constructor-arg value="jms.topic"/>
</bean>

2.更改JmsTemplate配置

@Bean
public JmsTemplate jmsTemplateTopic(){
    JmsTemplate jmsTemplate = new JmsTemplate();
    jmsTemplate.setConnectionFactory(connectionFactory());
    jmsTemplate.setDefaultDestinationName("jms.topic");
    jmsTemplate.setPubSubDomain(true);
    return jmsTemplate;
}

更改默认目标名和设置setPubSubDomain参数以启用主题模式。您现在可以使用@Autowire标记将JmsTemplate注入您的任何SpringBean中。

3.编写测试类

@SpringBootTest
class JmsConfigTest {

    @Autowired
    JmsTemplate jmsTemplateTopic;

    @Test
    void testSend() {
        jmsTemplateTopic.convertAndSend("Hello, JMS!");
    }
}

这个测试将发送“Hello, JMS！” 消息并在控制台上打印出“INFO”级别的消息。

四、多个生产者和队列模式/主题模式

1.添加配置

为了支持多个生产者和多个队列/主题，我们需要添加一些配置，以便每个生产者都可以向不同的队列或主题发送消息。在这里，我们提供XML配置和JavaConfig配置选择。

2.XML配置示例

<bean id="messageProduceService1" class="com.example.service.MessageProduceService">
    <property name="jmsTemplate" ref="jmsTemplateForQueue1"/>
</bean>
<bean id="jmsTemplateForQueue1" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="defaultDestinationName" value="jms.queue1"/>
</bean>
<bean id="messageProduceService2" class="com.example.service.MessageProduceService">
    <property name="jmsTemplate" ref="jmsTemplateForQueue2"/>
</bean>
<bean id="jmsTemplateForQueue2" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="defaultDestinationName" value="jms.queue2"/>
</bean>

我们在这个配置文件中定义了两个MessageProduceService和JmsTemplate实例。这些实例分别被注入了名为jms.queue1和jms.queue2的队列。您可以根据需要添加更多的实例和配置。

3.JavaConfig配置示例

@Configuration
public class JmsConfiguration {

    @Bean
    public MessageProduceService messageProduceService1(){
        MessageProduceService messageProduceService = new MessageProduceService();
        messageProduceService.setJmsTemplate(jmsTemplate1());
        return messageProduceService;
    }

    @Bean
    public MessageProduceService messageProduceService2(){
        MessageProduceService messageProduceService = new MessageProduceService();
        messageProduceService.setJmsTemplate(jmsTemplate2());
        return messageProduceService;
    }

    @Bean
    public JmsTemplate jmsTemplate1(){
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(connectionFactory());
        jmsTemplate.setDefaultDestinationName("jms.queue1");
        return jmsTemplate;
    }

    @Bean
    public JmsTemplate jmsTemplate2(){
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(connectionFactory());
        jmsTemplate.setDefaultDestinationName("jms.queue2");
        return jmsTemplate;
    }
}

这个JavaConfig文件中定义了与XML配置文件中相同的两个MessageProduceService和JmsTemplate实例。您可以根据需要添加更多的实例和配置。

五、结论

JmsTemplate是SpringBoot应用程序中使用JMS的最佳选择之一。它可以显着减少冗余的代码和配置。本文讨论了如何在SpringBoot应用程序中使用JmsTemplate实现队列模式和主题模式，并提供了使用XML和JavaConfig两种配置实现多个生产者和多个队列/主题的示例。