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

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

🎯 需求背景

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

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

🏗️ 总体设计思路

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);
}

服务实现：

    @Overridepublic 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 邮件列表*/@Overridepublic 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 TDA[构建连接参数] --> 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("[e-mail]");// 从监控服务获取该临时邮箱的邮件
List<EmailMessage> emails = defaultEmailMonitorService.getRecipientEmailMap(email);

🔭 后续优化方向

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