springboot实现消息通知

Spring Boot可以使用Spring框架提供的消息队列实现消息通知功能。常见的消息队列有ActiveMQ、RabbitMQ、Kafka等。

以使用ActiveMQ为例，首先需要在pom.xml中添加ActiveMQ的依赖：

<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

接着创建一个消息生产者，将消息发送到ActiveMQ：

@Service
public class MessageProducer {

    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendMessage(String destination, String message) {
        jmsTemplate.send(destination, session -> session.createTextMessage(message));
    }
}

其中destination为消息目的地，可以是队列或主题，message为消息内容。

最后创建一个消息消费者，从ActiveMQ接收消息并进行处理：

@Service
public class MessageConsumer {

    @JmsListener(destination = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

其中@JmsListener注解标注了消息监听器，destination为消息目的地，这里是队列myQueue。

这样就可以通过ActiveMQ实现消息通知功能了。当需要发送消息时，调用MessageProducer的sendMessage方法，消息消费者会自动接收消息并进行处理。