邮件聊天机器人重复发送消息问题的修复方案咨询

问题描述 #

开发邮件聊天机器人时遇到问题：发送第一条消息后，收到用户回复时，机器人会持续重复发送针对该回复的响应，直到收到新回复才切换重复内容。初步设想通过设置变量检测新邮件，并添加仅收到新邮件时才响应的条件，想咨询更合理的修复方案。

附接收邮件代码 #

def receive_email():
    try:
        mail = imaplib.IMAP4_SSL("smtp.gmail.com")
        mail.login(email_address, email_password)
        mail.select('inbox')
        # 搜索收件箱
        status, data = mail.search(None, 'Recent')
        mail_ids = data[0].split()
        latest_email_id = mail_ids[-1]
        status, data = mail.fetch(latest_email_id, '(RFC822)')
        # 获取消息内容
        for response_part in data:
            if isinstance(response_part, tuple):
                msg = email.message_from_bytes(response_part[1])
                sender = msg['from']
                subject = msg['subject']
                if msg.is_multipart():
                    for part in msg.get_payload():
                        if part.get_content_type() == 'text/plain':
                            return part.get_payload()
                    message = msg.get_payload()
                    return message,
    except Exception as e:
        print("Error: ", e)
        print("Could not receive email")
        return None, None

修复方案 #

核心思路：跟踪已处理的邮件ID #

你的初步思路方向正确，但可以更严谨——直接记录已处理过的邮件ID，每次拉取邮件时只处理未被记录的新邮件，从根源避免重复响应。

具体实现步骤 #

1. 存储已处理ID
   在函数外定义集合变量processed_email_ids = set()，保存已处理的邮件ID。如果需要重启机器人后不丢失记录，可将集合存入本地文件或轻量数据库（如SQLite）。

2. 修改邮件接收逻辑

   • 拉取邮件时遍历所有目标邮件（而非仅最新一封）
   • 对每个邮件ID先检查是否已处理，未处理才执行后续逻辑
   • 处理完成后将该ID加入已处理集合

3. 修正原代码细节问题

   • IMAP服务器地址错误，应改为imap.gmail.com（原代码写的是SMTP地址）
   • 原函数返回格式混乱，统一返回结构避免后续逻辑出错

优化后的代码示例 #

processed_email_ids = set()

def receive_email():
    try:
        # 修正IMAP服务器地址
        mail = imaplib.IMAP4_SSL("imap.gmail.com")
        mail.login(email_address, email_password)
        # 只读模式打开收件箱，避免误操作
        mail.select('inbox', readonly=True)
        # 搜索未读邮件（比Recent更可靠）
        status, data = mail.search(None, 'UNSEEN')
        mail_ids = data[0].split()
        new_messages = []
        
        for mail_id in mail_ids:
            # 跳过已处理邮件
            if mail_id in processed_email_ids:
                continue
            status, data = mail.fetch(mail_id, '(RFC822)')
            for response_part in data:
                if isinstance(response_part, tuple):
                    msg = email.message_from_bytes(response_part[1])
                    sender = msg['from']
                    subject = msg['subject']
                    message_content = ""
                    # 解析邮件内容
                    if msg.is_multipart():
                        for part in msg.get_payload():
                            if part.get_content_type() == 'text/plain':
                                message_content = part.get_payload()
                                break
                    else:
                        message_content = msg.get_payload()
                    # 标记为已处理
                    processed_email_ids.add(mail_id)
                    new_messages.append({
                        "sender": sender,
                        "subject": subject,
                        "content": message_content
                    })
        return new_messages
    except Exception as e:
        print("Error: ", e)
        print("Could not receive email")
        return []

额外建议 #

• 用UNSEEN替代Recent：IMAP的Recent标记在部分客户端读取后会失效，UNSEEN专门标识未读邮件，逻辑更可靠
• 持久化已处理ID：用pickle将集合写入本地文件，或存入SQLite，确保机器人重启后不会重复处理旧邮件
• 控制轮询频率：检查邮件的间隔设为10-30秒，避免触发邮箱的请求限制

内容的提问来源于stack exchange，提问作者SRTAI22