Потоковое закрытое исключение выдается, когда «mail.pop3.filecache.enabled» имеет значение true - PullRequest
0 голосов
/ 02 января 2012

Я написал автономную программу на основе 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();
        }
    }

}

1 Ответ

0 голосов
/ 02 января 2012

Помните, что файловый кеш удаляется при закрытии папки или завершении JVM.

...