`
Will_Turner
  • 浏览: 69763 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

JavaMail异步邮件发送

阅读更多

      今天把之前写的使用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;
	}

}
 

 

 

0
4
分享到:
评论
9 楼 shy323 2016-12-06  
有个问题
我也这样写的
使用for循环 调用20次
就出现只收到18封邮件的问题
平均每10封掉一封
试了多个发送服务器一样
找不到原因?你的代码尝试过高并发吗

for(int i=0;i<20;i++){
System.out.println("执行中...current-"+(i+1));
MailUtil.sendEmail(to,attachments,subject,content);
}
8 楼 zjqwll 2014-03-05  
CollectionUtils 也放出来嘛
7 楼 zjqwll 2014-03-05  
Will_Turner,StringUtils也放出来嘛,猜来猜去猜不到是什么啊。QQ85583755
6 楼 zjqwll 2014-03-05  
非常不过,很感谢Will_Turner无私奉献
5 楼 LAFEU 2013-11-14  
扫了一眼看真没有线程啊,仔细看看用的线程池!有点晕,不会线程池,学!
4 楼 ssy341 2012-10-20  
Will_Turner 写道
ssy341 写道
没看出哪里异步了

要不你再去翻翻书?

你是使用了线程 ,像三楼说的那样?
3 楼 Shen.Yiyang 2012-10-08  
这跟mail基本没关系啊,任何任务设计成runnable,都可以来异步嘛。。
2 楼 Will_Turner 2012-10-06  
ssy341 写道
没看出哪里异步了

要不你再去翻翻书?
1 楼 ssy341 2012-10-03  
没看出哪里异步了

相关推荐

    自己写的一个基于Javamail的邮件发送客户端

    这个基于 Javamail 的邮件发送客户端项目,显然利用了这一强大的工具来构建一个 Web 界面,用于四川联通电子渠道的邮件服务。下面我们将详细探讨 JavaMail 的核心概念以及如何实现邮件发送客户端。 1. **JavaMail ...

    Android 使用javamail发送邮件

    总的来说,"Android使用javamail发送邮件"这个主题涵盖了Android平台上利用JavaMail API实现邮件发送的基本流程和注意事项,包括设置SMTP服务器、构建邮件消息、处理附件以及可能的安全性和用户体验优化。...

    基于Java消息服务的异步邮件发送技术.pdf

    【基于Java消息服务的异步邮件发送技术】 随着信息技术的发展,电子邮件已经成为企业内外沟通的关键工具。在复杂的业务环境中,为了确保系统的高效运行,邮件发送必须能够异步进行,避免因邮件处理过程影响到核心...

    javamail邮件发送项目

    【javamail邮件发送项目】是一个基于Java技术的邮件发送解决方案,主要利用Spring框架进行配置,结合FreeMarker(FTL)模板技术实现邮件内容的动态生成,并具备异步发送及批量处理邮件的能力,最多可同时处理1000份...

    springboot整合JavaMail,实现异步发送邮件功能

    创建好 Message 对象后, 只需要使用邮件发送API 得到 Transport 对象, 然后把 Message 对象传递给 Transport 对象, 并调用它的发送方法, 就可以把邮件发送给指定的邮件服务器。 (3)、Store 类 javax.mail....

    springboot系列教程(十九):springboot整合JavaMail,实现异步发送邮件功能

    springboot系列教程(十九):springboot整合JavaMail,实现异步发送邮件功能

    javamail批量发送邮件

    System.err.println("邮件发送给 " + recipient + " 失败: " + e.getMessage()); } } ``` 7. **线程安全与性能优化**:如果需要大量并发发送,可以考虑使用线程池,或者将邮件信息存储在队列中,由后台任务进行...

    java javamail 发送邮件 源代码 例子

    Java/javamail发送邮件是Java...总的来说,这些文件覆盖了Java Web开发的多个主题,包括邮件发送、Ajax、MVC模式、数据对象、Excel操作以及客户端脚本语言JavaScript。学习这些内容有助于提升你的Java全栈开发能力。

    WEB项目使用JavaMail 发送邮件

    在WEB项目中,通常我们会把邮件发送的功能封装到一个服务类中,并通过HTTP请求调用。这可能涉及到异常处理、事务管理以及异步发送等复杂逻辑。 总的来说,JavaMail是一个强大的工具,它允许开发者灵活地处理邮件...

    Spring 3.x企业应用开发实战 附录 A - JavaMail 发送邮件

    ### Spring 3.x企业应用开发实战之JavaMail发送邮件知识点详解 #### 一、JavaMail基础知识的...Spring通过对JavaMail的支持,不仅简化了邮件发送的流程,还提高了开发效率,使得开发者能够更加专注于业务逻辑的实现。

    JAVA源码Javamail的邮件收发系统源码/文档

    - **多线程处理**:为了提高效率,可以在后台异步处理邮件发送和接收任务。 - **安全性考虑**:在连接邮件服务器时应使用加密方式(如SSL/TLS),保护用户隐私。 ##### 3. 实现步骤 1. **配置邮件会话**:创建`...

    使用javamail捕获异常发送邮件的jar包

    JavaMail 是一个开源库,用于在Java应用程序中发送和接收电子邮件。它提供了丰富的API,使得开发者可以方便地处理SMTP、POP3、IMAP等邮件协议。...此外,还可以使用异步或定时重试机制来提高邮件发送的成功率。

    javamail-1_3_3_01邮件发送组件

    这个“javamail-1_3_3_01邮件发送组件”指的是 JavaMail 的一个特定版本,即1.3.3_01。这个版本可能包含了对之前版本的改进、修复了某些已知问题,或者增加了新的功能。 在JavaMail中,发送邮件主要依赖`javax.mail...

    Android使用JavaMail后台发送邮件遇到的一些问题

    为确保邮件发送成功,可以考虑使用AlarmManager或者WorkManager来定时发送,或者在用户触发某些事件时立即发送。 最后,考虑到Android的多线程机制,发送邮件的操作应该在异步任务或者IntentService中执行,以免...

    基于Javamail的邮件收发系统-project

    为了提高邮件系统的性能,可以考虑使用多线程处理批量邮件,或者使用异步发送机制。同时,合理设置缓存和连接池也可以提升效率。 8. **测试和调试**: 在开发过程中,可以使用测试邮箱和模拟邮件服务器来测试邮件...

    ActiveMq+SpringMVC实现邮件异步发送

    而在消费者端,需要监听这个队列,接收到消息后执行实际的邮件发送操作,如使用JavaMail API发送邮件。 总的来说,这个项目提供了一种实用的方法,将邮件发送这种可能影响用户体验的操作异步化,从而优化了系统性能...

    javamail邮件发送

    在JavaMail中,邮件发送的过程通常涉及以下步骤: 1. **引入依赖**:首先,你需要在项目中引入JavaMail相关的依赖。如果是Maven项目,可以添加如下的Maven依赖: ```xml &lt;groupId&gt;com.sun.mail&lt;/groupId&gt; ...

    Java通过Exchange协议发送和接收邮件

    5. 发送邮件:使用EmailMessage的send方法将邮件发送出去。 接收邮件部分,主要涉及到查询和处理邮箱中的邮件: 1. 获取Folder对象:通过ExchangeService对象获取Inbox或Drafts等特定文件夹的引用。 2. 查询邮件:...

Global site tag (gtag.js) - Google Analytics