详解Springboot整合ActiveMQ（Queue和Topic两种模式）

以下是“详解Springboot整合ActiveMQ（Queue和Topic两种模式）”的完整攻略，包含两个示例说明。

简介

ActiveMQ是一个流行的开源消息队列系统，它支持多种消息传递模式，包括点对点（Queue）和发布/订阅（Topic）。在本教程中，我们将介绍如何使用Spring Boot整合ActiveMQ，并演示如何使用Queue和Topic两种模式发送和接收消息。

示例1：使用Queue模式发送和接收消息

以下是一个使用Queue模式发送和接收消息的示例：

1. 添加依赖

在pom.xml文件中添加以下依赖：

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

2. 配置ActiveMQ

在application.properties文件中添加以下配置：

spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin

在这个示例中，我们指定了ActiveMQ服务器的URL、用户名和密码。

3. 创建消息发送者

创建一个名为MessageSender的类，用于发送消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

@Component
public class MessageSender {

    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendMessage(String message) {
        jmsTemplate.convertAndSend("test.queue", message);
    }
}

在这个示例中，我们使用JmsTemplate类发送消息到名为test.queue的队列。

4. 创建消息接收者

创建一个名为MessageReceiver的类，用于接收消息：

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class MessageReceiver {

    @JmsListener(destination = "test.queue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在这个示例中，我们使用@JmsListener注解监听名为test.queue的队列，并在接收到消息时打印消息内容。

5. 发送和接收消息

在Application类中添加以下代码：

@SpringBootApplication
public class Application implements CommandLineRunner {

    @Autowired
    private MessageSender messageSender;

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

    @Override
    public void run(String... args) throws Exception {
        messageSender.sendMessage("Hello, world!");
    }
}

在这个示例中，我们在Application类的run方法中调用MessageSender类的sendMessage方法发送消息。

6. 运行应用程序

使用以下命令运行应用程序：

mvn spring-boot:run

现在，您可以在控制台中看到Received message: Hello, world!的输出，表示已成功接收到消息。

示例2：使用Topic模式发送和接收消息

以下是一个使用Topic模式发送和接收消息的示例：

1. 创建消息发送者

创建一个名为TopicMessageSender的类，用于发送消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

@Component
public class TopicMessageSender {

    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendMessage(String message) {
        jmsTemplate.convertAndSend("test.topic", message);
    }
}

在这个示例中，我们使用JmsTemplate类发送消息到名为test.topic的主题。

2. 创建消息接收者

创建一个名为TopicMessageReceiver的类，用于接收消息：

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class TopicMessageReceiver {

    @JmsListener(destination = "test.topic", containerFactory = "topicListenerFactory")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在这个示例中，我们使用@JmsListener注解监听名为test.topic的主题，并在接收到消息时打印消息内容。

3. 配置主题监听器

在Application类中添加以下配置：

@SpringBootApplication
@EnableJms
public class Application {

    @Bean
    public JmsListenerContainerFactory<?> topicListenerFactory(ConnectionFactory connectionFactory,
                                                               DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        configurer.configure(factory, connectionFactory);
        factory.setPubSubDomain(true);
        return factory;
    }

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

在这个示例中，我们使用@EnableJms注解启用JMS支持，并创建一个名为topicListenerFactory的Bean，用于配置主题监听器。

4. 发送和接收消息