如何通过Python多线程实现Outlook邮件的读取与发送？

首先明确：Outlook的COM组件基于单线程公寓（STA）模型，主线程创建的Outlook/MAPI对象不能直接在子线程中使用，每个线程必须独立初始化COM环境，且只能访问自身线程内创建的COM对象。

核心实现思路 #

1. 主线程先筛选出目标邮件，只提取邮件的唯一标识EntryID和StoreID（避免跨线程传递COM对象）
2. 每个子线程启动时初始化pythoncom的STA环境，结束时释放资源
3. 子线程通过EntryID和StoreID重新获取邮件对象，执行回复操作

完整代码示例 #

import win32com.client
import pythoncom
import threading
from typing import List, Tuple

# 全局配置
MAINTENANCE_DATE = "2024-05-01 00:00:00"  # 替换成你的日期筛选条件
THREAD_COUNT = 4  # 根据机器性能调整线程数

def get_target_mail_ids() -> List[Tuple[str, str]]:
    """主线程获取符合条件的邮件EntryID和StoreID"""
    outlook = win32com.client.Dispatch("Outlook.Application")
    mapi = outlook.GetNamespace("MAPI")
    inbox = mapi.GetDefaultFolder(6)  # 6对应收件箱
    messages = inbox.Items
    messages.Sort("[ReceivedTime]", True)  # 按接收时间排序
    # 应用筛选条件
    filtered_messages = messages.Restrict(f"[ReceivedTime] >= '{MAINTENANCE_DATE}'")
    
    mail_ids = []
    for msg in filtered_messages:
        try:
            # 保存EntryID和StoreID，用于子线程重新获取邮件
            mail_ids.append((msg.EntryID, msg.StoreID))
        except Exception as e:
            print(f"获取邮件ID失败: {str(e)}")
    return mail_ids

def process_mail(mail_info: Tuple[str, str]):
    """子线程处理单封邮件的回复"""
    entry_id, store_id = mail_info
    # 初始化COM环境（必须在子线程内调用）
    pythoncom.CoInitialize()
    try:
        outlook = win32com.client.Dispatch("Outlook.Application")
        mapi = outlook.GetNamespace("MAPI")
        # 通过EntryID和StoreID获取邮件对象
        msg = mapi.GetItemFromID(entry_id, store_id)
        
        # 执行回复操作
        mail_reply = msg.ReplyAll()
        mail_reply.Body = f"This is a reply!\nRegards\n{mail_reply.Body}"
        # 如果需要修改To/CC可以在这里调整
        # mail_reply.To = "xxx@example.com"
        mail_reply.Save()
        mail_reply.Send()
        print(f"成功回复邮件: {msg.Subject}")
    except Exception as e:
        print(f"处理邮件失败: {str(e)}")
    finally:
        # 释放COM资源
        pythoncom.CoUninitialize()

def main():
    mail_ids = get_target_mail_ids()
    if not mail_ids:
        print("没有符合条件的邮件")
        return
    
    # 拆分任务到多个线程
    threads = []
    # 按线程数拆分邮件ID列表
    batch_size = len(mail_ids) // THREAD_COUNT + 1
    for i in range(THREAD_COUNT):
        start_idx = i * batch_size
        end_idx = min((i+1)*batch_size, len(mail_ids))
        batch = mail_ids[start_idx:end_idx]
        if not batch:
            continue
        thread = threading.Thread(target=lambda b: [process_mail(m) for m in b], args=(batch,))
        threads.append(thread)
        thread.start()
    
    # 等待所有线程完成
    for thread in threads:
        thread.join()
    print("所有邮件处理完成")

if __name__ == "__main__":
    main()

关键注意事项 #

• COM环境初始化：每个子线程必须调用pythoncom.CoInitialize()和pythoncom.CoUninitialize()，否则会出现COM错误
• 避免跨线程传递COM对象：绝对不能把主线程的messages、msg等COM对象直接传给子线程，必须用EntryID+StoreID重新获取
• 线程数量控制：不要设置过多线程（建议4-8个），过多线程会导致Outlook COM组件负载过高，反而降低效率甚至崩溃
• 异常处理：必须捕获处理单个邮件的异常，避免一个邮件处理失败导致整个线程终止

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