Rabbimq发送邮件并消费邮件

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: Rabbimq发送邮件并消费邮件

📑前言

本文主要是【Rabbitmq】——Rabbimq发送邮件并消费邮件的文章,如果有什么需要改进的地方还请大佬指出⛺️

🎬作者简介:大家好,我是听风与他🥇
☁️博客首页:阿里云主页听风与他
🌄每日一句:狠狠沉淀,顶峰相见

Rabbimq发送邮件并消费邮件

1.配置application.yml文件

spring:
  rabbitmq:
    virtual-host: /test
    username: admin
    password: admin
    addresses: localhost

2.定义消息队列的配置:RabbitConfiguration

package com.rabbitmqtest.config;

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfiguration {
   
   
    /**
     * 导包时候注意是amqp这个包
     * @return
     */
    @Bean("directExchange")  //定义交换机Bean,可以很多个
    public Exchange exchange(){
   
   
        //如果没有会自动进行创建
        return ExchangeBuilder.directExchange("amq.direct").build();
    }

    @Bean("yydsQueue")     //定义消息队列
    public Queue queue(){
   
   
        return QueueBuilder
                .nonDurable("yyds")   //非持久化类型
                .build();
    }

    @Bean("binding")
    public Binding binding(@Qualifier("directExchange") Exchange exchange,
                           @Qualifier("yydsQueue") Queue queue){
   
   
        //将我们刚刚定义的交换机和队列进行绑定
        return BindingBuilder
                .bind(queue)   //绑定队列
                .to(exchange)  //到交换机
                .with("my-yyds")   //使用自定义的routingKey
                .noargs();
    }

}

运行后打开rabbitmq:我们发现已经创建了yyds队列

image.png

3.监听类:TestListener

package com.rabbitmqtest.listener;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class TestListener {
   
   

    @RabbitListener(queues = "yyds")
    public void test(Message message){
   
   
        System.out.println(new String(message.getBody()));
    }
}

测试类进行测试

package com.rabbitmqtest;

import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class RabbitmqTestApplicationTests {
   
   

    //RabbitTemplate为我们封装了大量的RabbitMQ操作,已经由Starter提供,因此直接注入使用即可
    @Resource
    RabbitTemplate template;


    @Test
    void publisher() {
   
   
        //使用convertAndSend方法一步到位,参数基本和之前是一样的
        //最后一个消息本体可以是Object类型,真是大大的方便
        template.convertAndSend("amq.direct", "my-yyds", "邮件信息");
    }

}

结果:

//控制台会打印:邮件信息

📑文章末尾

image.png

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
Jamil+c#—实现邮件的发送
Jamil+c#—实现邮件的发送
120 0
Jamil+c#—实现邮件的发送
|
监控 安全 开发者
安全日报邮件的发送和介绍|学习笔记
快速学习安全日报邮件的发送和介绍
91 0
安全日报邮件的发送和介绍|学习笔记
如何撤回 Gmail 已发送的邮件
还记得发送电子邮件并在下一刻意识到您不应该发送它吗?幸运的是,可以在 Gmail 中撤回已发送的电子邮件。
551 0
如何撤回 Gmail 已发送的邮件
阿里云如何添加邮箱解析来实现收发邮件服务
当你买域名后,要在阿里云添加邮箱解析,邮箱解析是把域名指向邮箱的服务器地址,实现邮箱的收发邮件服务。一、联系邮箱提供商,获取邮箱解析记录,这部分数据一般在邮箱提供商帮助文档里有,要么就和客服索要。二、添加解析操作步骤 1、联系邮箱提供商,获取邮箱解析地址记录。
|
数据安全/隐私保护
邮箱发送
邮箱发送
1721 0
|
关系型数据库 测试技术 数据库

相关产品

  • 云消息队列 MQ
  • 云消息队列 Kafka 版
  • 微服务引擎