emailserviceimpl.java

野蔷薇论坛源码 java 自己看看吧。 学习用

/* 
 * Created on 2007-2-12
 * Last modified on 2007-9-22
 * Powered by YeQiangWei.com
 */
package com.yeqiangwei.club.service.mail;

import java.io.UnsupportedEncodingException;
import java.security.Security;
import java.util.Date;
import java.util.Properties;

import javax.mail.Authenticator;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;

import org.apache.log4j.Logger;

import com.yeqiangwei.club.exception.ClubException;
import com.yeqiangwei.club.service.ServiceLocator;
import com.yeqiangwei.club.service.ServiceWrapper;
import com.yeqiangwei.club.service.model.BasicInfoModel;
import com.yeqiangwei.club.service.util.BasicInfoService;
import com.yeqiangwei.club.util.MessageUtils;
import com.yeqiangwei.util.Validator;

public class EmailServiceImpl implements MailService{
	
	private static final Logger logger = Logger.getLogger(EmailServiceImpl.class);

	public BasicInfoService getBasicInfoService() {
		return ServiceWrapper.<BasicInfoService>getSingletonInstance(ServiceLocator.BASICINFO);
	}

	public Session getSession() {
		BasicInfoModel basic = this.getBasicInfoService().findOnly();
		final String smtpId = basic.getSmtpId();
		final String smtpPassword = basic.getSmtpPassword();
		Properties props = System.getProperties();
		props.setProperty("mail.smtp.host", basic.getSmtpServer());
		if(basic.getSmtpIsNeedSSL()){ //判断是否有SSL安全套接字验证
			Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider());
			final String SSL_FACTORY = "javax.net.ssl.SSLSocketFactory";
			props.setProperty("mail.smtp.socketFactory.class", SSL_FACTORY);
			props.setProperty("mail.smtp.socketFactory.fallback", "false");
		}
		if(!Validator.isEmpty(basic.getSmtpPort())){
			props.setProperty("mail.smtp.port", basic.getSmtpPort());
			props.setProperty("mail.smtp.socketFactory.port", basic.getSmtpPort());
		}
		if(basic.getSmtpIsNeedPassword()){
			props.setProperty("mail.smtp.auth","true");
		}else{
			props.setProperty("mail.smtp.auth","false");
		}	
		return Session.getDefaultInstance(props, new Authenticator(){
		    protected PasswordAuthentication getPasswordAuthentication() {
		    return new PasswordAuthentication(smtpId, smtpPassword);
		}});
	}

	
	public void sendMail(MailEntry entry) throws ClubException {
		Session session = this.getSession();
		try{
			if(Validator.isEmpty(entry.getSender())){
				entry.setSender(this.getBasicInfoService().findOnly().getEmailSender());
			}
			InternetAddress address = new InternetAddress(entry.getFrom(),entry.getSender());
			MimeMessage msg = new MimeMessage(session);   
			msg.setFrom(address);
			msg.setRecipients(Message.RecipientType.TO, 
					  InternetAddress.parse(entry.getTo(),false));
			msg.setSubject(entry.getSubject());  //设置邮件标题
			msg.setText(entry.getContent());//设置邮件内容
			msg.setSentDate(new Date());  //邮件发送日期
		   	Transport.send(msg);  //执行发送
		}catch(MessagingException e){
			logger.error(e.toString());
			throw new ClubException(MessageUtils.getMessage("error_email_send"));
		} catch (UnsupportedEncodingException e) {
			throw new ClubException(e.getMessage());
		}
	}

	public void sendMail(Session session, MailEntry item) throws ClubException {
		try{
			if(Validator.isEmpty(item.getSender())){
				item.setSender(this.getBasicInfoService().findOnly().getEmailSender());
			}
			if(Validator.isEmpty(item.getFrom())){
				item.setFrom(this.getBasicInfoService().findOnly().getEmailAddress());
			}
			if(Validator.isEmpty(item.getSubject())){
				throw new ClubException(MessageUtils.getMessage("error_empty"));
			}
			if(Validator.isEmpty(item.getContent())){
				throw new ClubException(MessageUtils.getMessage("error_empty"));
			}
			InternetAddress address = new InternetAddress(item.getFrom(),item.getSender());
			MimeMessage msg = new MimeMessage(session);   
			msg.setFrom(address);
			msg.setRecipients(Message.RecipientType.TO,InternetAddress.parse(item.getTo(),false));
			msg.setSubject(item.getSubject());  //设置邮件标题
			msg.setText(item.getContent());//设置邮件内容
			msg.setSentDate(new Date());  //邮件发送日期
		   	Transport.send(msg);  //执行发送
		}catch(MessagingException e){
			logger.error(e.toString());
			throw new ClubException(MessageUtils.getMessage("error_email_send"));
		} catch (UnsupportedEncodingException e) {
			throw new ClubException(e.getMessage());
		}
	}
}