如何使用ActiveMQ中間件方式發(fā)送郵件

更新時(shí)間：2021年07月05日 10:13:57 作者：王小白_Ada

這篇文章主要介紹了如何使用ActiveMQ中間件方式發(fā)送郵件的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

前言

在大型互聯(lián)網(wǎng)公司中，一般都會(huì)搭建內(nèi)部的消息服務(wù)平臺(tái)，處理公司內(nèi)部的各種消息服務(wù)，比如：發(fā)送郵件、發(fā)送短信、微信推送等，公司內(nèi)部消息平臺(tái)再去調(diào)用第三發(fā)消息平臺(tái)。消息服務(wù)平臺(tái)的接口有兩種：同步和異步，同步需求一般是需要返回調(diào)用第三方平臺(tái)是否成功，否則都采用異步的。

公司內(nèi)部消息服務(wù)平臺(tái)

調(diào)用內(nèi)部消息服務(wù)平臺(tái)，使用消息中間件

發(fā)送消息一般都會(huì)做消息模板，調(diào)用的時(shí)候傳模板id

整合Eamil實(shí)現(xiàn)異步發(fā)送郵件信息

采用163郵件接口，先注冊(cè)163郵箱，并開(kāi)通pop3協(xié)議，此時(shí)會(huì)有一個(gè)授權(quán)碼，發(fā)送內(nèi)容不能帶有廣告，否則會(huì)被163攔截，導(dǎo)致發(fā)送失敗。

場(chǎng)景：會(huì)員服務(wù)調(diào)用內(nèi)部消息服務(wù)平臺(tái)發(fā)送郵件

會(huì)員服務(wù)（生產(chǎn)者）

Maven依賴

        <!-- SpringBoot整合web組件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- ActiveMQ依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
        <!-- FastJson工具包 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>LATEST</version>
        </dependency>

YML配置文件

spring:
  activemq:
    broker-url: tcp://127.0.0.1:61616    # ActiveMQ消息中間件服務(wù)器通訊地址
    user: admin  # 用戶名
    password: admin  #密碼
queue: springboot-queue   #自定義隊(duì)列名，等下程序中會(huì)用到
server:
  port: 8080

配置類

@Configuration
public class QueueConfig {
    //獲取隊(duì)列名
    @Value("${queue}")
    private String queue;
    //注冊(cè)bean
    @Bean
    public Queue logQueue() {
        return new ActiveMQQueue(queue);
    }
}

創(chuàng)建Producer

@Component
@EnableScheduling
public class Producer {
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
    @Autowired
    private Queue queue;
    //每隔5秒向消息隊(duì)列發(fā)送消息
    @Scheduled(fixedDelay = 5000)
    public void send(){
        //用戶名，封裝郵件內(nèi)容時(shí)使用
        String userName = "張三"+ new Random().nextInt(20);
        //指定發(fā)送到哪個(gè)郵箱 (郵件接收者郵箱)
        String email = "593****77@qq.com";
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("userName",userName);
        jsonObject.put("email",email);
        //將發(fā)送的消息轉(zhuǎn)換為Json字符串
        String msg = jsonObject.toJSONString();
        System.out.println("生產(chǎn)者向消費(fèi)者發(fā)送內(nèi)容：" +  msg);
        jmsMessagingTemplate.convertAndSend(queue,msg);
    }
}

啟動(dòng)類

@EnableScheduling
@SpringBootApplication
public class ActivemqQueueApplication {
    public static void main(String[] args) {
        SpringApplication.run(ActivemqQueueApplication.class, args);
    }
}

消息服務(wù)平臺(tái)（消費(fèi)者）

Maven依賴

        <!-- SpringBoot整合Web組件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        
       <!-- activemq依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
        <!-- SpringBoot 整合Emai -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-mail</artifactId>
        </dependency>
        <!-- 工具包 -->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>LATEST</version>
        </dependency>

YML配置文件

spring:
  activemq:
    # ActiveMQ消息中間件服務(wù)器通訊地址
    broker-url: tcp://127.0.0.1:61616
    user: admin  # 用戶名
    password: admin  #密碼
  # 發(fā)送郵件配置
  mail:
    # 郵件服務(wù)器地址
    host: smtp.163.com
    # 郵箱用戶名(郵件發(fā)送者)
    username: *********@163.com
    # 授權(quán)碼，163郵箱開(kāi)通協(xié)議時(shí)設(shè)置的那個(gè)授權(quán)碼，不是登錄密碼
    password: wx1**********3
    enable:  true
    smtp:
      auth: true
    starttls:
      enable: true
      required: true
#自定義隊(duì)列名屬性，等下程序中會(huì)用到（以生產(chǎn)者的隊(duì)列名一致）
queue: springboot-queue
server:
  port: 8081

創(chuàng)建Consumer

@Component
public class Consumer{
    @Autowired
    private JavaMailSender javaMailSender;
    @Value("${spring.mail.username}") //發(fā)送方郵箱
    private String toEmail;
    @JmsListener(destination = "${queue}")     //監(jiān)聽(tīng)的隊(duì)列，配置文件中的queue屬性
    public void receive(String msg){
        if(StringUtils.isEmpty(msg)){
            return;
        }
        System.out.println("收到生產(chǎn)者消息："+msg);
        JSONObject jsonObject = JSONObject.parseObject(msg);
        String userName = jsonObject.getString("userName");
        String eamil = jsonObject.getString("eamil");
        //發(fā)送郵件
        sendEmail(userName,toEmail);
    }
    /**
     * 發(fā)送簡(jiǎn)單郵件
     * @param userName  用戶名，用戶封裝郵件內(nèi)容
     * @param toEmail 通過(guò)哪個(gè)郵箱發(fā)送
     * @return
     */
    public String sendEmail(String userName,String toEmail){
        //發(fā)送消息對(duì)象
        SimpleMailMessage message = new SimpleMailMessage();
        //發(fā)送者
        message.setFrom(toEmail);
        //接收者
        message.setTo(toEmail);
        //主題(標(biāo)題)
        message.setSubject("尊敬的"+userName);
        //內(nèi)容
        message.setText("歡迎使用您使用本公司的產(chǎn)品！");  //發(fā)送html，發(fā)送html格式源碼
        javaMailSender.send(message);
        System.out.println("郵件發(fā)送完成："+ JSONObject.toJSONString(message));
        return  "send success!";
    }
}

啟動(dòng)類

@SpringBootApplication
public class ActivemqQueueConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ActivemqQueueConsumerApplication.class, args);
    }
}