javamail收取邮件正文中带有图片的问题，急求

Question

使用javamail解析获取的邮件，当邮件正文中含有图片时，该如何解析？最好有demo！

Answer 1

补充当前解析类

 @Service
public class AutoReadEmailServiceImpl extends BaseService<Question> implements AutoReadEmailService {
    private static String POP3SERVER = "pop.exmail.qq.com";
    private static String IMAPSERVER = "imap.exmail.qq.com";
    @Resource
    private SysUserDao sysUserDao;
    @Resource
    private QuestionDao questionDao;
    @Resource
    private QuestionAttachmentDao questionAttachmentDao;
    @Resource
    private SysUserEmailPWDDao sysUserEmailPWDDao;
    @Value("${file.question.attachment.path}")
    private String questionAttachmentPath;

    public AutoReadEmailServiceImpl() {
    }

    // 自动获取邮件信息
    @Override
    public void aotuReadEmail() {
        // 查询认证维护表中的认证信息，一般是获取接收邮箱的地址，密码和最后接收时间，此处只有一个
        List<SysUserEmailPWD> queryResult = sysUserEmailPWDDao.doQueryAll();
        if (queryResult != null && queryResult.size() > 0) {
            for (SysUserEmailPWD epwd : queryResult) {
                // 最后接收时间如果没有  默认给当前时间
                Date latestReceiveTime = epwd.getLatestReceiveTime();
                if(latestReceiveTime == null) {
                    latestReceiveTime = new Date();
                }
                SysUser sysUser = sysUserDao.get(epwd.getUserId());
                if (StringUtils.isNotBlank(sysUser.getEmail())) {
                    receive(POP3SERVER, sysUser.getEmail(), epwd.getEmailpwd(), latestReceiveTime,
                            epwd, epwd.getUserId());
                }
            }
        }
    }

    // 处理任何一种邮件都需要的方法
    private void handle(Message msg, Question q) throws Exception {
        q.setQuestionTitle(msg.getSubject());
        q.setQuestionLastDealTime(msg.getSentDate());
    }

    @SuppressWarnings("unused")
    private void saveAttach(Part part, Question q) throws Exception {
        // 得到未经处理的附件名字
        String fileName = MimeUtility.decodeText(part.getFileName());
        String path = questionAttachmentPath;
        new java.io.File(path).mkdir();
        path = path + "//" + q.getQuestionId();
        new java.io.File(path).mkdir();
        InputStream in = part.getInputStream();
        FileOutputStream writer = new FileOutputStream(new File(path + "//" + fileName));
        byte[] content = new byte[255];
        int read = 0;
        while ((read = in.read(content)) != -1) {
            writer.write(content);
        }
        QuestionAttachment qa = new QuestionAttachment();
        qa.setQuestionId(q.getQuestionId());
        qa.setFileName(fileName);
        qa.setFilePath(path + "//" + fileName);
        questionAttachmentDao.persist(qa);
        writer.close();
        in.close();
    }

    /**
     * @param multipart // 接卸包裹（含所有邮件内容(包裹+正文+附件)）
     * @throws Exception
     */
    private void reMultipart(Multipart multipart, Question q) throws Exception {
        // 依次处理各个部分
        for (int j = 0, n = multipart.getCount(); j < n; j++) {
            Part part = multipart.getBodyPart(j);// 解包, 取出 MultiPart的各个部分, 每部分可能是邮件内容,
            // 也可能是另一个小包裹(MultipPart)
            // 判断此包裹内容是不是一个小包裹, 一般这一部分是 正文 Content-Type: multipart/alternative
            if (part.getContent() instanceof Multipart) {
                Multipart p = (Multipart) part.getContent();// 转成小包裹
                // 递归迭代
                reMultipart(p, q);
            } else {
                rePart(part, q);
            }
        }
    }

    /**
     * @param part 解析内容
     * @throws Exception
     */
    private void rePart(Part part, Question q) throws Exception, UnsupportedEncodingException, IOException,
            FileNotFoundException {
        if (part.getDisposition() != null) {
            saveAttach(part, q);
        } else {
            if (part.getContentType().startsWith("text/plain")) {
                q.setQuestionContent(part.getContent().toString());
            } else {
                // System.out.println("HTML内容：" + part.getContent());
            }
        }
    }

    private void receive(String pop3Server, String username, String password, Date latestReceiveTime,
            SysUserEmailPWD epwd, Long userId) {
        try {
            Date currentTime = new Date();
            // 连接到邮件服务器并获得邮件
            Properties prop = new Properties();
            prop.put("mail.pop3.host", pop3Server);
            Session session = Session.getDefaultInstance(prop);
            Store store = session.getStore("pop3");
            store.connect(pop3Server, username, password);
            Folder inbox = store.getDefaultFolder().getFolder("INBOX");
            // 设置inbox对象属性为可读写，这样可以控制在读完邮件后直接删除该附件
            inbox.open(Folder.READ_WRITE);
            Message[] msg = inbox.getMessages();
            FetchProfile profile = new FetchProfile();
            profile.add(FetchProfile.Item.ENVELOPE);
            inbox.fetch(msg, profile);
            for (int i = 0; i < msg.length; i++) {
                if (msg[i].getSentDate().after(latestReceiveTime)) {
                    InternetAddress addr = (InternetAddress) msg[i].getFrom()[0];
                    InternetAddress[] cc = (InternetAddress[]) msg[i].getRecipients(Message.RecipientType.CC);
                    SysUser customer = sysUserDao.getByProerties("email", addr.getAddress());
                    if (customer != null && customer.getCustomerService() != null) {
                        Question q = new Question();
                        q.setQuestionStatus(QuestionParameters.STATUS_UNDISTRIBUTED);
                        q.setQuestionType("");
                        q.setQuestionCustomerServiceType(QuestionParameters.CUSTOMERSERVICETYPE_B);
                        q.setQuestionCustomerService(customer.getCustomerService());
                        q.setQuestionCustomer(String.valueOf(customer.getId()));
                        q.setQuestionCreateTime(new Date());
                        String ccaddr = "";
                        if (cc != null) {
                            for (int j = 0; j < cc.length; j++) {
                                String email = cc[j].getAddress();
                                if (email == null)
                                    email = "";
                                else {
                                    email = MimeUtility.decodeText(email);
                                }
                                String compositeto = email;
                                ccaddr += "," + compositeto;
                            }
                            ccaddr = ccaddr.substring(1);
                        }
                        q.setQuestionCc(ccaddr);
                        // 标记此邮件的flag标志对象的DELETED位为true,可以在读完邮件后直接删除该附件，具体执行时间是在调用
                        // inbox.close()方法的时候
                        msg[i].setFlag(Flags.Flag.DELETED, true);
                        handle(msg[i], q);
                        q = questionDao.generateQuestionId(q);
                        // getContent() 是获取包裹内容, Part相当于外包装
                        Object o = msg[i].getContent();
                        if (o instanceof Multipart) {
                            Multipart multipart = (Multipart) o;
                            reMultipart(multipart, q);
                        } else if (o instanceof Part) {
                            Part part = (Part) o;
                            rePart(part, q);
                        } else {
                            q.setQuestionContent(msg[i].getContent().toString());
                        }
                        questionDao.update(q);
                    }
                    epwd.setLatestReceiveTime(currentTime);
                    sysUserEmailPWDDao.merge(epwd);
                }
            }
            if (inbox != null) {
                // 参数为true表明阅读完此邮件后将其删除，更多的属性请参考mail.jar的API
                inbox.close(true);
            }
            if (store != null) {
                store.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        try {
            // 连接到邮件服务器并获得邮件
            Properties prop = new Properties();
            prop.put("mail.imap.host", IMAPSERVER);
            prop.put("mail.imap.auth.plain.disable","true");
            Session session = Session.getDefaultInstance(prop, null);
            IMAPStore store = (IMAPStore)session.getStore("imap");
            store.connect(pop3Server, username, password);
            IMAPFolder inbox = (IMAPFolder)store.getDefaultFolder().getFolder("INBOX");
            // 设置inbox对象属性为可读写，这样可以控制在读完邮件后直接删除该附件
            inbox.open(Folder.READ_WRITE);
            Message[] msg = inbox.getMessages();
            FetchProfile profile = new FetchProfile();
            profile.add(FetchProfile.Item.ENVELOPE);
            inbox.fetch(msg, profile);
            for (int i = 0; i < msg.length; i++) {
                if (msg[i].getSentDate().before(latestReceiveTime)) {
                    // 标记此邮件的flag标志对象的DELETED位为true,可以在读完邮件后直接删除该附件，具体执行时间是在调用
                    // inbox.close()方法的时候
                    msg[i].setFlag(Flags.Flag.DELETED, true);
                }
            }
            if (inbox != null) {
                // 参数为true表明阅读完此邮件后将其删除，更多的属性请参考mail.jar的API
                inbox.close(true);
            }
            if (store != null) {
                store.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}