springboot 集成使用jms

Spring Boot可以集成和使用JMS（Java Message Service）来实现消息的发送和接收。

首先，在pom.xml文件中添加相应的依赖，如下所示：

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

接下来，在application.properties文件中配置ActiveMQ的连接信息，如下所示：

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

然后，在Spring Boot的配置类中添加注解@EnableJms，启用JMS功能。同时，使用@Bean注解注入ActiveMQ的连接工厂、目的地以及JmsTemplate等bean。

@Configuration
@EnableJms
public class JmsConfig {
    
    @Value("${spring.activemq.broker-url}")
    private String brokerUrl;
    
    @Value("${spring.activemq.user}")
    private String username;
    
    @Value("${spring.activemq.password}")
    private String password;
    
    @Bean
    public ConnectionFactory connectionFactory() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL(brokerUrl);
        connectionFactory.setUserName(username);
        connectionFactory.setPassword(password);
        return connectionFactory;
    }
    
    @Bean
    public Queue queue() {
        return new ActiveMQQueue("myQueue");
    }
    
    @Bean
    public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory) {
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(connectionFactory);
        return jmsTemplate;
    }
}

然后，可以在需要发送消息的地方注入JmsTemplate，并使用其send或convertAndSend方法发送消息。如下所示：

@Autowired
private JmsTemplate jmsTemplate;

public void sendMessage(String message) {
    jmsTemplate.convertAndSend("myQueue", message);
}

对于接收消息，只需要在需要接收消息的方法上添加@JmsListener注解，并指定需要监听的目的地。如下所示：

@JmsListener(destination = "myQueue")
public void receiveMessage(String message) {
    // 处理接收到的消息
}

以上的步骤完成后，就可以在Spring Boot中集成和使用JMS了。我们可以使用ActiveMQ或其他JMS提供商来实现消息的发送和接收。