Я написал автономную программу на основе Java (используя JavaMail API v1.4.4) для чтения сообщений электронной почты с сервера POP3, а также установил для свойства mail.pop3.filecache.enable
значение true , используя:
props.put("mail.pop3.filecache.enable", "true");
Соответственно, я получаю следующее исключение Stream Closed
из message.getContent()
метода времени выполнения для конкретного сообщения электронной почты:
Трассировка исключений:
java.lang.RuntimeException: Stream closed
at javax.mail.util.SharedFileInputStream.newStream(SharedFileInputStream.java:507)
at com.sun.mail.pop3.POP3Message.getContentStream(POP3Message.java:242)
at javax.mail.internet.MimePartDataSource.getInputStream(MimePartDataSource.java:98)
at com.sun.mail.handlers.text_plain.getContent(text_plain.java:107)
at javax.activation.DataSourceDataContentHandler.getContent(DataHandler.java:774)
at javax.activation.DataHandler.getContent(DataHandler.java:521)
at javax.mail.internet.MimeMessage.getContent(MimeMessage.java:1419)
at ReadPop3Email.readPOP3Account(ReadPop3Email.java:290)
at ReadPop3Email.main(ReadPop3Email.java:73)
Строка № 290 ReadPop3Email.java имеет следующий вид:
Object object = message.getContent();
Но, если я установлю mail.pop3.filecache.enable
на false , я не вижу никаких исключений.Однако мы хотим использовать свойство от mail.pop3.filecache.enable
до true , поскольку оно будет кэшировать данные сообщения во временном файле, а не в памяти, как указано в документе JavaMail.
ПочемуЯ получаю это исключение, когда filecache
включено?Что не так?Любая помощь / предложение высоко ценятся.Я использую JDK1.6, если это имеет значение.
РЕДАКТИРОВАТЬ: Хотя я не могу поделиться / опубликовать оригинальный исходный код, я вставил ниже модифицированной версии моего исходного исходного кода.
public class ReadPop3Email
{
public static void main(String[] args)
{
System.setProperty("mail.mime.parameters.strict", "false");
System.setProperty("mail.mime.ignoremultipartencoding", "false");
ReadPop3Email pop3Email = new ReadPop3Email();
pop3Email.readPOP3Account();
}
public static String[] getPOP3Info()
{
return new String[]{"mypop3host.net", "110", "jack@example.net", "password"};
}
public Properties getPOP3Properties()
{
Properties props = new Properties();
props.put("mail.pop3.timeout", "30000");
props.put("mail.pop3.connectiontimeout", "10000");
props.put("mail.pop3.filecache.enable", "true");
return props;
}
public void readPOP3Account()
{
String server = getPOP3Info()[0];
int port = Integer.parseInt(getPOP3Info()[1]);
String username = getPOP3Info()[2];
String password = getPOP3Info()[3];
Session session = null;
Store store = null;
Folder folder = null;
POP3Folder pf = null;
Message message = null;
Message[] messages = null;
try {
System.out.println("-------------- Started processing POP3 account: " + username + " -----------------");
session = Session.getInstance(getPOP3Properties());
System.out.println("Getting the session for accessing email.");
store = session.getStore("pop3");
store.connect(server, port, username, password);
System.out.println("Connection established with POP3 server.");
folder = store.getDefaultFolder();
folder = folder.getFolder("inbox");
System.out.println("Getting the Inbox folder.");
folder.open(Folder.READ_ONLY);
pf = (POP3Folder) folder;
System.out.println("Total messages found: " + folder.getMessageCount());
messages = folder.getMessages();
//Message no. 26 is the one having this issue
message = messages[26 - 1];
System.out.println("Message number: " + message.getMessageNumber());
System.out.println("Message UID: " + pf.getUID(message));
System.out.println("From: " + message.getFrom()[0].toString());
System.out.println("Subject: " + message.getSubject());
System.out.println("Received date: " + message.getReceivedDate());
System.out.println("Sent date: " + message.getSentDate());
System.out.println("Content Type: " + message.getContentType());
System.out.println("Disposition: " + message.getDisposition());
boolean isMultipart = (message.getContent() instanceof Multipart);
System.out.println("Message is multipart? " + isMultipart);
if (!isMultipart) {
getBodyContent(message);
}
folder.close(true);
store.close();
System.out.println("-------------- Completed processing POP3 account: " + username + " -----------------");
} catch (Exception e) {
e.printStackTrace();
}
}
private void getBodyContent(Message message)
{
try
{
System.out.println("============== BODY CONTENT STARTS HERE ==============");
Object object = message.getContent();
if (object instanceof String) {
System.out.println("STRING content follows below: \n" + (String) object);
} else if (object instanceof InputStream) {
System.out.println("INPUTSTREAM content");
InputStream is = (InputStream) object;
int c;
while ((c = is.read()) != -1) {
System.out.write(c);
}
}
System.out.println("============== BODY CONTENT ENDS HERE ==============");
} catch (Exception e) {
e.printStackTrace();
}
}
}