Java怎么用代码实现将邮件拉取到数据库中把附件保存在本地中

Java 可以使用 JavaMail API 实现将邮件拉取到数据库并保存附件至本地。具体实现大致流程如下：

1. 使用 JavaMail API 连接邮箱服务器，获取邮件信息。
2. 解析邮件，获取邮件中的附件。
3. 将邮件存入数据库中，并返回该邮件在数据库中的 ID。
4. 将附件按照邮件 ID 和附件名保存至本地。

示例代码如下（需要替换成对应的邮箱地址、用户名、密码、数据库信息）：

// 连接邮箱服务器
String host = "smtp.gmail.com";
String username = "your_email_address";
String password = "your_email_password";
Properties props = new Properties();
props.put("mail.smtp.auth", "true");
props.put("mail.smtp.starttls.enable", "true");
props.put("mail.smtp.host", host);
props.put("mail.smtp.port", "587");
Session session = Session.getInstance(props, new Authenticator() {
    protected PasswordAuthentication getPasswordAuthentication() {
        return new PasswordAuthentication(username, password);
    }
});

// 获取邮件信息
Store store = session.getStore("imaps");
store.connect(host, username, password);
Folder inbox = store.getFolder("INBOX");
inbox.open(Folder.READ_ONLY);
Message[] messages = inbox.getMessages();

// 处理邮件
Connection conn = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD);
PreparedStatement stmt = conn.prepareStatement("INSERT INTO emails (subject, content) VALUES (?, ?)",
    Statement.RETURN_GENERATED_KEYS);
for (Message message : messages) {
    // 保存邮件
    stmt.setString(1, message.getSubject());
    stmt.setString(2, message.getContent().toString());
    stmt.executeUpdate();
    ResultSet rs = stmt.getGeneratedKeys();
    rs.next();
    int emailId = rs.getInt(1);

    // 保存附件
    Multipart multipart = (Multipart) message.getContent();
    for (int i = 0; i < multipart.getCount(); i++) {
        BodyPart bodyPart = multipart.getBodyPart(i);
        if (Part.ATTACHMENT.equalsIgnoreCase(bodyPart.getDisposition())) {
            String fileName = bodyPart.getFileName();
            InputStream is = bodyPart.getInputStream();
            // 保存附件
            FileOutputStream fos = new FileOutputStream("path/to/attachments/" + emailId + "_" + fileName);
            byte[] buf = new byte[4096];
            int bytesRead;
            while ((bytesRead = is.read(buf)) != -1) {
                fos.write(buf, 0, bytesRead);
            }
            fos.close();
            is.close();
        }
    }
}
conn.close();

// 关闭连接
inbox.close(false);
store.close();