java邮件附件下载_用Java下载邮件附件

这是我用来下载电子邮件的类(附件处理).您将不得不浏览它正在做的一些事情(比如忽略日志记录类和数据库写入).为了便于阅读,我还重新命名了一些软件包.

一般的想法是所有附件都保存为文件系统中的单个文件,并且每个电子邮件都作为记录保存在数据库中,并带有一组指向所有附件文件路径的子记录.

专注于doEMailDownload方法.

/**

* Copyright (c) 2008 Steven M. Cherry

* All rights reserved.

*/

package utils.scheduled;

import java.io.BufferedOutputStream;

import java.io.File;

import java.io.FileOutputStream;

import java.io.InputStream;

import java.sql.Timestamp;

import java.util.Properties;

import java.util.Vector;

import javax.mail.Address;

import javax.mail.Flags;

import javax.mail.Folder;

import javax.mail.Message;

import javax.mail.Multipart;

import javax.mail.Part;

import javax.mail.Session;

import javax.mail.Store;

import javax.mail.internet.MimeBodyPart;

import glob.ActionLogicImplementation;

import glob.IOConn;

import glob.log.Log;

import logic.utils.sql.Settings;

import logic.utils.sqldo.EMail;

import logic.utils.sqldo.EMailAttach;

/**

* This will connect to our incoming e-mail server and download any e-mails

* that are found on the server. The e-mails will be stored for further processing

* in our internal database. Attachments will be written out to separate files

* and then referred to by the database entries. This is intended to be run by

* the scheduler every minute or so.

*

* &＃64;author Steven M. Cherry

*/

public class DownloadEMail implements ActionLogicImplementation {

protected String receiving_host;

protected String receiving_user;

protected String receiving_pass;

protected String receiving_protocol;

protected boolean receiving_secure;

protected String receiving_attachments;

/** This will run our logic */

public void ExecuteRequest(IOConn ioc) throws Exception {

Log.Trace("Enter");

Log.Debug("Executing DownloadEMail");

ioc.initializeResponseDocument("DownloadEMail");

// pick up our configuration from the server:

receiving_host &＃61; Settings.getValue(ioc, "server.email.receiving.host");

receiving_user &＃61; Settings.getValue(ioc, "server.email.receiving.username");

receiving_pass &＃61; Settings.getValue(ioc, "server.email.receiving.password");

receiving_protocol &＃61; Settings.getValue(ioc, "server.email.receiving.protocol");

String tmp_secure &＃61; Settings.getValue(ioc, "server.email.receiving.secure");

receiving_attachments &＃61; Settings.getValue(ioc, "server.email.receiving.attachments");

// sanity check on the parameters:

if(receiving_host &＃61;&＃61; null || receiving_host.length() &＃61;&＃61; 0){

ioc.SendReturn();

ioc.Close();

Log.Trace("Exit");

return; // no host defined.

}

if(receiving_user &＃61;&＃61; null || receiving_user.length() &＃61;&＃61; 0){

ioc.SendReturn();

ioc.Close();

Log.Trace("Exit");

return; // no user defined.

}

if(receiving_pass &＃61;&＃61; null || receiving_pass.length() &＃61;&＃61; 0){

ioc.SendReturn();

ioc.Close();

Log.Trace("Exit");

return; // no pass defined.

}

if(receiving_protocol &＃61;&＃61; null || receiving_protocol.length() &＃61;&＃61; 0){

Log.Debug("EMail receiving protocol not defined, defaulting to POP");

receiving_protocol &＃61; "POP";

}

if(tmp_secure &＃61;&＃61; null ||

tmp_secure.length() &＃61;&＃61; 0 ||

tmp_secure.compareToIgnoreCase("false") &＃61;&＃61; 0 ||

tmp_secure.compareToIgnoreCase("no") &＃61;&＃61; 0

){

receiving_secure &＃61; false;

} else {

receiving_secure &＃61; true;

}

if(receiving_attachments &＃61;&＃61; null || receiving_attachments.length() &＃61;&＃61; 0){

Log.Debug("EMail receiving attachments not defined, defaulting to ./email/attachments/");

receiving_attachments &＃61; "./email/attachments/";

}

// now do the real work.

doEMailDownload(ioc);

ioc.SendReturn();

ioc.Close();

Log.Trace("Exit");

}

protected void doEMailDownload(IOConn ioc) throws Exception {

// Create empty properties

Properties props &＃61; new Properties();

// Get the session

Session session &＃61; Session.getInstance(props, null);

// Get the store

Store store &＃61; session.getStore(receiving_protocol);

store.connect(receiving_host, receiving_user, receiving_pass);

// Get folder

Folder folder &＃61; store.getFolder("INBOX");

folder.open(Folder.READ_WRITE);

try {

// Get directory listing

Message messages[] &＃61; folder.getMessages();

for (int i&＃61;0; i

// get the details of the message:

EMail email &＃61; new EMail();

email.fromaddr &＃61; messages[i].getFrom()[0].toString();

Address[] to &＃61; messages[i].getRecipients(Message.RecipientType.TO);

email.toaddr &＃61; "";

for(int j &＃61; 0; j

email.toaddr &＃43;&＃61; to[j].toString() &＃43; "; ";

}

Address[] cc;

try {

cc &＃61; messages[i].getRecipients(Message.RecipientType.CC);

} catch (Exception e){

Log.Warn("Exception retrieving CC addrs: %s", e.getLocalizedMessage());

cc &＃61; null;

}

email.cc &＃61; "";

if(cc !&＃61; null){

for(int j &＃61; 0; j

email.cc &＃43;&＃61; cc[j].toString() &＃43; "; ";

}

}

email.subject &＃61; messages[i].getSubject();

if(messages[i].getReceivedDate() !&＃61; null){

email.received_when &＃61; new Timestamp(messages[i].getReceivedDate().getTime());

} else {

email.received_when &＃61; new Timestamp( (new java.util.Date()).getTime());

}

email.body &＃61; "";

Vector vema &＃61; new Vector();

Object content &＃61; messages[i].getContent();

if(content instanceof java.lang.String){

email.body &＃61; (String)content;

} else if(content instanceof Multipart){

Multipart mp &＃61; (Multipart)content;

for (int j&＃61;0; j

Part part &＃61; mp.getBodyPart(j);

String disposition &＃61; part.getDisposition();

if (disposition &＃61;&＃61; null) {

// Check if plain

MimeBodyPart mbp &＃61; (MimeBodyPart)part;

if (mbp.isMimeType("text/plain")) {

Log.Debug("Mime type is plain");

email.body &＃43;&＃61; (String)mbp.getContent();

} else {

Log.Debug("Mime type is not plain");

// Special non-attachment cases here of

// image/gif, text/html, ...

EMailAttach ema &＃61; new EMailAttach();

ema.name &＃61; decodeName(part.getFileName());

File savedir &＃61; new File(receiving_attachments);

savedir.mkdirs();

File savefile &＃61; File.createTempFile("emailattach", ".atch", savedir );

ema.path &＃61; savefile.getAbsolutePath();

ema.size &＃61; part.getSize();

vema.add(ema);

ema.size &＃61; saveFile(savefile, part);

}

} else if ((disposition !&＃61; null) &&

(disposition.equals(Part.ATTACHMENT) || disposition.equals(Part.INLINE) )

){

// Check if plain

MimeBodyPart mbp &＃61; (MimeBodyPart)part;

if (mbp.isMimeType("text/plain")) {

Log.Debug("Mime type is plain");

email.body &＃43;&＃61; (String)mbp.getContent();

} else {

Log.Debug("Save file (%s)", part.getFileName() );

EMailAttach ema &＃61; new EMailAttach();

ema.name &＃61; decodeName(part.getFileName());

File savedir &＃61; new File(receiving_attachments);

savedir.mkdirs();

File savefile &＃61; File.createTempFile("emailattach", ".atch", savedir );

ema.path &＃61; savefile.getAbsolutePath();

ema.size &＃61; part.getSize();

vema.add(ema);

ema.size &＃61; saveFile( savefile, part);

}

}

}

}

// Insert everything into the database:

logic.utils.sql.EMail.insertEMail(ioc, email);

for(int j &＃61; 0; j

vema.get(j).emailid &＃61; email.id;

logic.utils.sql.EMail.insertEMailAttach(ioc, vema.get(j) );

}

// commit this message and all of it&＃39;s attachments

ioc.getDBConnection().commit();

// Finally delete the message from the server.

messages[i].setFlag(Flags.Flag.DELETED, true);

}

// Close connection

folder.close(true); // true tells the mail server to expunge deleted messages.

store.close();

} catch (Exception e){

folder.close(true); // true tells the mail server to expunge deleted messages.

store.close();

throw e;

}

}

protected int saveFile(File saveFile, Part part) throws Exception {

BufferedOutputStream bos &＃61; new BufferedOutputStream( new FileOutputStream(saveFile) );

byte[] buff &＃61; new byte[2048];

InputStream is &＃61; part.getInputStream();

int ret &＃61; 0, count &＃61; 0;

while( (ret &＃61; is.read(buff)) > 0 ){

bos.write(buff, 0, ret);

count &＃43;&＃61; ret;

}

bos.close();

is.close();

return count;

}

protected String decodeName( String name ) throws Exception {

if(name &＃61;&＃61; null || name.length() &＃61;&＃61; 0){

return "unknown";

}

String ret &＃61; java.net.URLDecoder.decode( name, "UTF-8" );

// also check for a few other things in the string:

ret &＃61; ret.replaceAll("&＃61;\\?utf-8\\?q\\?", "");

ret &＃61; ret.replaceAll("\\?&＃61;", "");

ret &＃61; ret.replaceAll("&＃61;20", " ");

return ret;

}

}