package com.yc.crm.mail.action;
|
|
import com.sun.mail.imap.IMAPStore;
|
import org.springframework.mail.SimpleMailMessage;
|
import org.springframework.mail.javamail.JavaMailSenderImpl;
|
|
import javax.mail.*;
|
import javax.mail.internet.InternetAddress;
|
import javax.mail.internet.MimeUtility;
|
import javax.mail.search.FlagTerm;
|
import java.io.IOException;
|
import java.util.HashMap;
|
import java.util.Properties;
|
|
public class MailDemo {
|
public static void sendEmail(String[] args) {
|
JavaMailSenderImpl mailSender = new JavaMailSenderImpl();
|
mailSender.setHost("smtp.163.com");//邮箱服务商
|
mailSender.setProtocol("smtp");//发邮件
|
mailSender.setUsername("xxxxx@163.com");//账号
|
mailSender.setPassword("Xxxx");//授权码
|
mailSender.setDefaultEncoding("utf-8");
|
SimpleMailMessage message = new SimpleMailMessage();
|
message.setTo("xxxxx@qq.com");
|
message.setSubject("测试邮箱");
|
message.setText("abc");
|
message.setFrom("xxxxx@163.com");//发件人邮箱
|
mailSender.send(message);
|
}
|
public static void main(String[] args) throws Exception {
|
ReceiveEmail();
|
}
|
public static void ReceiveEmail() throws MessagingException, IOException {
|
|
String imapServer = "imap.qq.com";
|
String user="xxx@qq.com";
|
String pwd="xxxx";
|
|
HashMap IAM = new HashMap();
|
//带上IMAP ID信息，由key和value组成，例如name，version，vendor，support-email等。
|
IAM.put("name","myname");
|
IAM.put("version","1.0.0");
|
IAM.put("vendor","myclient");
|
IAM.put("support-email","testmail@test.com");
|
//创建会话
|
Session session = Session.getInstance(new Properties(), new Authenticator() {
|
@Override
|
protected PasswordAuthentication getPasswordAuthentication() {
|
return new PasswordAuthentication(user,pwd);
|
}
|
});
|
//存储对象
|
IMAPStore store = (IMAPStore) session.getStore("imap");
|
//连接
|
store.connect(imapServer,user,pwd);
|
store.id(IAM);//163邮箱需要，不然会报：A3 NO SELECT Unsafe Login. Please contact kefu@188.com for help
|
Folder folder = null;
|
try {
|
// 获得收件箱
|
folder = store.getFolder("INBOX");
|
// 以读写模式打开收件箱
|
folder.open(Folder.READ_WRITE);
|
//false 表示未读
|
FlagTerm flagTerm = new FlagTerm(new Flags(Flags.Flag.SEEN),true);
|
//获得收件箱的邮件列表
|
Message[] messages = folder.search(flagTerm);
|
// 打印不同状态的邮件数量
|
System.out.println("收件箱中共" + messages.length + "封邮件!");
|
System.out.println("收件箱中共" + folder.getUnreadMessageCount() + "封未读邮件!");
|
System.out.println("收件箱中共" + folder.getNewMessageCount() + "封新邮件!");
|
System.out.println("收件箱中共" + folder.getDeletedMessageCount() + "封已删除邮件!");
|
|
System.out.println("------------------------开始解析邮件----------------------------------");
|
|
for (int i = 0; i < messages.length; i++) {
|
System.out.println("消息:"+messages[i].getSubject());
|
System.out.println("内容:"+messages[i].getContent());
|
String from = MimeUtility.decodeText(messages[i].getFrom()[0].toString());
|
InternetAddress internetAddress = new InternetAddress(from);
|
System.out.println("发件人：" + internetAddress.getPersonal() + '(' + internetAddress.getAddress() + ')');
|
}
|
|
} catch (NoSuchProviderException e) {
|
e.printStackTrace();
|
} catch (MessagingException e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
if (folder != null) {
|
folder.close(false);
|
}
|
if (store != null) {
|
store.close();
|
}
|
} catch (MessagingException e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
}
|
