ActiveMQ结合Spring收发消息的示例代码

ActiveMQ 是一个开源的消息中间件，它实现了 JMS（Java Message Service）规范，可以用于在应用程序之间异步发送消息，Spring 框架提供了对 JMS 的良好支持，使得使用 ActiveMQ 变得更加简单和直观，下面是一个简单的示例代码，展示如何使用 Spring 结合 ActiveMQ 来收发消息。

项目结构

我们假设你已经创建了一个 Maven 项目，并添加了以下依赖：

<dependencies>
    <!-Spring Boot Starter -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <!-Spring Boot Starter for ActiveMQ -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-activemq</artifactId>
    </dependency>
    <!-Spring Boot Starter Test (for testing) -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

配置文件

在src/main/resources 目录下创建一个application.properties 文件，配置 ActiveMQ 的连接信息：

spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin
spring.jms.listener.auto-startup=true

发送消息的代码

创建一个服务类，用于发送消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;
@Service
public class SenderService {
    @Autowired
    private JmsTemplate jmsTemplate;
    public void send(String destination, String message) {
        jmsTemplate.convertAndSend(destination, message);
    }
}

接收消息的代码

创建一个监听器类，用于接收消息：

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
@Component
public class Receiver {
    @JmsListener(destination = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

主程序

在你的主程序中注入SenderService 并发送一条消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class ActivemqSpringExampleApplication implements CommandLineRunner {
    @Autowired
    private SenderService senderService;
    public static void main(String[] args) {
        SpringApplication.run(ActivemqSpringExampleApplication.class, args);
    }
    @Override
    public void run(String... args) throws Exception {
        senderService.send("myQueue", "Hello, ActiveMQ!");
    }
}

FAQs

问题1: ActiveMQ 服务器没有运行，会发生什么？

回答: ActiveMQ 服务器没有运行，应用程序将无法连接到消息代理，导致发送和接收消息失败，通常会抛出连接异常。

问题2: 如何确保消息被可靠地传递？

回答: 可以通过启用持久性、事务或确认机制来确保消息的可靠传递，可以在发送消息时使用事务，或者在接收消息后手动确认。

小编有话说

通过这个简单的示例，你可以看到使用 Spring 和 ActiveMQ 进行消息传递是多么容易，ActiveMQ 的强大功能和 Spring 的易用性相结合，为构建分布式系统提供了一个强大的工具，希望这个示例能帮助你快速上手，并在你的项目中应用这些技术，如果你有任何问题或需要进一步的帮助，请随时留言！