在Spring/Spring Boot整合ActiveMQ的过程中,你需要做以下几个步骤:
- 添加依赖:确保你的项目中包含了Spring Boot对ActiveMQ的支持。
<!-- 如果使用的是Spring Boot,可以添加starter POM -->
<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
- 配置Spring消息监听器。
@Component
public class ActiveMQListener {
@JmsListener(destination = "your.queue.name")
public void receiveMessage(String text) {
System.out.println("Received <" + text + ">");
}
}
- 发送消息。
@Autowired
private JmsTemplate jmsTemplate;
public void sendMessage(String queueName, String message) {
jmsTemplate.convertAndSend(queueName, message);
}
确保你的ActiveMQ服务器正在运行,并且你已经配置了正确的连接信息。上述代码提供了一个简单的示例,展示了如何在Spring Boot应用程序中整合ActiveMQ,并发送、接收消息。