SpringBoot整合ActiveMQ

这篇文章距离上次修改已过213天，其中的内容可能已经有所变动。

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服务器正在运行。

SpringBoot整合ActiveMQ

评论已关闭

推荐阅读