临时邮箱地址获取服务器邮件工作流程与实现

临时邮箱地址获取服务器邮件工作流程与实现

🎯 需求背景

用户需要快速生成一个临时邮箱地址，并通过该地址接收来自外部系统/服务发送的邮件。系统需提供：

• 临时邮箱生成
• 从已有邮箱服务器增量获取邮件
• 过滤出目标收件人邮件
• 返回可用的邮件信息并支持持续监控

🏗️ 总体设计思路

1. 临时邮箱生成：生成 8-12 位用户名 + 从配置中选择域名
2. 邮件获取：基于 IMAP 协议，从服务器增量拉取新邮件
3. 并发解析：根据邮件数量选择串行/并行解析策略
4. 过滤归并：只保留目标收件人（临时邮箱地址）的邮件
5. 返回结果：返回邮件列表；并支持在后台持续监控和清理

🔑 临时邮箱接口-实现映射

• 临时邮箱生成：
  • 后端：GET /api/email/random
    • 实现：EmailService.generateRandomEmail()
• 临时邮箱监控与删除：
  • 后端：POST /api/email/temp-inbox（读取监控内存中的该收件人邮件）
    • 实现：DefaultEmailMonitorService.getRecipientEmailMap(email)
  • 后端：POST /api/email/delete（删除该收件人的所有邮件）
    • 实现：DefaultEmailMonitorService.deleteRecipientEmail(email)

🗃️ 存储数据结构

// 收件人 -> 邮件列表（监控缓存）
private final Map<String, List<EmailMessage>> recipientEmailMap = new ConcurrentHashMap<>();

// 收件人 -> 创建时间戳（毫秒）
private final Map<String, Long> emailCreationTimestamps = new ConcurrentHashMap<>();

// 已处理邮件ID集合（避免重复解析）
private final Set<String> processedMessageIds = ConcurrentHashMap.newKeySet();

// 邮箱保留时间（1天）
private static final long EMAIL_RETENTION_TIME = 24 * 60 * 60 * 1000;

🔧 核心实现要点

1. 临时邮箱生成

后端接口：

@GetMapping("/random")
public ResponseEntity<Map<String, String>> generateRandomEmail() {
    String randomEmail = emailService.generateRandomEmail();
    Map<String, String> response = new HashMap<>();
    response.put("email", randomEmail);
    return ResponseEntity.ok(response);
}

服务实现：

    @Override
    public String generateRandomEmail() {
        String username = generateRandomUsername();
        List<String> domains = emailServerConfig.getRandomDomains();
        if (domains.isEmpty()) {
            return username + "@example.com";
        }
        String domain = domains.get(random.nextInt(domains.size()));
        return username + "@" + domain;
    }

    /**
     * 生成随机用户名
     * 生成8-12位长度的随机用户名，包含字母和数字
     *
     * @return 随机用户名
     */
    private String generateRandomUsername() {
        StringBuilder username = new StringBuilder();
        // 8-12位长度
        int length = 8 + random.nextInt(5);
        for (int i = 0; i < length; i++) {
            username.append(RANDOM_CHARS.charAt(random.nextInt(RANDOM_CHARS.length())));
        }
        return username.toString();
    }

流程：

2. 邮件获取与增量解析（已实现于 IMAP 策略）

策略接口：

List<EmailMessage> fetchEmails(EmailServerParams params, Collection<String> processedMessageIds);

IMAP 实现：

    /**
     * 获取邮件（支持增量获取）
     *
     * @param params              邮件服务器连接参数
     * @param processedMessageIds 已处理的邮件ID集合，用于增量获取
     * @return 邮件列表
     */
    @Override
    public List<EmailMessage> fetchEmails(EmailServerParams params, Collection<String> processedMessageIds) {
        if (!params.isValid()) {
            log.error("邮件服务器参数无效: {}", params.getConnectionString());
            return new ArrayList<>();
        }

        List<EmailMessage> messages = new ArrayList<>();

        try {
            // 使用连接池获取或创建连接
            Store store = connectionFactory.getOrCreateImapStore(params);
            Folder inbox = store.getFolder("INBOX");

            long startTime = System.currentTimeMillis();
            inbox.open(Folder.READ_ONLY);

            SearchTerm searchTerm = buildSearchTerm(params.getSearchCriteriaParam());
            Message[] emailMessages = ObjectUtils.isNotEmpty(searchTerm) ? inbox.search(searchTerm) : inbox.getMessages();
            long fetchTime = System.currentTimeMillis();
            log.debug("获取邮件列表耗时: {}ms", fetchTime - startTime);

            // 如果提供了已处理的邮件ID集合，进行早期过滤
            if (ObjectUtils.isNotEmpty(processedMessageIds)) {
                emailMessages = filterUnprocessedMessages(emailMessages, processedMessageIds);
                log.debug("过滤后需要处理的邮件数量: {}", emailMessages.length);
            }
            // 确保邮件列表不为空
            if (ObjectUtils.isEmpty(emailMessages)){
                return messages;
            }

            // 选择合适的处理方式：串行或并行
            if (emailMessages.length <= SERIAL_PROCESSING_THRESHOLD) {
                processEmailsSerially(emailMessages, messages);
            } else {
                processEmailsInParallel(emailMessages, messages);
            }

        } catch (Exception e) {
            log.error("获取邮件失败: email={}, host={}, port={}", params.getEmail(), params.getHost(), params.getPort(), e);
        } finally {
            // 注意：这里不关闭连接，保持连接在池中复用
        }

        return messages;
    }

流程：

3. 监控与清理

• 定时任务：@Scheduled(fixedRate = 10000) 调用 defaultEmailMonitorService.getDefaultEmails()
• 自动清理过期邮箱：对 emailCreationTimestamps 超过 EMAIL_RETENTION_TIME 的条目进行批量清理
• 删除接口：POST /api/email/delete

flowchart TD
  A[构建连接参数] --> B[IMAP连接池复用连接]
  B --> C[打开INBOX]
  C --> D[可选SearchTerm过滤窗口]
  D --> E[早期过滤已解析Message-ID]
  E --> F{数量阈值?}
  F -->|小于| G[串行解析]
  F -->|大于| H[并行解析]
  G --> I[返回解析后消息]
  H --> I[返回解析后消息]

📝 使用示例

// 生成默认配置的临时邮箱
String randomEmail = emailService.generateRandomEmail();

// 定时任务执行，默认配置获取邮箱列表
defaultEmailMonitorService.getDefaultEmails();

// 删除指定收件人邮件
defaultEmailMonitorService.deleteRecipientEmail("xxx@qq.com");

// 从监控服务获取该临时邮箱的邮件
List<EmailMessage> emails = defaultEmailMonitorService.getRecipientEmailMap(email);

🔭 后续优化方向

• 限流与告警机制（避免雪崩式拉取）