今天把之前写的使用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;
}
}
分享到：
！
相关推荐
这个基于 Javamail 的邮件发送客户端项目，显然利用了这一强大的工具来构建一个 Web 界面，用于四川联通电子渠道的邮件服务。下面我们将详细探讨 JavaMail 的核心概念以及如何实现邮件发送客户端。 1. **JavaMail ...
总的来说，"Android使用javamail发送邮件"这个主题涵盖了Android平台上利用JavaMail API实现邮件发送的基本流程和注意事项，包括设置SMTP服务器、构建邮件消息、处理附件以及可能的安全性和用户体验优化。...
【基于Java消息服务的异步邮件发送技术】 随着信息技术的发展，电子邮件已经成为企业内外沟通的关键工具。在复杂的业务环境中，为了确保系统的高效运行，邮件发送必须能够异步进行，避免因邮件处理过程影响到核心...
【javamail邮件发送项目】是一个基于Java技术的邮件发送解决方案，主要利用Spring框架进行配置，结合FreeMarker（FTL）模板技术实现邮件内容的动态生成，并具备异步发送及批量处理邮件的能力，最多可同时处理1000份...
创建好 Message 对象后， 只需要使用邮件发送API 得到 Transport 对象， 然后把 Message 对象传递给 Transport 对象， 并调用它的发送方法， 就可以把邮件发送给指定的邮件服务器。 (3)、Store 类 javax.mail....
springboot系列教程（十九）：springboot整合JavaMail，实现异步发送邮件功能
System.err.println("邮件发送给 " + recipient + " 失败: " + e.getMessage()); } } ``` 7. **线程安全与性能优化**：如果需要大量并发发送，可以考虑使用线程池，或者将邮件信息存储在队列中，由后台任务进行...
Java/javamail发送邮件是Java...总的来说，这些文件覆盖了Java Web开发的多个主题，包括邮件发送、Ajax、MVC模式、数据对象、Excel操作以及客户端脚本语言JavaScript。学习这些内容有助于提升你的Java全栈开发能力。
在WEB项目中，通常我们会把邮件发送的功能封装到一个服务类中，并通过HTTP请求调用。这可能涉及到异常处理、事务管理以及异步发送等复杂逻辑。 总的来说，JavaMail是一个强大的工具，它允许开发者灵活地处理邮件...
### Spring 3.x企业应用开发实战之JavaMail发送邮件知识点详解 #### 一、JavaMail基础知识的...Spring通过对JavaMail的支持，不仅简化了邮件发送的流程，还提高了开发效率，使得开发者能够更加专注于业务逻辑的实现。
- **多线程处理**：为了提高效率，可以在后台异步处理邮件发送和接收任务。 - **安全性考虑**：在连接邮件服务器时应使用加密方式（如SSL/TLS），保护用户隐私。 ##### 3. 实现步骤 1. **配置邮件会话**：创建`...
JavaMail 是一个开源库，用于在Java应用程序中发送和接收电子邮件。它提供了丰富的API，使得开发者可以方便地处理SMTP、POP3、IMAP等邮件协议。...此外，还可以使用异步或定时重试机制来提高邮件发送的成功率。
这个“javamail-1_3_3_01邮件发送组件”指的是 JavaMail 的一个特定版本，即1.3.3_01。这个版本可能包含了对之前版本的改进、修复了某些已知问题，或者增加了新的功能。 在JavaMail中，发送邮件主要依赖`javax.mail...
为确保邮件发送成功，可以考虑使用AlarmManager或者WorkManager来定时发送，或者在用户触发某些事件时立即发送。 最后，考虑到Android的多线程机制，发送邮件的操作应该在异步任务或者IntentService中执行，以免...
为了提高邮件系统的性能，可以考虑使用多线程处理批量邮件，或者使用异步发送机制。同时，合理设置缓存和连接池也可以提升效率。 8. **测试和调试**： 在开发过程中，可以使用测试邮箱和模拟邮件服务器来测试邮件...
而在消费者端，需要监听这个队列，接收到消息后执行实际的邮件发送操作，如使用JavaMail API发送邮件。 总的来说，这个项目提供了一种实用的方法，将邮件发送这种可能影响用户体验的操作异步化，从而优化了系统性能...
在JavaMail中，邮件发送的过程通常涉及以下步骤： 1. **引入依赖**：首先，你需要在项目中引入JavaMail相关的依赖。如果是Maven项目，可以添加如下的Maven依赖： ```xml <groupId>com.sun.mail</groupId> ...
5. 发送邮件：使用EmailMessage的send方法将邮件发送出去。 接收邮件部分，主要涉及到查询和处理邮箱中的邮件： 1. 获取Folder对象：通过ExchangeService对象获取Inbox或Drafts等特定文件夹的引用。 2. 查询邮件：...