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

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

🎯 需求背景

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

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

🏗️ 总体设计思路

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

• 临时邮箱生成：
  • 后端：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();
}

流程：

#mermaid-svg-lfPPTJyQ4pwSDivk {font-family:\”trebuchet ms\”,verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-lfPPTJyQ4pwSDivk .error-icon{fill:#552222;}#mermaid-svg-lfPPTJyQ4pwSDivk .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-lfPPTJyQ4pwSDivk .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-lfPPTJyQ4pwSDivk .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-lfPPTJyQ4pwSDivk .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-lfPPTJyQ4pwSDivk .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-lfPPTJyQ4pwSDivk .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-lfPPTJyQ4pwSDivk .marker{fill:#333333;stroke:#333333;}#mermaid-svg-lfPPTJyQ4pwSDivk .marker.cross{stroke:#333333;}#mermaid-svg-lfPPTJyQ4pwSDivk svg{font-family:\”trebuchet ms\”,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-lfPPTJyQ4pwSDivk .label{font-family:\”trebuchet ms\”,verdana,arial,sans-serif;color:#333;}#mermaid-svg-lfPPTJyQ4pwSDivk .cluster-label text{fill:#333;}#mermaid-svg-lfPPTJyQ4pwSDivk .cluster-label span{color:#333;}#mermaid-svg-lfPPTJyQ4pwSDivk .label text,#mermaid-svg-lfPPTJyQ4pwSDivk span{fill:#333;color:#333;}#mermaid-svg-lfPPTJyQ4pwSDivk .node rect,#mermaid-svg-lfPPTJyQ4pwSDivk .node circle,#mermaid-svg-lfPPTJyQ4pwSDivk .node ellipse,#mermaid-svg-lfPPTJyQ4pwSDivk .node polygon,#mermaid-svg-lfPPTJyQ4pwSDivk .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-lfPPTJyQ4pwSDivk .node .label{text-align:center;}#mermaid-svg-lfPPTJyQ4pwSDivk .node.clickable{cursor:pointer;}#mermaid-svg-lfPPTJyQ4pwSDivk .arrowheadPath{fill:#333333;}#mermaid-svg-lfPPTJyQ4pwSDivk .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-lfPPTJyQ4pwSDivk .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-lfPPTJyQ4pwSDivk .edgeLabel{background-color:#e8e8e8;text-align:center;}#mermaid-svg-lfPPTJyQ4pwSDivk .edgeLabel rect{opacity:0.5;background-color:#e8e8e8;fill:#e8e8e8;}#mermaid-svg-lfPPTJyQ4pwSDivk .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-lfPPTJyQ4pwSDivk .cluster text{fill:#333;}#mermaid-svg-lfPPTJyQ4pwSDivk .cluster span{color:#333;}#mermaid-svg-lfPPTJyQ4pwSDivk div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\”trebuchet ms\”,verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-lfPPTJyQ4pwSDivk :root{–mermaid-font-family:\”trebuchet ms\”,verdana,arial,sans-serif;}请求生成随机邮箱生成随机用户名从配置选择域名拼接邮箱地址返回邮箱地址

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

流程：

#mermaid-svg-Y6hTZfROHL5pNh2N {font-family:\”trebuchet ms\”,verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-Y6hTZfROHL5pNh2N .error-icon{fill:#552222;}#mermaid-svg-Y6hTZfROHL5pNh2N .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-Y6hTZfROHL5pNh2N .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-Y6hTZfROHL5pNh2N .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-Y6hTZfROHL5pNh2N .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-Y6hTZfROHL5pNh2N .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-Y6hTZfROHL5pNh2N .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-Y6hTZfROHL5pNh2N .marker{fill:#333333;stroke:#333333;}#mermaid-svg-Y6hTZfROHL5pNh2N .marker.cross{stroke:#333333;}#mermaid-svg-Y6hTZfROHL5pNh2N svg{font-family:\”trebuchet ms\”,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-Y6hTZfROHL5pNh2N .label{font-family:\”trebuchet ms\”,verdana,arial,sans-serif;color:#333;}#mermaid-svg-Y6hTZfROHL5pNh2N .cluster-label text{fill:#333;}#mermaid-svg-Y6hTZfROHL5pNh2N .cluster-label span{color:#333;}#mermaid-svg-Y6hTZfROHL5pNh2N .label text,#mermaid-svg-Y6hTZfROHL5pNh2N span{fill:#333;color:#333;}#mermaid-svg-Y6hTZfROHL5pNh2N .node rect,#mermaid-svg-Y6hTZfROHL5pNh2N .node circle,#mermaid-svg-Y6hTZfROHL5pNh2N .node ellipse,#mermaid-svg-Y6hTZfROHL5pNh2N .node polygon,#mermaid-svg-Y6hTZfROHL5pNh2N .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-Y6hTZfROHL5pNh2N .node .label{text-align:center;}#mermaid-svg-Y6hTZfROHL5pNh2N .node.clickable{cursor:pointer;}#mermaid-svg-Y6hTZfROHL5pNh2N .arrowheadPath{fill:#333333;}#mermaid-svg-Y6hTZfROHL5pNh2N .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-Y6hTZfROHL5pNh2N .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-Y6hTZfROHL5pNh2N .edgeLabel{background-color:#e8e8e8;text-align:center;}#mermaid-svg-Y6hTZfROHL5pNh2N .edgeLabel rect{opacity:0.5;background-color:#e8e8e8;fill:#e8e8e8;}#mermaid-svg-Y6hTZfROHL5pNh2N .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-Y6hTZfROHL5pNh2N .cluster text{fill:#333;}#mermaid-svg-Y6hTZfROHL5pNh2N .cluster span{color:#333;}#mermaid-svg-Y6hTZfROHL5pNh2N div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\”trebuchet ms\”,verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-Y6hTZfROHL5pNh2N :root{–mermaid-font-family:\”trebuchet ms\”,verdana,arial,sans-serif;}小于大于构建连接参数IMAP连接池复用连接打开INBOX可选SearchTerm过滤窗口早期过滤已解析Message-ID数量阈值?串行解析并行解析返回解析后消息

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

🔭 后续优化方向

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