SpringBoot整合ActiveMQ

Spring Boot整合ActiveMQ的基本步骤如下：

1. 添加依赖：在pom.xml中添加ActiveMQ的Spring Boot Starter依赖。

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

2. 配置ActiveMQ：在application.properties或application.yml中配置ActiveMQ的连接信息。

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

3. 配置消息生产者：创建配置类，配置消息队列，并提供消息生产者。

@Configuration
public class ActiveMQConfig {
 
    @Bean
    public Queue queue() {
        return new ActiveMQQueue("sample.queue");
    }
 
    @Bean
    public JmsTemplate jmsTemplate(ActiveMQConnectionFactory connectionFactory, Queue queue) {
        JmsTemplate template = new JmsTemplate();
        template.setConnectionFactory(connectionFactory);
        template.setDefaultDestination(queue);
        return template;
    }
}

4. 发送消息：使用JmsTemplate发送消息。

@RestController
public class MessageController {
 
    @Autowired
    private JmsTemplate jmsTemplate;
 
    @GetMapping("/sendMessage")
    public void sendMessage(@RequestParam String message) {
        jmsTemplate.convertAndSend(message);
    }
}

5. 接收消息：创建消息消费者来接收消息。

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

以上代码提供了一个简单的Spring Boot与ActiveMQ整合的例子。记得根据实际环境配置ActiveMQ的连接信息，并确保ActiveMQ服务器正在运行。