本文实例讲述了Python编程实现及时获取新邮件的方法。分享给大家供大家参考，具体如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
|
#-*- encoding: utf-8 -*-
import sys
import locale
import poplib
from email import parser
import email
import string
import mysql.connector
import traceback
import datetime
from mysql.connector import errorcode
import time
import re
reload(sys);
sys.setdefaultencoding('utf8');
# 确定运行环境的encoding
__g_codeset = sys.getdefaultencoding()
if "ascii"==__g_codeset:
__g_codeset = 'utf8';
#
def object2double(obj):
if(obj==None or obj==""):
return 0
else:
return float(obj)
#end if
#
def getMailIndex():
file = open('mailindex.txt',"r");
lines = file.readlines();
file.close();
return int(lines[0]);
#
def setMailIndex(index):
f = open('mailindex.txt', 'w');
f.write(index);
f.close();
#
def utf8_to_mbs(s):
return s.decode("utf-8").encode(__g_codeset)
#
def utf8_to_gbk(s):
return s.decode("utf-8").encode('gb2312')
#
def mbs_to_utf8(s):
return s.decode(__g_codeset).encode("utf-8")
#
def gbk_to_utf8(s):
return s.decode('gb2312').encode("utf-8")
#
def _queryQuick(cu,sql,tuple):
try:
cu.execute(sql,tuple);
rows = []
for row in cu:
rows.append(row)
#
return rows
except:
print(traceback.format_exc())
#end
#
#获取信息
def _queryRows(cu,sql):
try:
cu.execute(sql)
rows = []
for row in cu:
rows.append(row)
#
return rows
except:
print(traceback.format_exc())
#end
#
#是否有新邮件
global hasNewMail;
hasNewMail=True;
#全局已读的邮件数量
global globalMailReaded;
globalMailReaded=getMailIndex()+1;
#获取新邮件
def getNewMail(conn2,cur2):
try:
global hasNewMail;
global globalMailReaded;
conn2.commit();
rows=_queryRows(cur2,"select count(*) as message_count from hm_messages where messageaccountid=1");
message_count=rows[0][0];
if(hasNewMail):
print('read mailindex.txt')
globalMailReaded=getMailIndex()+1;
#end if
if(message_count<=globalMailReaded):
hasNewMail=False;
#print('Did not receive new mail,continue wait...')
return None;#没新邮件，直接返回
#end if
#登陆邮箱
host = '127.0.0.1'
username = 'username@myserver.net'
password = 'password'
pop_conn = poplib.POP3(host)
#print pop_conn.getwelcome()
pop_conn.user(username);
pop_conn.pass_(password);
#Get messages from server:
messages = [pop_conn.retr(i) for i in range(1, len(pop_conn.list()[1]) + 1)]
# Concat message pieces:
messages = ["\n".join(mssg[1]) for mssg in messages]
#Parse message intom an email object:
messages = [parser.Parser().parsestr(mssg) for mssg in messages]
print("get new mail!");
print pop_conn.stat()
print('%s readed mail count is %d,all mail count is: %d'%(datetime.datetime.now().strftime("%y-%m-%d %H:%M:%S"),globalMailReaded,len(messages)))
message = messages[globalMailReaded];
subject = message.get('subject')
h = email.Header.Header(subject)
dh = email.Header.decode_header(h)
#subject = unicode(dh[0][0], dh[0][1]).encode('utf8')
#print >> f, "Date: ", message["Date"]
#print >> f, "From: ", email.utils.parseaddr(message.get('from'))[1]
#print >> f, "To: ", email.utils.parseaddr(message.get('to'))[1]
#print >> f, "Subject: ", subject
j = 0
for part in message.walk():
j = j + 1
fileName = part.get_filename()
contentType = part.get_content_type()
mycode=part.get_content_charset();
# 保存附件
if fileName:
pass;
elif contentType == 'text/plain':# or contentType == 'text/html':
#保存正文
data = part.get_payload(decode=True)
content=str(data);
if mycode=='gb2312':
content= gbk_to_utf8(content)
#end if
content=content.replace(u'\u200d','');
setMailIndex(str(globalMailReaded));
hasNewMail=True;
pop_conn.quit();
return (content,email.utils.parseaddr(message.get('from'))[1]);
#end if
#end for
except:
print("search hmailserver fail,try again");
return None;
finally:
pass;
#end try
#end def
#连接数据库
conn2 = mysql.connector.connect(user='root', password='password',host='127.0.0.1',database='hmailserver',charset='gb2312');
cur2 = conn2.cursor();
#只要收到电子邮件，就把这个事件记录在事件库中
#现在就是循环查询邮箱，如果有新邮件就读取，并查询关键词库
while(True):
mailtuple=getNewMail(conn2,cur2);
if(mailtuple==None):
#print('Did not search MySQL,continue loop...')
time.sleep(0.5)
continue;
#end if
(article,origin)=mailtuple;
#end while
|
希望本文所述对大家Python程序设计有所帮助。
原文链接：http://blog.csdn.net/liumengcheng/article/details/44961081