如何在Spring Boot中集成JMS

要在Spring Boot中集成JMS，您需要遵循以下步骤：

1. 添加依赖项

在pom.xml文件中，添加ActiveMQ和Spring JMS的依赖项。这是一个示例：

    <!-- ActiveMQ dependency -->    <dependency>        <groupId>org.apache.activemq</groupId>        <artifactId>activemq-broker</artifactId>        <version>5.x.x</version>     </dependency>      <!-- Spring JMS dependency -->    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-activemq</artifactId>     </dependency> </dependencies> 

2. 配置ActiveMQ

在application.properties或application.yml文件中，添加ActiveMQ的配置信息。这是一个示例：

# ActiveMQ configuration spring.activemq.broker-url=tcp://localhost:61616 spring.activemq.user=admin spring.activemq.password=admin spring.activemq.packages.trust-all=true 

3. 创建JMS监听器

创建一个类，用于处理接收到的JMS消息。使用@JmsListener注解指定要监听的队列。

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

4. 发送JMS消息

注入JmsTemplate并使用convertAndSend方法将消息发送到指定的队列。

import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.core.JmsTemplate; import org.springframework.stereotype.Component;  @Component public class MyJmsSender {      @Autowired     private JmsTemplate jmsTemplate;      public void sendMessage(String message) {         jmsTemplate.convertAndSend("myQueue", message);     } } 

5. 使用JMS发送和接收消息

现在，您可以在应用程序中使用MyJmsSender来发送消息，并通过MyJmsListener接收消息。

这就是在Spring Boot中集成JMS的方法。根据实际需求，您可能需要调整配置和代码。