spring boot学习笔记之操作ActiveMQ指南

下面是对“Spring Boot学习笔记之操作ActiveMQ指南”的详细讲解。

一、前言

ActiveMQ是一个流行的消息队列中间件，它支持多种协议和语言，并且具有可扩展性、高可用性、高吞吐量等特点。本文将介绍如何在Spring Boot项目中使用ActiveMQ进行消息传递，以及使用示例说明。

二、配置ActiveMQ

首先，在Spring Boot项目中引入ActiveMQ的依赖：

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

然后，在application.properties中添加ActiveMQ的配置：

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

三、发送消息

要发送消息，我们需要一个消息队列。在Spring Boot中，我们可以使用spring-boot-starter-activemq中提供的JmsTemplate来完成消息的发送。

首先，在配置类中配置一个JmsTemplate bean：

@Configuration
public class JmsConfig {

    @Bean
    public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory) {
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(connectionFactory);
        return jmsTemplate;
    }

}

然后，在服务类中使用JmsTemplate发送消息：

@Service
public class MessageService {

    private JmsTemplate jmsTemplate;

    public MessageService(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    public void sendMessage(String message) {
        jmsTemplate.send("test.queue", (session) -> {
            return session.createTextMessage(message);
        });
    }

}

上面的代码中，我们使用JmsTemplate.send()方法发送消息到名为“test.queue”的消息队列中，其中Lambda表达式(session) -> session.createTextMessage(message)用于创建一个文本消息。

四、接收消息

要接收消息，我们需要一个消息监听器。在Spring Boot中，我们可以使用spring-boot-starter-activemq中提供的@JmsListener注解来创建一个消息监听器。

首先，在服务类中添加一个@JmsListener注解：

@Service
public class MessageService {

    ...

    @JmsListener(destination = "test.queue")
    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            TextMessage textMessage = (TextMessage) message;
            try {
                System.out.println("Received message: " + textMessage.getText());
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }

}

上面的代码中，我们使用@JmsListener注解来监听“test.queue”队列，并定义了一个onMessage()方法来处理接收到的消息。

五、完整示例

下面是一个完整的Spring Boot项目示例，展示如何使用ActiveMQ发送和接收消息：

@SpringBootApplication
public class Application {

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

    @Bean
    public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory) {
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(connectionFactory);
        return jmsTemplate;
    }

    @Service
    public class MessageService {

        private JmsTemplate jmsTemplate;

        public MessageService(JmsTemplate jmsTemplate) {
            this.jmsTemplate = jmsTemplate;
        }

        public void sendMessage(String message) {
            jmsTemplate.send("test.queue", (session) -> {
                return session.createTextMessage(message);
            });
        }

        @JmsListener(destination = "test.queue")
        public void onMessage(Message message) {
            if (message instanceof TextMessage) {
                TextMessage textMessage = (TextMessage) message;
                try {
                    System.out.println("Received message: " + textMessage.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        }

    }

}

我们可以使用MessageService的sendMessage()方法发送消息，使用@JmsListener注解监听“test.queue”队列接收消息。可以通过ActiveMQ的web控制台查看消息的发送和接收情况。

六、总结

本文介绍了如何在Spring Boot项目中使用ActiveMQ进行消息传递，并提供了一个完整的示例。通过学习本文，你应该能够掌握在Spring Boot项目中使用ActiveMQ进行消息传递的基本方法和技巧。