独立线程发送邮件

线程基础知识复习

通过Callable和FutureTask创建线程&＃xff0c;步骤如下&＃xff1a;

1. 创建Callable接口的实现类&＃xff0c;并实现Call方法&＃xff1b;
2. 创建Callable实现类的实现&＃xff0c;使用FutureTask类包装Callable对象&＃xff0c;该FutureTask对象封装了Callable对象的Call方法的返回值&＃xff1b;
3. 使用FutureTask对象作为Thread对象的target创建并启动线程&＃xff1b;
4. 调用FutureTask对象的get()方法来获取子线程执行结束的返回值。

public class Demo{public static void main(String[] args){Callable call &＃61; new MyCallable();FutureTask<Object> task &＃61; new FutureTask<Object>(call);Thread t &＃61; new Thread(task);t.start();try {System.out.println(task.get());//可以作为Future类型对象得到线程运算返回值} catch (Exception e) {e.printStackTrace();}}}class MyCallable implements Callable<Object>{&＃64;Overridepublic Object call() throws Exception{System.out.println(Thread.currentThread().getName());return null;}}


通过线程池创建线程&＃xff0c;如下&＃xff1a;

public class ThreadDemo{public static void main(String[] args){FutureTask<Integer> futureTask &＃61; new FutureTask<Integer>(new CallbleThread());ExecutorService executor &＃61; Executors.newCachedThreadPool();executor.submit(futureTask);//也可以使用execute&＃xff0c;证明其是一个Runnable类型对象executor.shutdown();while(!futureTask.isDone()){System.out.println("子线程还没做完&＃xff0c;我再睡会");TimeUnit.SECONDS.sleep(1);}try {System.out.println("子线程运行的结果&＃xff1a;"&＃43;futureTask.get());} catch (Exception e) {e.printStackTrace();}}
}
class CallbleThread implements Callable<Integer>{&＃64;Overridepublic Integer call() throws Exception{System.out.println("线程池创建的线程&＃xff1a;"&＃43;Thread.currentThread().getName());TimeUnit.SECONDS.sleep(2);return 2;}
}


发送邮件

在独立线程中发送邮件&＃xff1a;

public class SendMailUtil{private final Logger logger &＃61; Logger.getLogger(this.class);public Boolean sendMailWithTask(Mailbox mailbox){ExecutorService exec &＃61; executors.newCachedThreadPool();MailTask task &＃61; new MailTask();task.mailbox &＃61; mailbox;String failReason &＃61; null;Future<Boolean> future &＃61; exec.submit(task);Boolean taskResult &＃61; false;try{taskResult &＃61; future.get(120,TimeUnit.SECONDS);//等待计算结果&＃xff0c;最长等待120s&＃xff0c;120s后终止任务taskResult &＃61; true;}catch(InterruptedException e){failReason &＃61; "主线程在等待计算结果时被中断&＃xff01;" &＃43; e.getMessage();}catch(ExecutionException e){failReason &＃61; "主线程等待计算结果&＃xff0c;但计算抛出异常&＃xff01;" &＃43; e.getMessage();}catch(TimeoutException e){failReason &＃61; "主线程等待计算结果超时&＃xff0c;因此中断任务线程&＃xff01;" &＃43; e.getMessage();}finally{if(failReason!&＃61;null){logger.info(failReason);}}return taskResult ;}class MailTask implements Callable<Boolean>{public Mailbox mailbox &＃61; null;public Boolean call() throws Exception{result &＃61; MailSender.send(mailbox);return result;}}
}


MailSender类

public class MailSender{public static boolean send(Mailbox mailbox) throws Exception {// 判断是否需要身份认证MyAuthenticator authenticator &＃61; null;Properties pro &＃61; mailbox.getProperties();// 如果需要身份认证&＃xff0c;则创建一个密码验证器if (mailbox.getValidate()) {String password &＃61; mailbox.getPassword();authenticator &＃61; new MyAuthenticator(mailbox.getEmail(),password );}// 根据邮件会话属性和密码验证器构造一个发送邮件的sessionSession sendMailSession &＃61; Session.getInstance(pro, authenticator);// 根据session创建一个邮件消息Message mailMessage &＃61; new MimeMessage(sendMailSession);// 创建邮件发送者地址Address from &＃61; new InternetAddress(mailbox.getEmail());// 设置邮件消息的发送者mailMessage.setFrom(from);// 创建邮件的接收者地址&＃xff0c;并设置到邮件消息中Address to &＃61; new InternetAddress(mailbox.getToAddress());// Message.RecipientType.TO属性表示接收者的类型为TOmailMessage.setRecipient(Message.RecipientType.TO, to);//抄送//mailMessage.setRecipient(Message.RecipientType.CC, new InternetAddress(mailbox.getEmail()));// 设置邮件消息的主题mailMessage.setSubject(mailbox.getSubject());// 设置邮件消息发送的时间mailMessage.setSentDate(new Date());//MiniMultipart类是一个容器类&＃xff0c;包含MimeBodyPart类型的对象Multipart mainPart1 &＃61; new MimeMultipart();BodyPart html &＃61; new MimeBodyPart();//创建一个包含HTML内容的MimeBodyParthtml.setContent("hehehe","text/html; charset&＃61;utf-8");//设置HTML内容mainPart1.addBodyPart(html);//将MiniMultipart对象设置为邮件内容mailMessage.setContent(mainPart1);// 发送邮件Transport.send(mailMessage);return true;}
}


MailBox类&＃xff1a;

public class Mailbox {private Integer mailboxId;private String email;private String password;private String protocol;//imap/imaps/pop3/pop3s 邮箱协议 --SMTP管‘发’&＃xff0c;POP3/IMAP管‘收’private String mailServerHost;// 箱服务器的IP(或主机地址)private String mailServerPort;// 服务器的端口private String passwordEncrypt;// 登陆邮件服务器的密码private Boolean validate;// 是否需要身份验证private String toAddress;private String subject;private String connectType;//针对邮箱协议连接类型&＃64;JsonIgnorepublic Properties getProperties() {Properties p &＃61; new Properties();p.put("mail."&＃43;this.protocol&＃43;".host", this.mailServerHost);p.put("mail."&＃43;this.protocol&＃43;".port", this.mailServerPort);p.put("mail."&＃43;this.protocol&＃43;".auth", validate);if("TLS".equals(this.connectType)){p.put("mail."&＃43;this.protocol&＃43;".starttls.enable", true);}else if("SSL".equals(this.connectType)){p.put("mail."&＃43;this.protocol&＃43;".ssl.enable", true);}return p;}//属性的getter和setter方法略
}