前言
在quarkus 项目开发中,需要实现一个把用户数据写入到excel 表格中,然后发送邮件给到对应的用户邮箱上,在查找了Quarkus 官方文档后发现,Quarkus 对于发送邮箱的服务是天然支持的.
官方文档: https://cn.quarkus.io/guides/mailer
环境配置
首先发送邮箱服务,那么就需要有一个邮箱的配置,并且需要开启 smtp 服务才能进行发送邮箱,
这里我使用的是 网易邮箱,其他的邮箱应该也是同理.
进入到页面后,选择设置,点击smtp 按钮,然后开启
记住一定要保持密钥,这是后面发送消息的密码.环境配置好了,那么接下来就是集成了.
集成
maven:
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-mailer</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>easyexcel</artifactId>
<version>3.1.2</version>
</dependency>
项目中增加 以下以来,因为我们需要进行操作表格,所以我这里加入了阿里的表格工具类:easyexcel,可以很方便的操作.
application.properties
quarkus.mailer.from=miraitowa1796@163.com
quarkus.mailer.host=smtp.163.com
quarkus.mailer.port=465
quarkus.mailer.ssl=true
quarkus.mailer.username=miraitowa1796@163.com
quarkus.mailer.password=xxxxxxxx //请修改为自己的密码
%dev.quarkus.mailer.mock=false
quarkus.mailer.mock : 是否开启mock ,默认在正式环境下是false,所以我们在其他环境上需要手动指定为不开启
代码示例
增加一个表格实体类:
public class User {
@ExcelProperty("字符串标题")
private String string;
@ExcelProperty("数字标题")
private Double doubleData;
public String getString() {
return string;
}
public void setString(String string) {
this.string = string;
}
public Double getDoubleData() {
return doubleData;
}
public void setDoubleData(Double doubleData) {
this.doubleData = doubleData;
}
}
引入 Mailer 类即可实现发送邮箱服务:
/**
* 测试邮箱发送：
*/
@Path("/contextLoads")
@GET
@Blocking
public void contextLoads() {
Mail mail = Mail.withText("1796789910@qq.com", "测试邮件服务", "这是一封用来测试邮件的服务");
mailer.send(mail);
}
@Path("/contextFileXlisLoads")
@GET
@Blocking
public void contextFileXlisLoads() {
Mail mail = Mail.withText("1796789910@qq.com", "测试发送表格文件", "这是一个带附件的html文件")
.addAttachment("测试.xlsx", excelToByteArray(getUsers()),"text/plain");
mailer.send(mail);
}
/**
* 将 Excel 写入 ByteArrayOutputStream
*/
private byte[] excelToByteArray(List<User> list) {
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
EasyExcel.write(outputStream, User.class).sheet("测试").doWrite(list);
return outputStream.toByteArray();
}
private List<User> getUsers() {
List<User> list = ListUtils.newArrayList();
for (int i = 0; i < 10; i++) {
User data = new User();
data.setString("字符串" + i);
data.setDoubleData(0.56);
list.add(data);
}
return list;
}
启动应用服务访问: curl http://localhost:8080/contextFileXlisLoads, 查看邮箱即可发送成功.
以响应式的方式发送邮件服务
疑问
上面那种方式是以同步发送邮件,在请求多的情况下,会出现阻塞,接收邮件慢点问题,那么我们 如何以非阻塞,响应式发送邮件呢?
解决方案
Quarkus 已经为我们提供了解决方案,想以响应性的方式去发送邮件只需要注入ReactiveMailer 使用它,方法是一样,只是该方法返回了响应式副本,而不是同步式副本.
@Inject
ReactiveMailer mailer;
/**
* 测试邮箱发送：
*/
@Path("/contextLoads")
@GET
@Blocking
public void contextLoads() {
Mail mail = Mail.withText("1796789910@qq.com", "测试邮件服务", "这是一封用来测试邮件的服务");
mailer.send(mail);
}
@Path("/contextFileXlisLoads")
@GET
@Blocking
public void contextFileXlisLoads() {
Mail mail = Mail.withText("1796789910@qq.com", "测试发送表格文件", "这是一个带附件的html文件")
.addAttachment("测试.xlsx", excelToByteArray(data()),"text/plain");
mailer.send(mail);
}
/**
* 将 Excel 写入 ByteArrayOutputStream
*/
private byte[] excelToByteArray(List<User> list) {
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
EasyExcel.write(outputStream, User.class).sheet("测试").doWrite(list);
return outputStream.toByteArray();
}
private List<User> data() {
List<User> list = ListUtils.newArrayList();
for (int i = 0; i < 10; i++) {
User data = new User();
data.setString("字符串" + i);
data.setDoubleData(0.56);
list.add(data);
}
return list;
}
与上面的例子基本一致,只是把同步邮箱组件,改为响应式组件.
遇到的问题
发送邮件,没有报错,为什么没有收到邮件呢?
在最开始的时候,我没有加入quarkus.mailer.mock=false 这一行配置,导致出现了上面疑问的问题,在查找了官方文档后,发现了答案.
官网配置文档: https://cn.quarkus.io/guides/mailer-reference
quarkus.mailer.mock
启用模拟模式。启用后，邮件不会发送，而是存储在内存邮箱中。电子邮件的内容也打印在控制台上。在 PROD 模式下默认禁用，在 DEV
修改为false 即可.
项目源码:
https://gitee.com/QuRenNen/quarkus-integrate 如果有帮助请一键三连…
