Spring Boot整合ActiveMQ的基本步骤如下：
- 添加依赖：在
pom.xml中添加ActiveMQ的Spring Boot Starter依赖。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>- 配置ActiveMQ：在
application.properties或application.yml中配置ActiveMQ的连接信息。
# application.properties
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin- 配置消息生产者：创建配置类，配置消息队列，并提供消息生产者。
@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;
}
}- 发送消息：使用
JmsTemplate发送消息。
@RestController
public class MessageController {
@Autowired
private JmsTemplate jmsTemplate;
@GetMapping("/sendMessage")
public void sendMessage(@RequestParam String message) {
jmsTemplate.convertAndSend(message);
}
}- 接收消息：创建消息消费者来接收消息。
@Component
public class MessageReceiver {
@JmsListener(destination = "sample.queue")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}以上代码提供了一个简单的Spring Boot与ActiveMQ整合的例子。记得根据实际环境配置ActiveMQ的连接信息，并确保ActiveMQ服务器正在运行。