利用Javamail接收QQ邮箱和Gmail邮箱

QQ接收邮箱:

package com.sam.mail;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.security.Security;
import java.util.Enumeration;
import java.util.Properties;
import javax.mail.BodyPart;
import javax.mail.FetchProfile;
import javax.mail.Folder;
import javax.mail.Header;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.Session;
import javax.mail.Store;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeUtility;
import org.junit.Test;
import com.sun.mail.imap.IMAPMessage;


/**
* 
* @author  [e-mail]
*
*/

public class EmailClient {

private static final String IMAP = "imap";

@Test
public void testRece() throws Exception{
reviceQQEmail(System.getProperty("email"), System.getProperty("password"));
}
public void reviceQQEmail(String username, String password) throws Exception{
String host = "imap.qq.com"; 
String port = "143";

Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider());

final String SSL_FACTORY = "javax.net.ssl.SSLSocketFactory";

Properties props = System.getProperties();
props.setProperty("mail.imap.socketFactory.class", SSL_FACTORY);
//props.setProperty("mail.imap.socketFactory.fallback", "false");
// props.setProperty("mail.imap.port", port);
 props.setProperty("mail.imap.socketFactory.port", port);
 

 props.setProperty("mail.store.protocol","imap"); 
 props.setProperty("mail.imap.host", host); 
 props.setProperty("mail.imap.port", port); 
 props.setProperty("mail.imap.auth.login.disable", "true"); 
Session session = Session.getDefaultInstance(props,null);
session.setDebug(false);
Store store = session.getStore("imap"); 
 store.connect(host, username, password);
Folder inbox = null;
try {
 
inbox = store.getFolder("Inbox");
inbox.open(Folder.READ_ONLY);
FetchProfile profile = new FetchProfile();
profile.add(FetchProfile.Item.ENVELOPE);
Message[] messages = inbox.getMessages();
inbox.fetch(messages, profile);
System.out.println("收件箱的邮件数：" + messages.length);

IMAPMessage msg;
for (int i = 0; i < messages.length; i++) {
msg = (IMAPMessage)messages[i];
String from = decodeText(msg.getFrom()[0].toString());
InternetAddress ia = new InternetAddress(from);
System.out.println("FROM:" + ia.getPersonal()+'('+ia.getAddress()+')');
System.out.println("TITLE:" + msg.getSubject());
System.out.println("SIZE:" + msg.getSize());
System.out.println("DATE:" + msg.getSentDate());
 Enumeration headers = msg.getAllHeaders(); 
 System.out.println("----------------------allHeaders-----------------------------"); 
 while (headers.hasMoreElements()) { 
 Header header = (Header)headers.nextElement(); 
 System.out.println(header.getName()+" ======= "+header.getValue()); 
 } 
 parseMultipart((Multipart) msg.getContent()); 
}

} finally {
try {
inbox.close(false);
} catch (Exception e) {
}
try {
store.close();
} catch (Exception e) {
}
}
}
protected String decodeText(String text) throws UnsupportedEncodingException {
if (text == null)
return null;
if (text.startsWith("=?GB") || text.startsWith("=?gb"))
text = MimeUtility.decodeText(text);
else
text = new String(text.getBytes("ISO8859_1"));
return text;
}


 /** 
 * 对复杂邮件的解析 
 * @param multipart 
 * @throws MessagingException 
 * @throws IOException 
 */ 
 public static void parseMultipart(Multipart multipart) throws MessagingException, IOException { 
 int count = multipart.getCount(); 
 System.out.println("couont = "+count); 
 for (int idx=0;idx<count;idx++) { 
 BodyPart bodyPart = multipart.getBodyPart(idx); 
 System.out.println(bodyPart.getContentType()); 
 if (bodyPart.isMimeType("text/plain")) { 
 System.out.println("plain................."+bodyPart.getContent()); 
 } else if(bodyPart.isMimeType("text/html")) { 
 System.out.println("html..................."+bodyPart.getContent()); 
 } else if(bodyPart.isMimeType("multipart/*")) { 
 Multipart mpart = (Multipart)bodyPart.getContent(); 
 parseMultipart(mpart); 
 
 } else if (bodyPart.isMimeType("application/octet-stream")) { 
 String disposition = bodyPart.getDisposition(); 
 System.out.println(disposition); 
 if (disposition.equalsIgnoreCase(BodyPart.ATTACHMENT)) { 
 String fileName = bodyPart.getFileName(); 
 InputStream is = bodyPart.getInputStream(); 
 copy(is, new FileOutputStream("D:\\"+fileName)); 
 } 
 } 
 } 
 } 
 
 /** 
 * 文件拷贝，在用户进行附件下载的时候，可以把附件的InputStream传给用户进行下载 
 * @param is 
 * @param os 
 * @throws IOException 
 */ 
 public static void copy(InputStream is, OutputStream os) throws IOException { 
 byte[] bytes = new byte[1024]; 
 int len = 0; 
 while ((len=is.read(bytes)) != -1 ) { 
 os.write(bytes, 0, len); 
 } 
 if (os != null) 
 os.close(); 
 if (is != null) 
 is.close(); 
 } 
}