package book.email;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.Reader;
import java.io.StringReader;
import java.io.UnsupportedEncodingException;
import java.util.Date;
import javax.mail.BodyPart;
import javax.mail.Flags;
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.Session;
import javax.mail.Store;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeUtility;
/**
* 邮件接收器，目前支持pop3协议。
* 能够接收文本、HTML和带有附件的邮件
*/
public class MailReceiver {
// 收邮件的参数配置
private MailReceiverInfo receiverInfo;
// 与邮件服务器连接后得到的邮箱
private Store store;
// 收件箱
private Folder folder;
// 收件箱中的邮件消息
private Message[] messages;
// 当前正在处理的邮件消息
private Message currentMessage;
private String currentEmailFileName;
public MailReceiver(MailReceiverInfo receiverInfo) {
this.receiverInfo = receiverInfo;
}
/**
* 收邮件
*/
public void receiveAllMail() throws Exception{
if (this.receiverInfo == null){
throw new Exception("必须提供接收邮件的参数！");
}
// 连接到服务器
if (this.connectToServer()) {
// 打开收件箱
if (this.openInBoxFolder()) {
// 获取所有邮件
this.getAllMail();
this.closeConnection();
} else {
throw new Exception("打开收件箱失败！");
}
} else {
throw new Exception("连接邮件服务器失败！");
}
}
/**
* 登陆邮件服务器
*/
private boolean connectToServer() {
// 判断是否需要身份认证
MyAuthenticator authenticator = null;
if (this.receiverInfo.isValidate()) {
// 如果需要身份认证，则创建一个密码验证器
authenticator = new MyAuthenticator(this.receiverInfo.getUserName(),
this.receiverInfo.getPassword());
}
//创建session
Session session = Session.getInstance(this.receiverInfo
.getProperties(), authenticator);
//创建store,建立连接
try {
this.store = session.getStore(this.receiverInfo.getProtocal());
} catch (NoSuchProviderException e) {
System.out.println("连接服务器失败！");
return false;
}
System.out.println("connecting");
try {
this.store.connect();
} catch (MessagingException e) {
System.out.println("连接服务器失败！");
return false;
}
System.out.println("连接服务器成功");
return true;
}
/**
* 打开收件箱
*/
private boolean openInBoxFolder() {
try {
this.folder = store.getFolder("INBOX");
// 只读
folder.open(Folder.READ_ONLY);
return true;
} catch (MessagingException e) {
System.err.println("打开收件箱失败！");
}
return false;
}
/**
* 断开与邮件服务器的连接
*/
private boolean closeConnection() {
try {
if (this.folder.isOpen()) {
this.folder.close(true);
}
this.store.close();
System.out.println("成功关闭与邮件服务器的连接！");
return true;
} catch (Exception e) {
System.out.println("关闭和邮件服务器之间连接时出错！");
}
return false;
}
/**
* 获取messages中的所有邮件
* @throws MessagingException
*/
private void getAllMail() throws MessagingException {
//从邮件文件夹获取邮件信息
this.messages = this.folder.getMessages();
System.out.println("总的邮件数目：" + messages.length);
System.out.println("新邮件数目：" + this.getNewMessageCount());
System.out.println("未读邮件数目：" + this.getUnreadMessageCount());
//将要下载的邮件的数量。
int mailArrayLength = this.getMessageCount();
System.out.println("一共有邮件" + mailArrayLength + "封");
int errorCounter = 0; //邮件下载出错计数器
int successCounter = 0;
for (int index = 0; index < mailArrayLength; index++) {
try {
this.currentMessage = (messages[index]); //设置当前message
System.out.println("正在获取第" + index + "封邮件......");
this.showMailBasicInfo();
getMail(); //获取当前message
System.out.println("成功获取第" + index + "封邮件");
successCounter++;
} catch (Throwable e) {
errorCounter++;
System.err.println("下载第" + index + "封邮件时出错");
}
}
System.out.println("------------------");
System.out.println("成功下载了" + successCounter + "封邮件");
System.out.println("失败下载了" + errorCounter + "封邮件");
System.out.println("------------------");
}
/**
* 显示邮件的基本信息
*/
private void showMailBasicInfo() throws Exception{
showMailBasicInfo(this.currentMessage);
}
private void showMailBasicInfo(Message message) throws Exception {
System.out.println("-------- 邮件ID：" + this.getMessageId()
+ " ---------");
System.out.println("From：" + this.getFrom());
System.out.println("To：" + this.getTOAddress());
System.out.println("CC：" + this.getCCAddress());
System.out.println("BCC：" + this.getBCCAddress());
System.out.println("Subject：" + this.getSubject());
System.out.println("发送时间：：" + this.getSentDate());
System.out.println("是新邮件？" + this.isNew());
System.out.println("要求回执？" + this.getReplySign());
System.out.println("包含附件？" + this.isContainAttach());
System.out.println("------------------------------");
}
/**
* 获得邮件的收件人，抄送，和密送的地址和姓名，根据所传递的参数的不同
* "to"----收件人 "cc"---抄送人地址 "bcc"---密送人地址
*/
private String getTOAddress() throws Exception {
return getMailAddress("TO", this.currentMessage);
}
private String getCCAddress() throws Exception {
return getMailAddress("CC", this.currentMessage);
}
private String getBCCAddress() throws Exception {
return getMailAddress("BCC", this.currentMessage);
}
/**
* 获得邮件地址
* @param type 类型，如收件人、抄送人、密送人
* @param mimeMessage 邮件消息
* @return
* @throws Exception
*/
private String getMailAddress(String type, Message mimeMessage)
throws Exception {
String mailaddr = "";
String addtype = type.toUpperCase();
InternetAddress[] address = null;
if (addtype.equals("TO") || addtype.equals("CC")
|| addtype.equals("BCC")) {
if (addtype.equals("TO")) {
address = (InternetAddress[]) mimeMessage
.getRecipients(Message.RecipientType.TO);
} else if (addtype.equals("CC")) {
address = (InternetAddress[]) mimeMessage
.getRecipients(Message.RecipientType.CC);
} else {
address = (InternetAddress[]) mimeMessage
.getRecipients(Message.RecipientType.BCC);
}
if (address != null) {
for (int i = 0; i < address.length; i++) {
// 先获取邮件地址
String email = address[i].getAddress();
if (email == null){
email = "";
}else {
email = MimeUtility.decodeText(email);
}
// 再取得个人描述信息
String personal = address[i].getPersonal();
if (personal == null){
personal = "";
} else {
personal = MimeUtility.decodeText(personal);
}
// 将个人描述信息与邮件地址连起来
String compositeto = personal + "<" + email + ">";
// 多个地址时，用逗号分开
mailaddr += "," + compositeto;
}
mailaddr = mailaddr.substring(1);
}
} else {
throw new Exception("错误的地址类型！!");
}
return mailaddr;
}
/**
* 获得发件人的地址和姓名
* @throws Exception
*/
private String getFrom() throws Exception {
return getFrom(this.currentMessage);
}
private String getFrom(Message mimeMessage) throws Exception {
InternetAddress[] address = (InternetAddress[]) mimeMessage.getFrom();
// 获得发件人的邮箱
String from = address[0].getAddress();
if (from == null){
from = "";
}
// 获得发件人的描述信息
gg.rar （43个子文件） 
毕业设计 
毕业设计.doc 21KB chat 
Constants.java 616B book net chat Constants.class 530B ChatClient$ClentListener.class 3KB ClientProcessor.class 3KB ChatServer$1.class 579B ChatServer.class 6KB ChatClient.class 5KB ChatClient.java 9KB ChatServer.java 10KB FTP FtpServer.class 2KB FtpClientFrame$6.class 554B Request.java 6KB FtpServer.java 3KB FtpClientFrame$5.class 556B FtpClientFrame$4.class 552B FtpClientFrame$1.class 552B FtpClientFrame.class 10KB .project 379B FtpClientFrame$2.class 558B Response.class 7KB FtpClientFrame$3.class 553B .classpath 226B FtpClientFrame.java 13KB Response.java 9KB Request.class 5KB lib 
activation.jar 56KB mail.jar 374KB email MultiMailsender.java 5KB AttachmentMailSender.java 4KB MailSenderInfo.java 2KB MailReceiver.java 19KB book email MyAuthenticator.class 822B MailReceiverInfo.class 2KB MultiMailsender.class 3KB MultiMailsender$MultiMailSenderInfo.class 684B SimpleMailSender.class 3KB AttachmentMailSender.class 3KB MailReceiver.class 12KB MailSenderInfo.class 2KB MyAuthenticator.java 891B SimpleMailSender.java 4KB MailReceiverInfo.java 2KB资源评论
