转自:http://www.360doc.com/content/14/0103/13/11789990_342303735.shtml
参考了一些网络上的资料，做了个简单程序，使用python接收邮件并保存到mysql中。
#------------------------------------------------------------------------------- # Name: 接收邮件模块 # Purpose: # # Author: garfield # # Created: 15-02-2011 # Copyright: (c) garfield 2011 # Licence: <your licence> #------------------------------------------------------------------------------- #_*_encoding:utf-8_*_ ####源代码用来接收邮件 import MySQLdb import time import poplib import pickle import email,string,sys,os from email.Header import Header from email.Header import decode_header from time import strptime, strftime ISOTIMEFORMAT="%Y-%m-%d %X" #定义数据库常量 MySQL_Server="localhost" MySQL_User="root" MySQL_Password="****" MySQL_Database="Python" #定义邮件服务器常量 POP3Sever='pop3.sina.com' POP3User='mailuser' POP3Password='*****' CurMailID=-1 #取信息编码 def get_charset(message, default="ascii"): #Get the message charset return message.get_charset() return default def SaveMail(Sender,Receiver,Subject,SendDate,ReceiveDate,TextContent,HTMLContent,OriginalMailinfo): #save mail info to mysql Sender=MySQLdb.escape_string(Sender) Receiver=MySQLdb.escape_string(Receiver) Subject=MySQLdb.escape_string(Subject) TextContent=MySQLdb.escape_string(TextContent) HTMLContent=MySQLdb.escape_string(HTMLContent) OriginalMailinfo=MySQLdb.escape_string(OriginalMailinfo) conn = MySQLdb.connect(MySQL_Server,MySQL_User,MySQL_Password,MySQL_Database,port=3306,connect_timeout=10,compress=True,charset='utf8',use_unicode=True) cursor=conn.cursor() vsql="insert into mail(Sender,Receiver,Subject,SendDate,ReceiveDate,TextContent,HTMLContent,OriginalMailinfo) values('%s','%s','%s','%s','%s','%s','%s','%s')" % (Sender,Receiver,Subject,SendDate,ReceiveDate,TextContent,HTMLContent,OriginalMailinfo) ; vsql = vsql.encode('utf8') cursor.execute(vsql)#一条SQL语句 vsql = "SELECT max(id) from mail" cursor.execute(vsql) CurMailID=cursor.fetchone()[0] conn.commit() cursor.close() conn.close() def SaveMailAtta(vMailID,vFileName,Content,IsInline): vFileName=MySQLdb.escape_string(vFileName) Content=MySQLdb.escape_string(Content) conn = MySQLdb.connect(MySQL_Server,MySQL_User,MySQL_Password,MySQL_Database,port=3306,connect_timeout=10,compress=True,charset='utf8',use_unicode=True) cursor=conn.cursor() vsql="insert into mailatta(mailid,filename,content,isinline) values('%s','%s','%s','%s')" % (vMailID,vFileName,Content,IsInline) ; vsql = vsql.encode('utf8') cursor.execute(vsql)#一条SQL语句 conn.commit() cursor.close() conn.close() #解析邮件 def ParseMail(mail): textplain='' texthtml='' atta={} if mail.is_multipart(): for par in mail.walk(): if not par.is_multipart(): # 这里要判断是否是multipart，是的话，里面的数据是无用的，至于为什么可以了解mime相关知识。 name = par.get_param("name") #如果是附件，这里就会取出附件的文件名 if name: #有附件 # 下面的三行代码只是为了解码象=?gbk?Q?=CF=E0=C6=AC.rar?=这样的文件名 h = email.Header.Header(name) dh = email.Header.decode_header(h) fname = dh[0][0] #print '有附件'+fname data = par.get_payload(decode=True) # 解码出附件数据，然后存储到文件中 atta[fname]=data """ try: f = open(fname, 'wb') #注意一定要用wb来打开文件，因为附件一般都是二进制文件 except: print '附件名有非法字符，自动换一个' f = open('aaaa', 'wb') f.write(data) f.close() """ else: #不是附件，是文本内容 content_type=par.get_content_type() charset = get_charset(par) if content_type in ['text/plain']: if charset==None: textplain=par.get_payload(decode=True) else: textplain=par.get_payload(decode=True).decode(charset) if content_type in ['text/html']: if charset==None: texthtml=par.get_payload(decode=True) else: texthtml=par.get_payload(decode=True).decode(charset) else: type=mail.get_content_charset() if type==None: textplain=mail.get_payload() else: try: textplain=unicode(mail.get_payload('base64'),type) except UnicodeDecodeError: textplain='Error' return (textplain,texthtml,atta) def main(): t=time.strftime( ISOTIMEFORMAT, time.localtime()) popClient=poplib.POP3(POP3Sever) popClient.set_debuglevel(1) popClient.user(POP3User) popClient.pass_(POP3Password) numMsgs,mboxSize=popClient.stat() for id in range (numMsgs): hdr,message,octet=popClient.retr(id+1) mail=email.message_from_string(string.join(message, ' ')) subject=mail.get("subject") h = email.Header.Header(subject) dh = email.Header.decode_header(h) subject = dh[0][0] FromAddr=email.utils.parseaddr(mail['from'])[1] ToAddr=email.utils.parseaddr(mail['To'])[1] mdate=mail.get('date') #'Wed, 16 Feb 2011 14:34:44 +0800' mdate=mdate[0:len(mdate)-6] #:取邮件中的时间进行处理 md= mktime(strptime(mdate,"%a, %d %b %Y %H:%M:%S")) MailDate=time.strftime(ISOTIMEFORMAT,time.localtime(md)) originalmailinfo=mail.as_string() TextContent,HTMLContent,MailAtta=ParseMail(mail) #保存邮件 SaveMail(FromAddr,ToAddr,subject,MailDate,MailDate,TextContent,HTMLContent,originalmailinfo) #保存邮件附件 #for fk in MailAtta.keys(): # SaveMailAtta(CurMailID,fk,MailAtta[fk],False) popClient.quit() if __name__=='__main__': main() 但附件因为是二进制文件，所以保存到数据库中时需要序列化或进行其他处理，所以以上程序中的附件还不能这么简单地进行保存，需要进一步修改。 MySQL数据库脚本： -- -- 表的结构 `mail` -- CREATE TABLE IF NOT EXISTS `mail` ( `ID` int(10) NOT NULL auto_increment, `Sender` text, `Receiver` text, `SendDate` datetime default NULL, `ReceiveDate` datetime default NULL, `Subject` varchar(500) default NULL, `TextContent` text, `HTMLContent` text, `OriginalMailInfo` text, PRIMARY KEY (`ID`) ) ENGINE=MyISAM DEFAULT CHARSET=utf8 AUTO_INCREMENT=546 ; -- -- -- 表的结构 `mailatta` -- CREATE TABLE IF NOT EXISTS `mailatta` ( `ID` int(11) NOT NULL auto_increment, `MailID` int(11) NOT NULL, `filename` varchar(200) NOT NULL, `isinline` tinyint(1) NOT NULL, `conent` blob NOT NULL, PRIMARY KEY (`ID`) ) ENGINE=MyISAM DEFAULT CHARSET=utf8 AUTO_INCREMENT=1 ;