javamail实现gmail收发邮件

import java.io.UnsupportedEncodingException;

import java.security.Security;

import java.util.Properties;

import javax.mail.Authenticator;

import javax.mail.Folder;

import javax.mail.Message;

import javax.mail.MessagingException;

import javax.mail.Multipart;

import javax.mail.NoSuchProviderException;

import javax.mail.Part;

import javax.mail.PasswordAuthentication;

import javax.mail.Session;

import javax.mail.Store;

import javax.mail.Transport;

import javax.mail.URLName;

import javax.mail.internet.AddressException;

import javax.mail.internet.InternetAddress;

import javax.mail.internet.MimeMessage;

import javax.mail.internet.MimeUtility;

/*By 黄金@buaa 2009/06/08

* 转载请注明作者，谢谢！

*/

public class Email {

private Session session;

private String username;

private String password;

private String host;

private String text;

public void gmailSend(String to,String subject,String message) throws AddressException, MessagingException {

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

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

// Get a Properties object

Properties props = System.getProperties();

props.setProperty("mail.smtp.host", "smtp.gmail.com");

props.setProperty("mail.smtp.socketFactory.class", SSL_FACTORY);

props.setProperty("mail.smtp.socketFactory.fallback", "false");

props.setProperty("mail.smtp.port", "465");

props.setProperty("mail.smtp.socketFactory.port", "465");

props.put("mail.smtp.auth", "true");

Session session = Session.getDefaultInstance(props,

new Authenticator() {

protected PasswordAuthentication getPasswordAuthentication() {

return new PasswordAuthentication(getUsername(), getPassword());

}

});

// -- Create a new message --

Message msg = new MimeMessage(session);

msg.setFrom(new InternetAddress(getUsername()));

// Set the to address

msg.addRecipient(Message.RecipientType.TO, new InternetAddress(to));

msg.setSubject(subject);

msg.setText(message);

// msg.setSentDate(new Date());

msg.saveChanges();

Transport.send(msg);

System.out.println("Message sent.");

}

public String gmailFetch(int sum, String username, String password) {

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

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

// Get a Properties object

Properties props = System.getProperties();

props.setProperty("mail.pop3.socketFactory.class", SSL_FACTORY);

props.setProperty("mail.pop3.socketFactory.fallback", "false");

props.setProperty("mail.pop3.port", "995");

props.setProperty("mail.pop3.socketFactory.port", "995");

Session session = Session.getInstance(props, null);

URLName urln = new URLName("pop3", "pop.gmail.com", 995, null,

username, password);

Store store;

try {

store = session.getStore(urln);

} catch (NoSuchProviderException e) {

// TODO Auto-generated catch block

e.printStackTrace();

String result = "{/"type/":/"error/",/"body/":{/"reason/":/"" + e

+ "/"}}";

return result;

}

Folder inbox = null;

try {

store.connect();

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);

String result = "";

result += "{/"type/":/"api/",/"body/":{/"emails/":[";

for (int i = messages.length - 1; i >= messages.length - sum

&& i >= 0; i--) {

// 邮件发送者

String from;

try {

from = decodeText(messages[i].getFrom()[0].toString());

} catch (UnsupportedEncodingException e) {

// TODO Auto-generated catch block

e.printStackTrace();

result = "{/"type/":/"error/",/"body/":{/"reason/":/"" + e

+ "/"}}";

return result;

}

InternetAddress ia = new InternetAddress(from);

System.out.println("FROM:" + ia.getPersonal() + '('

+ ia.getAddress() + ')');

// 邮件标题

System.out.println("TITLE:" + messages[i].getSubject());

// 邮件大小

//System.out.println("SIZE:" + messages[i].getSize());

// 邮件发送时间

System.out.println("DATE:" + messages[i].getSentDate());

System.out.println("CONTENT:");

text = "";

try {

getMailContent(messages[i]);

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

result = "{/"type/":/"error/",/"body/":{/"reason/":/"" + e

+ "/"}}";

return result;

}

result += "{/"subject/":/"" + messages[i].getSubject() + "/"";

result += ",/"size/":/"" + messages[i].getSize() + "/"";

result += ",/"date/":/"" + messages[i].getSentDate() + "/"";

result += ",/"content/":/"" + text + "/"}";

if (i == 0 || i == messages.length - sum) {

result += "]}}";

} else {

result += ",";

}

}

return result;

} catch (MessagingException e1) {

// TODO Auto-generated catch block

String result = "{/"type/":/"error/",/"body/":{/"reason/":/"" + e1

+ "/"}}";

return result;

}

}

public void getMailContent(Part part) throws Exception {

StringBuffer bodytext = new StringBuffer();

String contenttype = part.getContentType();

int nameindex = contenttype.indexOf("name");

boolean conname = false;

if (nameindex != -1)

conname = true;

//System.out.println("CONTENTTYPE: " + contenttype);

if (part.isMimeType("text/plain") && !conname) {

bodytext.append((String) part.getContent());

//bodytext.append(new String(((String) part.getContent())

// .getBytes("ISO-8859-1"), "utf-8"));

System.out.println(bodytext.toString());

text += bodytext.toString();

} else if (part.isMimeType("text/html") && !conname) {

bodytext.append((String) part.getContent());

System.out.println(bodytext.toString());

text += bodytext.toString();

} else if (part.isMimeType("multipart/*")) {

Multipart multipart = (Multipart) part.getContent();

int counts = multipart.getCount();

for (int i = 0; i < counts; i++) {

getMailContent(multipart.getBodyPart(i));

}

} else if (part.isMimeType("message/rfc822")) {

getMailContent((Part) part.getContent());

} else {

}

}

public void login(String host,String username,String password) {

if (host.equals("") || username.equals("") || password.equals("")) {

String result = "{/"type/":/"error/",/"body/":{/"reason/":/"参数host、username、password都不能为空！/"}}";

System.out.println(result);

return;

}

setHost(host);

setUsername(username);

setPassword(password);

}

protected static 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;

}

public void setUsername(String username) {

this.username = username;

}

public String getUsername() {

return username;

}

public void setHost(String host) {

this.host = host;

}

public String getHost() {

return host;

}

public void setText(String text) {

this.text = text;

}

public String getText() {

return text;

}

public String getPassword() {

return password;

}

public void setPassword(String password) {

this.password = password;

}

public void setSession(Session session) {

this.session = session;

}

public Session getSession() {

return session;

}

public static void main(String[] args){

Email email = new Email();

email.login("smtp.gmail.com", "**********@gmail.com", "********");

try {

email.gmailSend("********@hotmail.com","subject","Hi!Have fun!I'm testing!");

} catch (AddressException e) {

e.printStackTrace();

} catch (MessagingException e) {

e.printStackTrace();

}

email.gmailFetch(1,"**********@gmail.com", "********");//第一个参数为显示邮件的个数

}

}

class MyAuthenticator extends javax.mail.Authenticator {

private String strUser;

private String strPwd;

public MyAuthenticator(String user, String password) {

this.strUser = user;

this.strPwd = password;

}

protected PasswordAuthentication getPasswordAuthentication() {

return new PasswordAuthentication(strUser, strPwd);

}

}