电子邮件发送重复

在代码中处理电子邮件发送重复的问题，可以通过以下几种方式来解决：

1. 数据库记录：在发送邮件之前，可以在数据库中记录每封邮件的唯一标识，例如邮件的主题或邮件的哈希值。在发送新邮件之前，检查数据库中是否已经存在相同的唯一标识，如果存在，则表示邮件已经发送过，可以选择跳过发送。

import hashlib

def send_email(subject, content):
    email_hash = hashlib.md5(subject.encode()).hexdigest()
    # 检查邮件是否已经发送过
    if check_email_sent(email_hash):
        return
    # 发送邮件的代码
    # ...
    # 记录已发送的邮件
    record_email_sent(email_hash)

def check_email_sent(email_hash):
    # 检查邮件是否已经发送过，可以查询数据库或者其他数据存储方式
    return email_hash in sent_emails

def record_email_sent(email_hash):
    # 记录已发送的邮件，可以写入数据库或者其他数据存储方式
    sent_emails.add(email_hash)

2. 发送邮件后的确认：发送邮件后，可以等待邮件服务器返回发送成功的确认消息，然后再记录已发送的邮件。如果收到发送成功的确认消息，则表示邮件已经成功发送，否则表示发送失败，可以重试发送。

import smtplib

def send_email(subject, content):
    # 发送邮件的代码，此处省略
    # ...
    # 等待邮件服务器返回发送成功的确认消息
    try:
        smtp_obj = smtplib.SMTP('smtp.example.com')
        smtp_obj.sendmail(sender, receiver, message)
    except smtplib.SMTPException:
        # 发送失败，重试发送或者处理其他逻辑
        return
    # 记录已发送的邮件
    record_email_sent(subject)

def record_email_sent(subject):
    # 记录已发送的邮件，可以写入数据库或者其他数据存储方式
    sent_emails.add(subject)

3. 使用消息队列：将待发送的邮件放入消息队列中，由一个或多个工作进程异步处理发送邮件的任务。每个工作进程从队列中获取待发送的邮件，发送完毕后再记录已发送的邮件。

import queue
import threading

email_queue = queue.Queue()
sent_emails = set()

def send_email_worker():
    while True:
        subject, content = email_queue.get()
        # 发送邮件的代码
        # ...
        # 记录已发送的邮件
        record_email_sent(subject)
        email_queue.task_done()

def send_email(subject, content):
    # 将待发送的邮件放入队列
    email_queue.put((subject, content))

def record_email_sent(subject):
    # 记录已发送的邮件，可以写入数据库或者其他数据存储方式
    sent_emails.add(subject)

# 创建多个工作线程
for _ in range(5):
    t = threading.Thread(target=send_email_worker)
    t.daemon = True
    t.start()

以上是一些常用的解决方法，具体使用哪种方法取决于你的应用场景和需求。