今天把之前写的使用JavaMail异步发送邮件的demo程序贴出来。
最近一段时间，发现新浪微博手机客户端也开始支持异步发送信息了。不管是发微博，还是评论微博，点击过“发送”按钮之后，马上会被告知“已经进入发送队列”，我觉得这明显增加了用户体验，并且这个提升也不存在任何技术困难。这样一种情况，比如我发一个带图的微博消息，在不使用wifi的情况下，上传一个稍大些的图片可能会耗费不少时间。假如微博客户端不支持异步发送，也许就因为图片的上传，这个客户端得卡上好半天，直到上传完成为止。这种完全阻塞的方式，对用户来说可不是种好的体验。
发送邮件的时候同样存在着类似上面的情况。整个邮件的发送过程是比较耗时的，假如使用普通的单线程串行处理方式，当并发量大时，必然带来灾难性的后果。在下面的例子中，我使用多线程的方式来解决这个问题，使得邮件支持异步发送。
要支持新浪微博的异步发送，可以使用多线程方式，也可以使用消息服务。我本身对于JMS的方式不太了解，因此选择了一种相对熟悉和容易实现的方式，即每个邮件发送请求都作为一个线程任务，由线程池中的线程来处理每一个邮件发送任务。
首先，介绍邮件的JavaBean对象Mail。很简单，无需赘言。
package org.tang.financial.domain;
import java.util.List;
public class Mail {
/**
* 发送人
*/
private String sender;
/**
* 收件人
*/
private List<String> recipientsTo;
/**
* 抄送人
*/
private List<String> recipientsCc;
/**
* 密送人
*/
private List<String> recipientsBcc;
/**
* 主题
*/
private String subject;
/**
* 正文
*/
private String body;
/**
* 附件列表
*/
private List<String> attachments;
public String getSender() {
return sender;
}
public void setSender(String sender) {
this.sender = sender;
}
public List<String> getRecipientsTo() {
return recipientsTo;
}
public void setRecipientsTo(List<String> recipientsTo) {
this.recipientsTo = recipientsTo;
}
public List<String> getRecipientsCc() {
return recipientsCc;
}
public void setRecipientsCc(List<String> recipientsCc) {
this.recipientsCc = recipientsCc;
}
public List<String> getRecipientsBcc() {
return recipientsBcc;
}
public void setRecipientsBcc(List<String> recipientsBcc) {
this.recipientsBcc = recipientsBcc;
}
public String getSubject() {
return subject;
}
public void setSubject(String subject) {
this.subject = subject;
}
public String getBody() {
return body;
}
public void setBody(String body) {
this.body = body;
}
public List<String> getAttachments() {
return attachments;
}
public void setAttachments(List<String> attachments) {
this.attachments = attachments;
}
}
其次，是邮件发送程序当中需要用到的常量。各个常量的含义都已经有说明，也无需赘言。
package org.tang.financial.mail;
public abstract class MailProperties {
/**
* SMTP服务器
*/
public static final String MAIL_SMTP_HOST = "mail.smtp.host";
/**
* SMTP服务器端口号
*/
public static final String MAIL_SMTP_PORT = "mail.smtp.port";
/**
* 登录SMTP服务器是否需要通过授权。可选值为true和false
*/
public static final String MAIL_SMTP_AUTH = "mail.smtp.auth";
/**
* 登录SMTP服务器默认邮箱账号
*/
public static final String MAIL_SMTP_USER = "mail.smtp.user";
/**
* 登录SMTP服务器默认邮箱账号对应密码
*/
public static final String MAIL_SMTP_PASSWORD = "mail.smtp.password";
/**
* 是否打开程序调试。可选值包括true和false
*/
public static final String MAIL_DEBUG = "mail.debug";
}
接着，是邮件发送程序需要使用到得properties属性配置文件。各个键值的含义参考上面的说明。
mail.smtp.host = smtp.example.com
mail.smtp.port = 25
mail.smtp.auth = true
mail.smtp.user = username@example.com
mail.smtp.password = password
mail.debug = true
最后，邮件发送的处理程序。
package org.tang.financial.service;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;
import java.util.Properties;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import javax.mail.Authenticator;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.AddressException;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeBodyPart;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeMultipart;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.stereotype.Component;
import org.tang.financial.domain.Mail;
import org.tang.financial.mail.MailProperties;
import org.tang.financial.util.CollectionUtils;
import org.tang.financial.util.StringUtils;
@Component
public class MailService {
private static Log logger = LogFactory.getLog(MailService.class);
private static final String MAIL_PROPERTIE_NAME = "JavaMail.properties";
private static Properties mailPro = new Properties();
private static Executor executor = Executors.newFixedThreadPool(10);
static {
//初始化，读取属性文件的过程
InputStream in = null;
try {
in = MailService.class.getResourceAsStream(MAIL_PROPERTIE_NAME);
mailPro.load(in);
} catch (IOException e) {
if (logger.isErrorEnabled()) {
logger.error(e);
}
} finally {
if (in != null) {
try {
in.close();
} catch (IOException e) {
if (logger.isErrorEnabled()) {
logger.error(e);
}
}
}
}
}
public boolean sendMail(final Mail mail) {
if(mail == null){
return false;
}
//创建邮件发送任务
Runnable task = new Runnable() {
@Override
public void run() {
final String username = mailPro.getProperty(MailProperties.MAIL_SMTP_USER);
final String password = mailPro.getProperty(MailProperties.MAIL_SMTP_PASSWORD);
//创建发送邮件的会话
Session session = Session.getDefaultInstance(mailPro, new Authenticator() {
protected PasswordAuthentication getPasswordAuthentication() {
return new PasswordAuthentication(username, password);
}
});
try {
//创建邮件消息
MimeMessage msg = new MimeMessage(session);
//设置邮件发送人
msg.setFrom(new InternetAddress(StringUtils.isEmpty(mail
.getSender()) ? mailPro
.getProperty(MailProperties.MAIL_SMTP_USER) : mail
.getSender()));
//分别设置邮件的收件人、抄送人和密送人
msg.setRecipients(Message.RecipientType.TO, strListToInternetAddresses(mail.getRecipientsTo()));
msg.setRecipients(Message.RecipientType.CC, strListToInternetAddresses(mail.getRecipientsCc()));
msg.setRecipients(Message.RecipientType.BCC, strListToInternetAddresses(mail.getRecipientsBcc()));
//设置邮件主题
msg.setSubject(mail.getSubject());
Multipart mp = new MimeMultipart();
//创建邮件主体内容
MimeBodyPart mbp1 = new MimeBodyPart();
mbp1.setText(mail.getBody());
mp.addBodyPart(mbp1);
if(!CollectionUtils.isEmpty(mail.getAttachments())){
//循环添加邮件附件
MimeBodyPart attach = null;
for(String path : mail.getAttachments()){
attach = new MimeBodyPart();
try {
attach.attachFile(path);
mp.addBodyPart(attach);
} catch (IOException e) {
if (logger.isErrorEnabled()) {
logger.error(e);
}
}
}
}
msg.setContent(mp);
msg.setSentDate(new Date());
//邮件开始发送
Transport.send(msg);
} catch (AddressException e) {
if (logger.isErrorEnabled()) {
logger.error(e);
}
} catch (MessagingException e) {
if (logger.isErrorEnabled()) {
logger.error(e);
}
}
}
};
//使用Executor框架的线程池执行邮件发送任务
executor.execute(task);
return true;
}
/**
* 将列表中的字符串转换成InternetAddress对象
* @param list 邮件字符串地址列表
* @return InternetAddress对象数组
*/
private InternetAddress[] strListToInternetAddresses(List<String> list) {
if (list == null || list.isEmpty()) {
return null;
}
int size = list.size();
InternetAddress[] arr = new InternetAddress[size];
for (int i = 0; i < size; i++) {
try {
arr[i] = new InternetAddress(list.get(i));
} catch (AddressException e) {
e.printStackTrace();
}
}
return arr;
}
}
分享到：
！
相关推荐
win7修复本地系统工具
《自动化专业英语》04-Automatic-Detection-Block(自动检测模块).ppt
《计算机专业英语》chapter12-Intelligent-Transportation.ppt
内容概要：本文详细介绍了基于西门子S7-1200博图平台的3轴伺服螺丝机程序。该程序使用SCL语言编写，结合KTP700组态和TIA V14及以上版本，实现了对X、Y、Z三个轴的精密控制。文章首先概述了程序的整体架构，强调了其在自动化控制领域的高参考价值。接着深入探讨了关键代码片段，如轴初始化、运动控制以及主程序的设计思路。此外，还展示了如何通过KTP700组态实现人机交互，并分享了一些实用的操作技巧和技术细节，如状态机设计、HMI交互、异常处理等。 适用人群：从事自动化控制系统开发的技术人员，尤其是对西门子PLC编程感兴趣的工程师。 使用场景及目标：适用于希望深入了解西门子S7-1200博图平台及其SCL语言编程特点的学习者；旨在帮助读者掌握3轴伺服系统的具体实现方法，提高实际项目中的编程能力。 其他说明：文中提供的代码示例和设计理念不仅有助于理解和学习，还能直接应用于类似的实际工程项目中。
内容概要：本文详细探讨了五种非线性滤波器（卡尔曼滤波(KF)、扩展卡尔曼滤波(EKF)、无迹卡尔曼滤波(UKF)、粒子滤波(PF)和变维卡尔曼滤波(VDKF)）在水下长基线定位（LBL）系统中的应用。通过对每种滤波器的具体实现进行MATLAB代码展示，分析了它们在不同条件下的优缺点。例如，KF适用于线性系统但在非线性环境中失效；EKF通过雅可比矩阵线性化处理非线性问题，但在剧烈机动时表现不佳；UKF利用sigma点处理非线性，精度较高但计算量大；PF采用蒙特卡罗方法，鲁棒性强但计算耗时；VDKF能够动态调整状态维度，适合信标数量变化的场景。 适合人群：从事水下机器人(AUV)导航研究的技术人员、研究生以及对非线性滤波感兴趣的科研工作者。 使用场景及目标：①理解各种非线性滤波器的工作原理及其在水下定位中的具体应用；②评估不同滤波器在特定条件下的性能，以便为实际项目选择合适的滤波器；③掌握MATLAB实现非线性滤波器的方法和技术。 其他说明：文中提供了详细的MATLAB代码片段，帮助读者更好地理解和实现这些滤波器。此外，还讨论了数值稳定性问题和一些实用技巧，如Cholesky分解失败的处理方法。
VMware-workstation-full-14.1.3-9474260
DeepSeek系列-提示词工程和落地场景.pdf
javaSE阶段面试题
《综合布线施工技术》第5章-综合布线工程测试.ppt
安川机器人NX100使用说明书.pdf
内容概要：本文详细介绍了将M7120型平面磨床的传统继电器控制系统升级为基于西门子S7-1200 PLC的自动化控制系统的过程。主要内容涵盖IO分配、梯形图设计和组态画面实现。通过合理的IO分配，确保了系统的可靠性和可维护性；梯形图设计实现了主控制逻辑、砂轮升降控制和报警逻辑等功能；组态画面则提供了友好的人机交互界面，便于操作和监控。此次改造显著提高了设备的自动化水平、运行效率和可靠性，降低了维护成本。 适合人群：从事工业自动化领域的工程师和技术人员，尤其是熟悉PLC编程和控制系统设计的专业人士。 使用场景及目标：适用于需要进行老旧设备升级改造的企业，旨在提高生产设备的自动化水平和可靠性，降低故障率和维护成本。具体应用场景包括但不限于金属加工行业中的平面磨床等设备的控制系统改造。 其他说明：文中还分享了一些实际调试中的经验和技巧，如急停逻辑的设计、信号抖动的处理方法等，有助于读者在类似项目中借鉴和应用。
chromedriver-linux64-136.0.7103.48.zip
IMG_20250421_180507.jpg
《网络营销策划实务》项目一-网络营销策划认知.ppt
Lianantech_Security-Vulnerabil_1744433229
MybatisCodeHelperNew2019.1-2023.1-3.4.1
【深度学习部署】基于Docker的BERT模型训练与API服务部署：实现代码复用与模型共享
摘 要 传统办法管理信息首先需要花费的时间比较多，其次数据出错率比较高，而且对错误的数据进行更改也比较困难，最后，检索数据费事费力。因此，在计算机上安装火车票订票系统软件来发挥其高效地信息处理的作用，可以规范信息管理流程，让管理工作可以系统化和程序化，同时，火车票订票系统的有效运用可以帮助管理人员准确快速地处理信息。 火车票订票系统在对开发工具的选择上也很慎重，为了便于开发实现，选择的开发工具为Eclipse，选择的数据库工具为Mysql。以此搭建开发环境实现火车票订票系统的功能。其中管理员管理用户，新闻公告。 火车票订票系统是一款运用软件开发技术设计实现的应用系统，在信息处理上可以达到快速的目的，不管是针对数据添加，数据维护和统计，以及数据查询等处理要求，火车票订票系统都可以轻松应对。 关键词：火车票订票系统；SpringBoot框架，系统分析，数据库设计
【ABB机器人】-00标准保养简介.pdf
最新校园跑腿小程序源码 多校版本，多模块，适合跑腿，外卖，表白，二手，快递等校园服务 此版本为独立版本，不需要微擎 直接放入就可以 需要自己准备好后台的服务器，已认证的小程序，备案的域名!