springboot集成rabbitmq实现邮件服务

最新推荐文章于 2024-10-09 09:38:56 发布

lazyRabbit丶

最新推荐文章于 2024-10-09 09:38:56 发布

阅读量1.9k

点赞数 1

分类专栏： RabbitMQ

本文链接：https://blog.csdn.net/lazyRabbitLLL/article/details/85226600

版权

本文介绍了如何在SpringBoot应用中集成RabbitMQ，实现邮件服务。包括生产者部分，详细说明了添加pom依赖、配置RabbitMQ、创建实体类以及使用rabbitTemplate发送消息到队列的步骤。同时，还给出了测试生产者代码的说明。在消费者部分，讲述了消费者的pom依赖、配置、消费者代码实现以及邮件发送服务和HTML邮件模板的创建。启动消费者项目后，邮件能成功发送到邮箱。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

生产者

pom依赖如下

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-test</artifactId>
	<scope>test</scope>
</dependency>

RabbitMQ配置

# RabbitMQ配置
spring.rabbitmq.host=*.*.*.*
spring.rabbitmq.port=5672
spring.rabbitmq.username=lazyrabbit
spring.rabbitmq.password=password
spring.rabbitmq.virtual-host=/

mail对应实体类

public class Mail implements Serializable {
   
    /**
     * 
     */
    private static final long serialVersionUID = 3062479058855881261L;
    private Integer id;
    private String to;
    private String subject;
    private String content;
    
    //getset方法。。。
}

生产者代码实现，通过内置的模板类rabbitTemplate将消息发送到队列中

@Component
public class MailSender {
   

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(Email email) {
   
        CorrelationData correlationData = new CorrelationData();
        correlationData.setId(email.getId().toString());
        rabbitTemplate.convertAndSend("mail-exchange", // exchange
                "mail.test", // routingKey
                email, // 消息实体
                correlationData);// 消息id，可以以此取得消息
    }
}

测试生产者发送消息

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootRabbitmqApplicationTests {
   

    @Autowired
    private MailSender mailSender;

    @Test
    public void testSend() {
   
        Email e = new Email();
        e.setId(123456);
        e.setSubject("hello");
        e.

最低0.47元/天解锁文章