如何使用ActiveMQ中间件方式发送邮件

如何使用ActiveMQ中间件方式发送邮件

前言

在大型互联网公司中，一般都会搭建内部的消息服务平台，处理公司内部的各种消息服务，比如：发送邮件、发送短信、微信推送等，公司内部消息平台再去调用第三发消息平台。消息服务平台的接口有两种：同步和异步，同步需求一般是需要返回调用第三方平台是否成功，否则都采用异步的。

公司内部消息服务平台

调用内部消息服务平台，使用消息中间件

发送消息一般都会做消息模板，调用的时候传模板id

整合Eamil实现异步发送邮件信息

采用163邮件接口，先注册163邮箱，并开通pop3协议，此时会有一个授权码，发送内容不能带有广告，否则会被163拦截，导致发送失败。

场景：会员服务调用内部消息服务平台发送邮件

会员服务（生产者）

Maven依赖

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-activemq

com.alibaba

fastjson

LATEST

YML配置文件

spring:

activemq:

broker-url: tcp://127.0.0.1:61616 # ActiveMQ消息中间件服务器通讯地址

user: admin # 用户名

password: admin #密码

queue: springboot-queue #自定义队列名，等下程序中会用到

server:

port: 8080

配置类

@Configuration

public class QueueConfig {

//获取队列名

@Value("${queue}")

private String queue;

//注册bean

@Bean

public Queue logQueue() {

return new ActiveMQQueue(queue);

}

}

创建Producer

@Component

@EnableScheduling

public class Producer {

@Autowired

private JmsMessagingTemplate jmsMessagingTemplate;

@Autowired

private Queue queue;

//每隔5秒向消息队列发送消息

@Scheduled(fixedDelay = 5000)

public void send(){

//用户名，封装邮件内容时使用

String userName = "张三"+ new Random().nextInt(20);

//指定发送到哪个邮箱 (邮件接收者邮箱)

String email = "593****77@qq.com";

JSONObject jsonObject = new JSONObject();

jsonObject.put("userName",userName);

jsonObject.put("email",email);

//将发送的消息转换为Json字符串

String msg = jsonObject.toJSONString();

System.out.println("生产者向消费者发送内容：" + msg);

jmsMessagingTemplate.convertAndSend(queue,msg);

}

}

启动类

@EnableScheduling

@SpringBootApplication

public class ActivemqQueueApplication {

http:// public static void main(String[] args) {

SpringApplication.run(ActivemqQueueApplication.class, args);

}

}

消息服务平台（消费者）

Maven依赖

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-activemq

org.springframework.boot

spring-boot-starter-mail

org.apache.commons

commons-lang3

com.alibaba

fastjson

LATEST

YML配置文件

spring:

activemq:

# ActiveMQ消息中间件服务器通讯地址

broker-url: tcp://127.0.0.1:61616

user: admin # 用户名

password: admin #密码

# 发送邮件配置

mail:

# 邮件服务器地址

host: smtp.163.com

# 邮箱用户名(邮件发送者)

username: *********@163.com

# 授权码，163邮箱开通协议时设置的那个授权码，不是登录密码

password: wx1**********3

enable: true

smtp:

auth: true

starttls:

enable: true

required: true

#自定义队列名属性，等下程序中会用到（以生产者的队列名一致）

queue: springboot-queue

server:

port: 8081

创建Consumer

@Component

public class Consumer{

@Autowired

private javaMailSender javaMailSender;

@Value("${spring.mail.username}") //发送方邮箱

private String toEmail;

@JmsListener(destination = "${queue}") //监听的队列，配置文件中的queue属性

public void receive(String msg){

if(StringUtils.isEmpty(msg)){

return;

}

System.out.println("收到生产者消息："+msg);

JSONObject jsonObject = JSONObject.parseObject(msg);

String userName = jsoOrOptMnObject.getString("userName");

String eamil = jsonObject.getString("eamil");

//发送邮件

sendEmail(userName,toEmail);

}

/**

* 发送简单邮件

* @param userName 用户名，用户封装邮件内容

* @param toEmail 通过哪个邮箱发送

* @return

*/

public String sendEmail(String userName,String toEmail){

//发送消息对象

SimpleMailMessage message = new SimpleMailMessage();

//发送者

message.setFrom(toEmail);

//接收者

message.setTo(toEmail);

//主题(标题)

message.setSubject("尊敬的"+userName);

//内容

message.setTexthttp://("欢迎使用您使用本公司的产品！"); //发送html，发送html格式源码

javaMailSender.send(message);

System.out.println("邮件发送完成："+ JSONObject.toJSONString(message));

return "send success!";

}

}

启动类

@SpringBootApplication

public class ActivemqQueueConsumerApplication {

public static void main(String[] args) {

SpringApplication.run(ActivemqQueueConsumerApplication.class, args);

}

}

测试

启动会员服务和消息服务平台服务

注意：启动前保证消息队列里面没有消息，有的话则先删除该队列，否则容易造成数据类型不一致导致Json解析异常出错。

会员服务：

消息服务平台：

此时消息服务平台发送邮件成功！

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。