Spring boot 集成邮件通知及线程异步发送

雨点打透心脏的1/2处 2022-05-22 09:51 314阅读 0赞

# 1. 工作中很难避免会有一些需要邮件通知的情况,网络上也有很多邮件模板和工具类 #

**     我们可以先从网上找一个邮件工具类试着体验一下邮件发送然后在进行改造(直接使用工具类也能发送邮件,不过我们每次程序执行时还要调用邮件发送势必会影响我们编写的程序执行效率,尤其对需进行压测的程序不建议直接使用)!**

**       在此提供一篇供参考 [邮件通知工具类][Link 1]       **

# 2. 邮件通知 #

首先我们建一张邮件模板表用于存储邮件模板,如下图

字段意思分别是 id,code,参数个数,模板内容,使用状态值.....后面是记录创建和修改人和时间

![70][]

其次我们**将邮件模板从数据库中读取出来并写入缓存中**(简单的代码在此忽略不做展示和解释)

logger.info("==========加载邮件模板信息===begin========");
    
          List<EmailTemplate> listEmailTemplate = emailTemplateMapper.selectAll();
    
          //本类只有一个属性List<EmailTemplate> emailTemplates 并于使用对象的方式存储数据
    
          EmailTemplateDTO emailTemplateDTO = new EmailTemplateDTO();
    
          emailTemplateDTO.setEmailTemplates(listEmailTemplate);
    
    
    
          redisUtil.setObjectToJson(SystemInitUtil.SYSTEM_EMAIL_TEMPLATE, -1,emailTemplateDTO);

注意需要在**程序启动时或使用时自动加载**实现CommandLineRunner类即可,这个实现简单不做解释;

下面我们就需要实际项目使用了,我们为了**不影响正常程序执行采用另起线程的方式发送邮件**(后面会给我封装好的工具类)

![70 1][]

String assignerEmail ="";   //收件人邮箱,可多个以逗号分隔
    
        String content1 =systemInitUtil.getEmailTempCon("AD-002", new String[] {enterName});
        //根据code返回模板内容
    
        SendEmailThread sendEmailThread = new SendEmailThread(sendEmailUtil,assignerEmail,"入场反馈",content1,null);
    
       new Thread(sendEmailThread, "需求创建系统自动发送邮件").start();

![70 2][]

![70 3][]

![70 4][]

# 工具类的属性值 #

# ![70 5][] #

# 修改后的邮件工具类 #

package com.leon.api.common.utils.email;
    
    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.util.Date;
    import java.util.Properties;
    
    import javax.mail.Address;
    import javax.mail.BodyPart;
    import javax.mail.Multipart;
    import javax.mail.Session;
    import javax.mail.Transport;
    import javax.mail.internet.InternetAddress;
    import javax.mail.internet.MimeBodyPart;
    import javax.mail.internet.MimeMessage;
    import javax.mail.internet.MimeMultipart;
    import javax.mail.internet.MimeUtility;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Configuration;
    
    import com.leon.api.common.utils.StringUtil;
    
    @Configuration
    public class SendEmailUtil {
        private static Logger logger = LoggerFactory.getLogger(SendEmailUtil.class);    
        @Value("${emailTitle}")
        private String emailTitle;    
        
        @Value("${emailAccount}")
        private String emailAccount;
        
        @Value("${emailPassword}")
        private String emailPassword;
        
        @Value("${emailSMTPHost}")
        private String emailSMTPHost;
        
        @Value("${templatePath}")
        private String templatePath;
        
        public static void main(String[] args) {
            SendEmailUtil util = new SendEmailUtil();
            util.sendEmail("***@163.com,***@163.com", "***审批通过,详细可登录系统查看，谢谢！");
        }
    
        /**
         * 邮件发送
         *
         * @param receiveMailAccount
         *            发送邮件地址
         * @param title
         *            主题
         * @param content
         *            内容
         */
        public synchronized void sendEmail(String receiveMailAccount, String content) {
            sendEmail(receiveMailAccount,emailTitle,content,null);
        }
    
        /**
         * 邮件发送
         *
         * @param receiveMailAccount
         *            发送邮件地址
         * @param title
         *            主题
         * @param content
         *            内容
         */
        public synchronized void sendEmail(String receiveMailAccount, String title, String content) {
            sendEmail(receiveMailAccount,title,content,null);
        }
        
        /**
         * 邮件发送
         *
         * @param receiveMailAccount
         *            发送邮件地址    
         * @param title
         *            主题
         * @param content
         *            内容
         * @param ccMailAccount
         *            抄送邮件地址
         */
        public synchronized void sendEmail(String receiveMailAccount, String title, String content,String ccMailAccount) {
            logger.info("==========邮件发送开始=========== ");
            logger.info("邮件发送地址：" + receiveMailAccount);
            logger.info("邮件内容：" + content);
            try {
                String  emailT = getEmailTempalte();
                
                content =  emailT.replace("/**content**/",content);
                
    //            receiveMailAccount = "yhxiangc@isoftstone.com";
    //            ccMailAccount = "yhxiangc@isoftstone.com";
                
                Properties props = new Properties(); // 参数配置
                props.setProperty("mail.transport.protocol", "smtp"); // 使用的协议（JavaMail规范要求）
                props.setProperty("mail.smtp.host", emailSMTPHost); // 发件人的邮箱的 SMTP 服务器地址
                props.setProperty("mail.smtp.auth", "true");
    
                Session session = Session.getInstance(props);
                session.setDebug(true);                
                MimeMessage message = sendMimeMessage(session, receiveMailAccount,ccMailAccount,title,content);
    
                Transport transport = session.getTransport();
                transport.connect(emailAccount, emailPassword);
                transport.sendMessage(message, message.getAllRecipients());
                transport.close();        
            } catch (Exception e) {
                e.printStackTrace();
            }
            logger.info("==========邮件发送完成=========== ");
        }
    
        /**
         * 创建一封只包含文本的简单邮件
         *
         * @param session
         *            和服务器交互的会话
         * @param replyToMail
         *            抄送邮箱
         * @param receiveMail
         *            收件人邮箱
         * @return
         * @throws Exception
         */    
        private static MimeMessage sendMimeMessage(Session session, String receiveMail,String replyToMail, String title, String content)
                throws Exception {
            // 1. 创建一封邮件
            MimeMessage message = new MimeMessage(session);
            Multipart multipart = new MimeMultipart();
            
            // 2. From: 发件人（昵称有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改昵称）
            message.setFrom(new InternetAddress("******@163.com", "系统公共邮箱", "UTF-8"));
    
            // 3. To: 收件人（可以增加多个收件人、抄送、密送）
            if (receiveMail.indexOf(",") < 0) {
                message.setRecipient(MimeMessage.RecipientType.TO,new InternetAddress(receiveMail, receiveMail.split("@")[0], "UTF-8"));
            } else {
                String[] receiveMails = receiveMail.split(",");
                Address[] addresses = new Address[receiveMails.length];
                String mail = "";
                for (int i = 0; i < receiveMails.length; i++) {
                    mail = receiveMails[i];
                    addresses[i] = new InternetAddress(mail, mail.split("@")[0], "UTF-8");
                }
                message.setRecipients(MimeMessage.RecipientType.TO, addresses);                
            }
            
            //抄送
            if(StringUtil.isNotNull(replyToMail) && replyToMail.indexOf(",") < 0) {
                message.setRecipient(MimeMessage.RecipientType.CC,new InternetAddress(replyToMail, replyToMail.split("@")[0], "UTF-8"));
            } else if(StringUtil.isNotNull(replyToMail) && replyToMail.indexOf(",") > 0) {
                String[] replyToMails = replyToMail.split(",");
                Address[] addresses = new Address[replyToMails.length];
                String ccAddresses = "";
                for(int i = 0; i < replyToMails.length; i++) {
                    ccAddresses = replyToMails[i];
                    addresses[i] = new InternetAddress(ccAddresses, ccAddresses.split("@")[0], "UTF-8");
                }
                message.setRecipients(MimeMessage.RecipientType.CC, addresses);
            }        
    
            // 4. Subject: 邮件主题（标题有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改标题）
            message.setSubject(MimeUtility.encodeText(title, "UTF-8", "B"));
    
            BodyPart bodyPart = new MimeBodyPart();  
            bodyPart.setContent(content, "text/html;charset=utf-8");
            multipart.addBodyPart(bodyPart);
            
            // 5. Content: 邮件正文（可以使用html标签）（内容有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改发送内容）
            message.setContent(multipart);        
    
            // 6. 设置发件时间
            message.setSentDate(new Date());
    
            // 7. 保存设置
            message.saveChanges();
            
            return message;
        }
        
        @SuppressWarnings("resource")
        private String getEmailTempalte() {
            String filePath = this.getClass().getResource("/").getPath();        
            filePath = filePath+"emailTemplate.html";
            if(filePath.indexOf("%20") >= 0){
                filePath = filePath.replaceAll("%20", " ");
            }
            logger.info("当前操作系统："+System.getProperties().get("os.name").toString().toUpperCase());
            if (System.getProperties().get("os.name").toString().toUpperCase().indexOf("WINDOWS") >= 0) {
                filePath = filePath.substring(1,filePath.length());
            }else {
                filePath = this.templatePath;
            }
            logger.info("=======filePath====="+filePath);
            InputStreamReader isr = null;
            try {
                isr = new InputStreamReader(new FileInputStream(new File(filePath)), "UTF-8");
                BufferedReader input = new BufferedReader(isr);
                StringBuffer buffer = new StringBuffer();
                String text;
                while ((text = input.readLine()) != null) {
                    buffer.append(text + "\n");
                }
                logger.info("=======buffer====="+buffer.length());
                return buffer.toString();
            } catch (FileNotFoundException e) {            
                logger.error("文件获取错误：",e);
            } catch (IOException e) {            
                logger.error("文件输出错误：",e);
            }
            return "";
        }
        
    
    }

# 线程处理 邮件发送 #

package com.leon.api.common.utils.email;
    
    import java.text.MessageFormat;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    public class SendEmailThread implements Runnable{
        
        private Logger logger = LoggerFactory.getLogger(SendEmailThread.class);
        
        private String receiveMailAccount;//收件邮箱
        
        private String title;//标题
        
        private String content;//内容
        
        private String ccMailAccount;//抄送
        
        private SendEmailUtil sendEmailUtil;// 发送邮件
        
        public SendEmailThread(SendEmailUtil sendEmailUtil,String receiveMailAccount, String title, String content,String ccMailAccount) {
            this.receiveMailAccount = receiveMailAccount;
            this.title = title;
            this.content = content;
            this.ccMailAccount = ccMailAccount;
            this.sendEmailUtil = sendEmailUtil;
        }
        
        @Override
        public void run() {
            try {
                sendEmailUtil.sendEmail(this.receiveMailAccount,this.title,this.content);
            } catch (Exception e) {
                logger.info(MessageFormat.format("邮件发送失败,收件人:{0}抄送:{1},标题:{2}内容:{3}", this.receiveMailAccount,this.ccMailAccount,this.title, this.content));
                e.printStackTrace();
            }
        }
        //get/set忽略
    }

# 注意:拓展一种方式,使用线程池发送 #

以下是邮件模板内容获取和邮件工具类的注入

![20190307174800790.png][]

**调用方式:**

![20190307175006242.png][]

**优化后的工具类 **

import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Properties;
    
    import javax.activation.DataHandler;
    import javax.activation.DataSource;
    import javax.activation.FileDataSource;
    import javax.mail.Address;
    import javax.mail.BodyPart;
    import javax.mail.MessagingException;
    import javax.mail.Multipart;
    import javax.mail.SendFailedException;
    import javax.mail.Session;
    import javax.mail.Transport;
    import javax.mail.internet.InternetAddress;
    import javax.mail.internet.MimeBodyPart;
    import javax.mail.internet.MimeMessage;
    import javax.mail.internet.MimeMultipart;
    import javax.mail.internet.MimeUtility;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.Async;
    import org.springframework.util.StringUtils;
    
    import com.isoftstone.api.system.entity.Users;
    import com.isoftstone.common.utils.StringUtil;
    import com.isoftstone.common.utils.web.JsonResult;
    import com.isoftstone.common.utils.web.StatusUtil;
    
    @Configuration
    public class SendEmailUtil{
    	
    	private static Logger logger = LoggerFactory.getLogger(SendEmailUtil.class);
    	
    	private static String templateStr;
    	private static DataSource dataPic;	
    	private String tempFileName = "emailTemplate.html";
    	private boolean havePic = true;//控制是否需要签名图片
    	private boolean haveCon = true;//控制是否需要邮件内容
    	private String passUrl = ""; //审批邮件审批通过URL
    	private String notPassUrl = "";//审批邮件审批不通过URL
    	private Users users = null;
    	private String signatureInfo = null;
    	public final static String SUBMIT_EMAIL_TYPE_SCR="screening";//简历筛选
    	
    	@Value("${emailTitle}")
    	private String emailTitle;	
    	
    	@Value("${emailAccount}")
    	private String emailAccount;
    	
    	@Value("${emailPassword}")
    	private String emailPassword;
    	
    	@Value("${emailNickname}")
    	private String emailNickname;
    	
    	@Value("${emailSMTPHost}")
    	private String emailSMTPHost;
    	
    	@Value("${templatePath}")
    	private String templatePath;
    	
    	
    			
    	public Users getUsers() {
    		return users;
    	}
    
    	public void setUsers(Users users) {
    		this.users = users;
    	}
    
    	//用于动态获取模版文件名称
    	public  String getTempFileName() {
    		return tempFileName;
    	}
    
    	public  void setTempFileName(String tempFileName) {
    		this.tempFileName = tempFileName;
    	}
    	
    	//用于判断是否需要签名图片
    	public boolean isHavePic() {
    		return havePic;
    	}
    
    	public void setHavePic(boolean havePic) {
    		this.havePic = havePic;
    	}	
    	
        //用于判断是否需要内容
    	public boolean isHaveCon() {
    		return haveCon;
    	}
    
    	public void setHaveCon(boolean haveCon) {
    		this.haveCon = haveCon;
    	}
    	
    	//获取签名信息
    	public String getSignatureInfo() {
    		return signatureInfo;
    	}
    
    	public void setSignatureInfo(String signatureInfo) {
    		this.signatureInfo = signatureInfo;
    	}
    	
    	//审批邮件审批通过URL
    	public String getPassUrl() {
    		return passUrl;
    	}
    
    	public void setPassUrl(String passUrl) {
    		this.passUrl = passUrl;
    	}
    	
    	//审批邮件审批不通过URL
    	public String getNotPassUrl() {
    		return notPassUrl;
    	}
    
    	public void setNotPassUrl(String notPassUrl) {
    		this.notPassUrl = notPassUrl;
    	}
    
    	public static void main(String[] args) {
    		SendEmailUtil util = new SendEmailUtil();	
    		util.sendEmail("weiluof@isoftstone.com,yhxiangc@isoftstone.com", "您提交的需求申请已审批通过，请您持续关注后续状态，详细可登录系统查看，谢谢！");
    	}
    
    	/**
    	 * 邮件发送
    	 * 
    	 * @param receiveMailAccount
    	 *            发送邮件地址
    	 * @param title
    	 *            主题
    	 * @param content
    	 *            内容
    	 */
    	public void sendEmail(String receiveMailAccount, String content) {
    		sendEmail(receiveMailAccount,emailTitle,content,null,new File[]{},false);
    	}
    
    	/**
    	 * 邮件发送
    	 * 
    	 * @param receiveMailAccount
    	 *            发送邮件地址
    	 * @param title
    	 *            主题
    	 * @param content
    	 *            内容
    	 */
    	@Async("threadPoolTaskExecutor")
    	public void sendEmail(String receiveMailAccount, String title, String content) {
    		sendEmail(receiveMailAccount,title,content,null,new File[]{},false);
    	}
    	
    	/**
    	 * 邮件发送
    	 * 
    	 * @param receiveMailAccount
    	 *            发送邮件地址
    	 * @param title
    	 *            主题
    	 * @param content
    	 *            内容
    	 */
    	@Async("threadPoolTaskExecutor")
    	public void sendEmail(String receiveMailAccount, String title, String content,String ccMailAccount) {
    		sendEmail(receiveMailAccount,title,content,ccMailAccount,new File[]{},false);
    	}
    	
    	/**
    	 * 邮件发送
    	 * @param receiveMailAccount 接收人地址
    	 * @param title 标题
    	 * @param content 内容
    	 * @param ccMailAccount 抄送邮件地址 
    	 * @param attcFile  附件
    	 * @param isDelete  发送完成是否删除附件
    	 */
    	@Async("threadPoolTaskExecutor")
    	public JsonResult sendEmail(String receiveMailAccount, String title, String content,String ccMailAccount,File[] attcFile,boolean isDelete) {
    		return sendEmailByBatch(receiveMailAccount, title, content, ccMailAccount, attcFile, isDelete);
    	}
    	
    	/**
    	 * 邮件发送
    	 * @param receiveMailAccount 接收人地址
    	 * @param title 标题
    	 * @param content 内容
    	 * @param ccMailAccount 抄送邮件地址 
    	 * @param attcFile  附件
    	 */
    	@Async("threadPoolTaskExecutor")
    	public void sendEmail(String receiveMailAccount, String title, String content,String ccMailAccount,File attcFile) {
    		sendEmail(receiveMailAccount,title,content,ccMailAccount,new File[]{attcFile},true);
    	}
    	
    	/**
    	 * 审批邮件发送
    	 * @param receiveMailAccount 接收人地址
    	 * @param title 标题
    	 * @param content 内容
    	 * @param attcFile  附件
    	 * @param isDelete  发送完成是否删除附件
    	 */
    	@Async("threadPoolTaskExecutor")
    	public JsonResult sendSubmitEmail(String receiveMailAccount, String title, String content,String submitType,File[] attcFile,boolean isDelete) {
    		return sendSubmitEmailByBatch(receiveMailAccount, title, content, submitType, attcFile, isDelete);
    	}
    
    	/**
    	 * 创建一封只包含文本的简单邮件
    	 *
    	 * @param session
    	 *            和服务器交互的会话
    	 * @param replyToMail
    	 *            抄送邮箱
    	 * @param receiveMail
    	 *            收件人邮箱
    	 * @return
    	 * @throws Exception
    	 */	
    	private MimeMessage sendMimeMessage(Session session, String receiveMail,String replyToMail, String title, String content,File[] attcFile)
    			throws Exception {
    		// 1. 创建一封邮件
    		MimeMessage message = new MimeMessage(session);
    		Multipart multipart = new MimeMultipart("mixed");
    		HashMap<String,String> recAddMap = new HashMap<String,String>();//主送邮箱
    		HashMap<String,String> repAddMap = new HashMap<String,String>();//抄送邮箱
    		if(StringUtils.isEmpty(receiveMail)){
    			throw new RuntimeException("邮件主送地址为空！");
    		}
    		
    		BodyPart bodyPart = null; 
    		
    		if(isHavePic()){
    			bodyPart = new MimeBodyPart();			
    			dataPic = getEmailAutographPic();					
    			bodyPart.setDataHandler(new DataHandler(dataPic));		
    			bodyPart.setHeader("Content-ID", "<logobottomPic>");
    			multipart.addBodyPart(bodyPart);
    		}
    		
    		//加入附件
    		long beginTime = System.currentTimeMillis();
    		if(attcFile != null && attcFile.length > 0 ) {
    			for(File sub : attcFile){
    				if(sub!=null){
    					bodyPart = new MimeBodyPart();
    					bodyPart.setDataHandler(new DataHandler(new FileDataSource(sub)));	
    					if (System.getProperties().get("os.name").toString().toUpperCase().indexOf("WINDOWS") >= 0) {
    						bodyPart.setFileName(MimeUtility.encodeText(sub.getName(),"GBK","B"));
    					}else{
    						bodyPart.setFileName(MimeUtility.encodeText(sub.getName(),"UTF-8","B"));
    					}				
    					multipart.addBodyPart(bodyPart);
    				}
    			}
    		}
    		logger.info("=========附件读取时间==========="+(System.currentTimeMillis()-beginTime)/1000+"秒");
    		
    		// 2. From: 发件人（昵称有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改昵称）
    		message.setFrom(new InternetAddress(emailAccount, emailNickname, "UTF-8"));
    
    		// 3. To: 收件人（可以增加多个收件人、抄送、密送）
    		if (receiveMail.indexOf(",") < 0) {
    			message.setRecipient(MimeMessage.RecipientType.TO,new InternetAddress(receiveMail, receiveMail.split("@")[0], "UTF-8"));
    		} else {
    			String[] receiveMails = receiveMail.split(",");
    			for (int i = 0; i < receiveMails.length; i++) {
    				recAddMap.put(receiveMails[i], "is");
    			}
    			Iterator<Entry<String, String>> iter = recAddMap.entrySet().iterator();
    			Address[] addresses = new Address[recAddMap.size()];
    			String mail = "";
    			Map.Entry<String,String> entry = null;
    			int i = 0;
    			while (iter.hasNext()) {
    				entry = (Map.Entry<String,String>) iter.next();
    				mail = entry.getKey();
    				addresses[i] = new InternetAddress(mail, mail.split("@")[0], "UTF-8");
    				i++;
    			}
    			if(addresses.length > 0 ){
    				message.setRecipients(MimeMessage.RecipientType.TO, addresses);	
    			}
    		}
    		
    		//抄送
    		if(StringUtil.isNotNull(replyToMail) && replyToMail.indexOf(",") < 0) {
    			if(receiveMail.toLowerCase().indexOf(replyToMail.toLowerCase()) < 0){
    				message.setRecipient(MimeMessage.RecipientType.CC,new InternetAddress(replyToMail, replyToMail.split("@")[0], "UTF-8"));
    			}			
    		} else if(StringUtil.isNotNull(replyToMail) && replyToMail.indexOf(",") > 0) {
    			String[] replyToMails = replyToMail.split(",");
    			for (int i = 0; i < replyToMails.length; i++) {
    				//如果主送中没有，则抄送
    				if(recAddMap.get(replyToMails[i]) == null){
    					repAddMap.put(replyToMails[i], "is");
    				}
    			}
    			Iterator<Entry<String, String>> iter = repAddMap.entrySet().iterator();
    			Address[] addresses = new Address[repAddMap.size()];			
    			String ccAddresses = "";
    			Map.Entry<String,String> entry = null;
    			int i = 0;
    			while (iter.hasNext()) {
    				entry = (Map.Entry<String,String>) iter.next();
    				ccAddresses = entry.getKey();						
    				addresses[i] = new InternetAddress(ccAddresses, ccAddresses.split("@")[0], "UTF-8");
    				i++;
    			}
    			if(addresses.length > 0 ){
    				message.setRecipients(MimeMessage.RecipientType.CC, addresses);
    			}
    		}		
    
    		// 4. Subject: 邮件主题（标题有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改标题）
    		message.setSubject(MimeUtility.encodeText(title, "UTF-8", "B"));
    
    		bodyPart = new MimeBodyPart();
    		if(isHaveCon()){
    			bodyPart.setContent(content, "text/html;charset=utf-8"); 
    		}else{
    			bodyPart.setContent("", "text/html;charset=utf-8"); 
    		}
            multipart.addBodyPart(bodyPart);
            
    		// 5. Content: 邮件正文（可以使用html标签）（内容有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改发送内容）        
    		message.setContent(multipart);		
    
    		// 6. 设置发件时间
    		message.setSentDate(new Date());
    
    		// 7. 保存设置
    		message.saveChanges();
    		
    		return message;
    	}
    	
    	/**
    	 * 创建一封审批邮件
    	 *
    	 * @param session
    	 *            和服务器交互的会话
    	 * @param receiveMail
    	 *            收件人邮箱
    	 * @return
    	 * @throws Exception
    	 */	
    	private MimeMessage sendSubmitMimeMessage(Session session, String receiveMail,String title, String content,String submitType,File[] attcFile)
    			throws Exception {
    		// 1. 创建一封邮件
    		MimeMessage message = new MimeMessage(session);
    		Multipart multipart = new MimeMultipart("mixed");
    		HashMap<String,String> recAddMap = new HashMap<String,String>();//主送邮箱
    		if(StringUtils.isEmpty(receiveMail)){
    			throw new RuntimeException("邮件主送地址为空！");
    		}
    		
    		BodyPart bodyPart = null; 		
    		
    //		//邮件中多个图片
    //		bodyPart = new MimeBodyPart();			
    //		dataPic = getEmailAutographPic();					
    //		bodyPart.setDataHandler(new DataHandler(dataPic));		
    //		bodyPart.setHeader("Content-ID", "<logobottomPic>");
    //		multipart.addBodyPart(bodyPart);
    //		bodyPart = new MimeBodyPart();			
    //		dataPic = getEmailAutographPic("notpass.png");					
    //		bodyPart.setDataHandler(new DataHandler(dataPic));		
    //		bodyPart.setHeader("Content-ID", "<notpassPic>");
    //		multipart.addBodyPart(bodyPart);
    //		bodyPart = new MimeBodyPart();
    //		dataPic = getEmailAutographPic("pass.png");					
    //		bodyPart.setDataHandler(new DataHandler(dataPic));		
    //		bodyPart.setHeader("Content-ID", "<passPic>");
    //		multipart.addBodyPart(bodyPart);
    //		bodyPart = new MimeBodyPart();
    //		dataPic = getEmailAutographPic("banner_"+submitType+".png");				
    //		bodyPart.setDataHandler(new DataHandler(dataPic));		
    //		bodyPart.setHeader("Content-ID", "<bannerPic>");
    //		multipart.addBodyPart(bodyPart);
    		
    		
    		//加入附件
    		long beginTime = System.currentTimeMillis();
    		if(attcFile != null && attcFile.length > 0 ) {
    			for(File sub : attcFile){
    				if(sub!=null){
    					bodyPart = new MimeBodyPart();
    					bodyPart.setDataHandler(new DataHandler(new FileDataSource(sub)));	
    					if (System.getProperties().get("os.name").toString().toUpperCase().indexOf("WINDOWS") >= 0) {
    						bodyPart.setFileName(MimeUtility.encodeText(sub.getName(),"GBK","B"));
    					}else{
    						bodyPart.setFileName(MimeUtility.encodeText(sub.getName(),"UTF-8","B"));
    					}				
    					multipart.addBodyPart(bodyPart);
    				}
    			}
    		}
    		logger.info("=========附件读取时间==========="+(System.currentTimeMillis()-beginTime)/1000+"秒");
    		
    		// 2. From: 发件人（昵称有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改昵称）
    		message.setFrom(new InternetAddress(emailAccount, emailNickname, "UTF-8"));
    
    		// 3. To: 收件人（可以增加多个收件人、抄送、密送）
    		if (receiveMail.indexOf(",") < 0) {
    			message.setRecipient(MimeMessage.RecipientType.TO,new InternetAddress(receiveMail, receiveMail.split("@")[0], "UTF-8"));
    		} else {
    			String[] receiveMails = receiveMail.split(",");
    			for (int i = 0; i < receiveMails.length; i++) {
    				recAddMap.put(receiveMails[i], "is");
    			}
    			Iterator<Entry<String, String>> iter = recAddMap.entrySet().iterator();
    			Address[] addresses = new Address[recAddMap.size()];
    			String mail = "";
    			Map.Entry<String,String> entry = null;
    			int i = 0;
    			while (iter.hasNext()) {
    				entry = (Map.Entry<String,String>) iter.next();
    				mail = entry.getKey();
    				addresses[i] = new InternetAddress(mail, mail.split("@")[0], "UTF-8");
    				i++;
    			}
    			if(addresses.length > 0 ){
    				message.setRecipients(MimeMessage.RecipientType.TO, addresses);	
    			}
    		}
    
    		// 4. Subject: 邮件主题（标题有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改标题）
    		message.setSubject(MimeUtility.encodeText(title, "UTF-8", "B"));
    
    		bodyPart = new MimeBodyPart();
    		if(isHaveCon()){
    			bodyPart.setContent(content, "text/html;charset=utf-8"); 
    		}else{
    			bodyPart.setContent("", "text/html;charset=utf-8"); 
    		}
            multipart.addBodyPart(bodyPart);
            
    		// 5. Content: 邮件正文（可以使用html标签）（内容有广告嫌疑，避免被邮件服务器误认为是滥发广告以至返回失败，请修改发送内容）        
    		message.setContent(multipart);		
    
    		// 6. 设置发件时间
    		message.setSentDate(new Date());
    
    		// 7. 保存设置
    		message.saveChanges();
    		
    		return message;
    	}
    	
    //	@SuppressWarnings("resource")
    	public String getEmailTempalte() {
    		String filePath = this.getClass().getResource("/").getPath();	
    		if(filePath.indexOf("%20") >= 0){
    			filePath = filePath.replaceAll("%20", " ");
    		}
    		logger.info("当前操作系统："+System.getProperties().get("os.name").toString().toUpperCase());
    		if (System.getProperties().get("os.name").toString().toUpperCase().indexOf("WINDOWS") >= 0) {
    			filePath = filePath.substring(1,filePath.length());
    		}else {
    			filePath = this.templatePath;
    		}		
    		filePath += getTempFileName();		
    		logger.info("=======filePath====="+filePath);
    		InputStreamReader isr = null;
    		try {
    			isr = new InputStreamReader(new FileInputStream(new File(filePath)), "UTF-8");
    			BufferedReader input = new BufferedReader(isr);
                StringBuffer buffer = new StringBuffer();
                String text;
                while ((text = input.readLine()) != null) {
                    buffer.append(text + "\n");
                } 
                logger.info("=======buffer====="+buffer.length());
                return buffer.toString();
    		} catch (FileNotFoundException e) {			
    			logger.error("文件获取错误：",e);
    		} catch (IOException e) {			
    			logger.error("文件输出错误：",e);
    		}
    		return "";
    	}
    	
    	/**
    	 * 获取图片签名
    	 * @return
    	 */	
    	private DataSource getEmailAutographPic() {
    		String filePath = this.getClass().getResource("/").getPath();		
    		filePath = filePath+"logobottom.jpg";
    		if(filePath.indexOf("%20") >= 0){
    			filePath = filePath.replaceAll("%20", " ");
    		}
    		logger.info("当前操作系统："+System.getProperties().get("os.name").toString().toUpperCase());
    		if (System.getProperties().get("os.name").toString().toUpperCase().indexOf("WINDOWS") >= 0) {
    			filePath = filePath.substring(1,filePath.length());
    		}else {
    			filePath = this.templatePath + "logobottom.jpg";
    		}	
    		DataSource dataSource = new FileDataSource(new File(filePath)); 
    		return dataSource;		
    	}
    	
    	/**
    	 * 获取图片签名
    	 * @return
    	 */	
    	private DataSource getEmailAutographPic(String picName) {
    		String filePath = this.getClass().getResource("/").getPath();		
    		filePath = filePath+picName;
    		if(filePath.indexOf("%20") >= 0){
    			filePath = filePath.replaceAll("%20", " ");
    		}
    		logger.info("当前操作系统："+System.getProperties().get("os.name").toString().toUpperCase());
    		if (System.getProperties().get("os.name").toString().toUpperCase().indexOf("WINDOWS") >= 0) {
    			filePath = filePath.substring(1,filePath.length());
    		}else {
    			filePath = this.templatePath + picName;
    		}	
    		DataSource dataSource = new FileDataSource(new File(filePath)); 
    		return dataSource;		
    	}
    	
    	/**
    	 * 大量发送邮件,不加线程池注解
    	 * @param receiveMailAccount
    	 * @param title
    	 * @param content
    	 * @param ccMailAccount
    	 * @param attcFile
    	 * @param isDelete
    	 * @return
    	 */
    	public JsonResult sendEmailByBatch(String receiveMailAccount, String title, String content,String ccMailAccount,File[] attcFile,boolean isDelete) {
    		logger.info("==========邮件发送开始=========== ");
    		logger.info("邮件发送地址：" + receiveMailAccount);
    		logger.info("邮件内容：" + content);
    		Transport transport = null;
    		try {			
    			templateStr = getEmailTempalte();						
    			content =  templateStr.replace("/**content**/",content);
    			
    			if(!"emailTemplate.html".equals(getTempFileName()) && StringUtil.isNotNull(content)){				
    				String signature = "";	
    				if(StringUtil.isNotNull(getSignatureInfo())){
    					signature = getSignatureInfo();
    				}else{
    					signature += "	<div class=\"bottom-title\">"
    							+"<b><span style=\"font-family:'微软雅黑',sans-serif;font-size:16px\">"+getUsers().getSurName()+"</span></b><br/>"
    							+"T&C高科技服务事业本部<br/>"
    							+"软通动力信息技术（集团）有限公司<br/>"
    						    +"<span class=\"red_word\">手机:</span>"+getUsers().getMobile()+"<br/>"
    							+"www.isoftstone.com "
    						    +"</div>";
    				}
    				content = content.replace("/**signature**/", signature);
    			}
    
    			Properties props = new Properties(); // 参数配置
    			props.setProperty("mail.transport.protocol", "smtp"); // 使用的协议（JavaMail规范要求）
    			props.setProperty("mail.smtp.host", emailSMTPHost); // 发件人的邮箱的 SMTP 服务器地址
    			props.setProperty("mail.smtp.auth", "true");
    			props.setProperty("mail.smtp.timeout", "10000");//设置超时时间
    
    			//文件名超过60个字符时出现被截断的问题
    			System.getProperties().setProperty("mail.mime.splitlongparameters", "false");
    			
    			Session session = Session.getInstance(props);
    			session.setDebug(false);				
    			MimeMessage message = sendMimeMessage(session, receiveMailAccount,ccMailAccount,title,content,attcFile);
    
    			transport = session.getTransport();
    			long beginTime = System.currentTimeMillis();
    			transport.connect(emailAccount, emailPassword);
    			logger.info("==========连接邮件服务器时间=========== "+(System.currentTimeMillis()-beginTime)/1000+"秒");
    			beginTime = System.currentTimeMillis();
    			transport.sendMessage(message, message.getAllRecipients());
    			logger.info("==========邮件发送时间=========== "+(System.currentTimeMillis()-beginTime)/1000+"秒");
    			transport.close();	
    			logger.info("==========邮件发送完成=========== ");
    			return new JsonResult(StatusUtil.SUCCESS,"发送成功");
    		} catch (SendFailedException e) {
    			logger.error("系统错误:",e);
    			String message = e.getMessage();
    			if(message.contains("Invalid Addresses")){
    				return new JsonResult(StatusUtil.EMAIL_ERROR,"邮件地址不存在");
    			}else if(message.contains("too much mail from")){		    	
    		    	return new JsonResult(StatusUtil.EMAIL_ERROR,"邮件发送太频繁");
    			}else{
    				return new JsonResult(StatusUtil.ERROR,"发送失败");
    			}
    		} catch (Exception e) {
    			logger.error("系统错误:",e);
    			return new JsonResult(StatusUtil.ERROR,"发送失败");
    		} finally {
    			if(transport != null){
    				try {
    					logger.info("====邮件发送完成=====transport==关闭=========");	
    					transport.close();
    				} catch (MessagingException e) {					
    					e.printStackTrace();
    					logger.error("关闭transport错误:",e);
    				}
    			}
    			if(attcFile != null && attcFile.length > 0 && isDelete) {
    				logger.info("===邮件发送完成======附件删除=========");	
    				for(File sub : attcFile){
    					if(sub != null){
    						sub.delete();
    					}
    				}
    			}
    			tempFileName = "emailTemplate.html";
    			transport = null;
    			templateStr = null;
    			havePic = true;
    			haveCon = true;
    			logger.info("===邮件发送完成======初始化静态变量=========");	
    		}
    	}
    	
    	/**
    	 * 发送审批邮件,不加线程池注解
    	 * @param receiveMailAccount
    	 * @param title
    	 * @param content
    	 * @param submitType
    	 * @param attcFile
    	 * @param isDelete
    	 * @return
    	 */
    	public JsonResult sendSubmitEmailByBatch(String receiveMailAccount, String title, String content,String submitType,File[] attcFile,boolean isDelete) {
    		logger.info("==========邮件发送开始=========== ");
    		logger.info("邮件发送地址：" + receiveMailAccount);
    		logger.info("邮件内容：" + content);
    		Transport transport = null;
    		try {
    			setTempFileName("emailTemplateSubmit.html");
    			templateStr = getEmailTempalte();						
    			content =  templateStr.replace("/**content**/",content);	
    			content =  content.replace("/**passUrl**/",getPassUrl());
    			content =  content.replace("/**notpassUrl**/",getNotPassUrl());
    
    			Properties props = new Properties(); // 参数配置
    			props.setProperty("mail.transport.protocol", "smtp"); // 使用的协议（JavaMail规范要求）
    			props.setProperty("mail.smtp.host", emailSMTPHost); // 发件人的邮箱的 SMTP 服务器地址
    			props.setProperty("mail.smtp.auth", "true");
    			props.setProperty("mail.smtp.timeout", "10000");//设置超时时间
    
    			//文件名超过60个字符时出现被截断的问题
    			System.getProperties().setProperty("mail.mime.splitlongparameters", "false");
    			
    			Session session = Session.getInstance(props);
    			session.setDebug(false);				
    			MimeMessage message = sendSubmitMimeMessage(session, receiveMailAccount,title,content,submitType,attcFile);
    
    			transport = session.getTransport();
    			long beginTime = System.currentTimeMillis();
    			transport.connect(emailAccount, emailPassword);
    			logger.info("==========连接邮件服务器时间=========== "+(System.currentTimeMillis()-beginTime)/1000+"秒");
    			beginTime = System.currentTimeMillis();
    			transport.sendMessage(message, message.getAllRecipients());
    			logger.info("==========邮件发送时间=========== "+(System.currentTimeMillis()-beginTime)/1000+"秒");
    			transport.close();	
    			logger.info("==========邮件发送完成=========== ");
    			return new JsonResult(StatusUtil.SUCCESS,"发送成功");
    		} catch (SendFailedException e) {
    			logger.error("系统错误:",e);
    			String message = e.getMessage();
    			if(message.contains("Invalid Addresses")){
    				return new JsonResult(StatusUtil.EMAIL_ERROR,"邮件地址不存在");
    			}else if(message.contains("too much mail from")){		    	
    		    	return new JsonResult(StatusUtil.EMAIL_ERROR,"邮件发送太频繁");
    			}else{
    				return new JsonResult(StatusUtil.ERROR,"发送失败");
    			}
    		} catch (Exception e) {
    			logger.error("系统错误:",e);
    			return new JsonResult(StatusUtil.ERROR,"发送失败");
    		} finally {
    			if(transport != null){
    				try {
    					logger.info("====邮件发送完成=====transport==关闭=========");	
    					transport.close();
    				} catch (MessagingException e) {					
    					e.printStackTrace();
    					logger.error("关闭transport错误:",e);
    				}
    			}
    			if(attcFile != null && attcFile.length > 0 && isDelete) {
    				logger.info("===邮件发送完成======附件删除=========");	
    				for(File sub : attcFile){
    					if(sub != null){
    						sub.delete();
    					}
    				}
    			}
    			tempFileName = "emailTemplate.html";
    			transport = null;
    			templateStr = null;
    			havePic = true;
    			haveCon = true;
    			passUrl = "";
    			notPassUrl = "";
    			logger.info("===邮件发送完成======初始化静态变量=========");	
    		}
    	}
    	
    }

##  线程池配置: ##

import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    
    /**
    * @author leon
    * @createDate 2018年6月6日 上午11:23:22
    * @version v1.0
    * @classRemarks 线程池配置
    */
    
    @Configuration
    @ConfigurationProperties(prefix="threadpool")
    public class ExecutePoolConfiguration {
    	
    	private static Logger logger = LoggerFactory.getLogger(ExecutePoolConfiguration.class);
    
    	/**
    	 * application.yml 配置方式
    		threadpool:
    		  core-pool-size: 10
    		  max-pool-size: 20
    		  queue-capacity: 1000
    		  keep-alive-seconds: 300
    	 */
        @Value("${threadpool.core-pool-size}")
        private int corePoolSize;
    
        @Value("${threadpool.max-pool-size}")
        private int maxPoolSize;
    
        @Value("${threadpool.queue-capacity}")
        private int queueCapacity;
    
        @Value("${threadpool.keep-alive-seconds}")
        private int keepAliveSeconds;
    
    
        @Bean(name="threadPoolTaskExecutor")
        public ThreadPoolTaskExecutor threadPoolTaskExecutor(){
        	
            ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();
            pool.setKeepAliveSeconds(keepAliveSeconds);
            pool.setCorePoolSize(corePoolSize);//核心线程池数
            pool.setMaxPoolSize(maxPoolSize); // 最大线程
            pool.setQueueCapacity(queueCapacity);//队列容量
            pool.setRejectedExecutionHandler(new java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy()); //队列满，线程被拒绝执行策略
            return pool;
        }
    }

# emailTemplate.html 模板 #

<html>
    <head>
    <meta charset="UTF-8">
    <style>
        .out-container h3{font-size:18px;font-weight: normal;line-height: 26px;color: #3a3a3a;}
        .out-table{border-left: 1px solid #5e6973;border-top: 1px solid #5e6973;}
        .out-table td{border-right: 1px solid #5e6973;border-bottom: 1px solid #5e6973;text-align: center;font-size: 14px;font-weight: normal;padding: 8px 15px;}
        .out-table th{border-right: 1px solid #5e6973;border-bottom: 1px solid #5e6973;text-align: center;font-size: 14px;padding: 8px 15px;background: #e7f1fa;}
        .out-font{font-size: 14px;margin-bottom: 15px;font-family:"微软雅黑";color: #333; margin-top:15px;}
        .out-font span{color:#fc9153;font-size: 18px;}
        .main-box{
            padding-left:20px;        
        }    
        .hello{
            font-weight:bold;
        }
        .box-item{
            width:auto;
            margin-left:32px;
        }
        .box-item span{
            display:block;
            height:28px;
            line-height:28px;
            color:#b0b0b0;
        }
        .box-item span a{
            color:#999;
        }
        .box-item span a:hover{
            color:#666;
        }    
    </style>
    </head>
    <body>
    <div class="main-box">
        <div>您好,</div>
        <div class="box-item">
            /**content**/        
            <br/>系统链接：<a href="http://ip:8080/login">*******系统</a>    
            <br/>如有任何问题，可咨询：***@163.com        
        </div>
        <div class="hello">
            ------------------------------------------------------------------
            <br/>本邮件为系统自动发出，不必回复。
            <br/>This email is automatically sent out, no need to reply.
        </div>
    </div>
    </body>
    </html>

[Link 1]: https://blog.csdn.net/lchq1995/article/details/80770804
[70]: /images/20220522/2791565ad93148c5968ebd8d7a5f95ac.png
[70 1]: /images/20220522/055e2fb69a9144bf83f28d55bf757aef.png
[70 2]: /images/20220522/4bdd2b1fac214ec6a45c67353864c6f8.png
[70 3]: /images/20220522/76311d600afd49d08b62b04eec6559fb.png
[70 4]: /images/20220522/62de175c51fe43d8822e8d2d52b89a09.png
[70 5]: /images/20220522/e46df480e2a849b4998829bf545b23c9.png
[20190307174800790.png]: /images/20220522/ae160cff7fc64e838b072b7058257c8c.png
[20190307175006242.png]: /images/20220522/19dcbc1d93f647508bf3c848deb9c17c.png