test

沈斌

2017-11-28 6cce9ad4c95a9cf7c1afc066fe71d8eac482f76f

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
package com.moral.monitor.listener.message; 
 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import javax.mail.Session; 
import javax.mail.Transport; 
import javax.mail.internet.InternetAddress; 
import javax.mail.internet.MimeMessage; 
import java.util.Date; 
import java.util.Properties; 
/** 
 * Created by a on 2017/3/13. 
 */ 
public class Mail implements Runnable { 
    private Logger logger = LoggerFactory.getLogger(Mail.class); 
    private String receiveMail; 
    private String msg; 
    public final static String myEmailAccount = "331641859@qq.com"; 
    public final static String myEmailPassword = "cbblvtoaitqgcaec"; 
    public final static String myEmailSMTPHost = "smtp.qq.com"; 
    public final static String smtpPort = "465"; 
    public final static Properties props = new Properties(); 
    static { 
        props.setProperty("mail.transport.protocol", "smtp"); 
        props.setProperty("mail.smtp.host", myEmailSMTPHost); 
        props.setProperty("mail.smtp.auth", "true"); 
        props.setProperty("mail.smtp.socketFactory.port", smtpPort); 
        props.setProperty("mail.smtp.socketFactory.class", "javax.net.ssl.SSLSocketFactory"); 
        props.setProperty("mail.smtp.socketFactory.fallback", "false"); 
    } 
 
    public void run() { 
        try { 
            long ssatime = new Date().getTime(); 
            email(receiveMail, msg); 
            long esatime = new Date().getTime(); 
            logger.warn("  邮件报警耗时 " + (esatime - ssatime) + "==========" + Thread.currentThread().getName() + "========="); 
        } catch (Exception e) { 
            e.printStackTrace(); 
            logger.warn("邮件发送失败" + e.getMessage()); 
        } 
    } 
 
    public static void email(String receiveMail, String msg) throws Exception { 
        String content = msg; 
        Session session = Session.getDefaultInstance(props); 
        session.setDebug(true); 
        MimeMessage message = createMimeMessage(session, myEmailAccount, receiveMail, content); 
        Transport transport = session.getTransport(); 
        transport.connect(myEmailAccount, myEmailPassword); 
        transport.sendMessage(message, message.getAllRecipients()); 
        transport.close(); 
    } 
 
    public static MimeMessage createMimeMessage(Session session, String sendMail, String receiveMail, String content) throws Exception { 
        MimeMessage message = new MimeMessage(session); 
        message.setFrom(new InternetAddress(sendMail, "摩瑞尔", "UTF-8")); 
        message.setRecipient(MimeMessage.RecipientType.TO, new InternetAddress(receiveMail)); 
        message.setSubject("工业软件报警提醒", "UTF-8"); 
        message.setContent(content, "text/html;charset=UTF-8"); 
        message.setSentDate(new Date()); 
        message.saveChanges(); 
        return message; 
    } 
 
    public Mail(String receiveMail, String msg) { 
        this.receiveMail = receiveMail; 
        this.msg = msg; 
    } 
}