SpringBoot整合ActiveMQ(消息中间件)实现邮件发送功能

好的，我可以为您提供一个简单的示例。

首先，您需要在SpringBoot项目中添加ActiveMQ的依赖。在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

接下来，您需要创建一个消息队列，用于存储要发送的邮件信息。在SpringBoot中，可以使用JmsTemplate来发送消息。您可以在您的Java代码中注入JmsTemplate，然后使用它来发送邮件消息。以下是一个示例代码：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;

@Service
public class EmailService {

    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendEmail(String to, String message) {
        jmsTemplate.convertAndSend("email.queue", new Email(to, message));
    }
}

在上面的代码中，我们注入了JmsTemplate，并使用它来发送一个Email对象到名为“email.queue”的消息队列中。

最后，您需要编写一个消息监听器，用于监听邮件队列中的消息，并实现邮件发送逻辑。以下是一个示例代码：

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class EmailListener {

    @Autowired
    private JavaMailSender mailSender;

    @JmsListener(destination = "email.queue")
    public void sendEmail(Email email) {
        SimpleMailMessage message = new SimpleMailMessage();
        message.setTo(email.getTo());
        message.setSubject("Test Email");
        message.setText(email.getMessage());
        mailSender.send(message);
    }
}

在上面的代码中，我们使用@JmsListener注解来监听名为“email.queue”的消息队列中的消息，并实现了邮件发送逻辑。

最后，您需要确保ActiveMQ服务器已经启动，然后运行您的SpringBoot应用程序即可。

希望这个示例对您有帮助！