验证Exchange邮箱用户是否存在

# -*- coding: utf-8 -*-import dns.resolverimport argparsefrom socket import *import random
def ColorPrint(string="", flag="", verbose=""):    colors = {        u"gray": "2",        u"red": "31",        u"green": "32",        u"yellow": "33",        u"blue": "34",        u"pink": "35",        u"cyan": "36",        u"white": "37",    }    flags = {        u"error": "[-] ",        u"warning": "[!] ",        u"info": "[*] ",        u"success": "[+] ",        u"debug": ">>> ",        u"echo": ">>> "    }    try:        if flag == 'error':            print(u"33[%sm%s%s" % (colors[u"red"], flags[flag], string))        if flag =="info":            print(u"33[%sm%s%s" % (colors[u"white"], flags[flag], string))        if flag == 'echo' or flag == '' or flag == 0:            print(u"33[%sm%s%s" % (colors[u"white"], flags[flag], string))        if flag == 'success':            print(u"33[%sm%s%s" % (colors[u"green"], flags[flag], string))        if verbose == 1:            if flag == 'warning':                print(u"33[%sm%s%s" % (colors[u"yellow"], flags[flag], string))            if flag == 'debug':                print(u"33[%sm%s%s" % (colors[u"white"], flags[flag], string))    except:        return 0
# 第一步: 获取域名MX 记录def DNSQuery(mailaddr):    dns_resolver = dns.resolver.Resolver(configure=False)    dns_resolver.timeout = 5    dns_resolver.lifetime = 5    dns_resolver.nameservers = ['119.29.29.29']    record = "MX"    domain = mailaddr[mailaddr.find(u"@") + 1:]    ColorPrint("query MX of DNS for %s" % domain, flag= "echo", verbose=verbose)    try:        MX = dns_resolver.resolve(domain, record)        m = random.randint(0, len(MX))        mx = MX[0].exchange        strMx = str(mx)[:-1]        assert strMx != u""    except Exception as e:        ColorPrint("query MX of %s failed: %s" % (strMx, e), flag="error", verbose=verbose)        return 0    ColorPrint("MX Server: %s" % strMx, flag="info", verbose=verbose)    return strMx
# 第二步: 请求mail服务器def smtpsend(server, port=20, mail_rcptTo=""):    mailserver = (server, port)    clientSocket = socket(AF_INET, SOCK_STREAM)    helloDomain = server[server.find(u".") + 1:]    mail_from = "[email protected]"    ColorPrint("connect to %s:%.f" % (server, port), flag="debug", verbose=verbose)    try:        clientSocket.connect(mailserver)        recv = clientSocket.recv(1024)        recv = recv.decode()        if recv[0:3] != '220':            ColorPrint("info: " + recv, flag="debug", verbose=verbose)            return 0    except Exception as e:        ColorPrint("Error: %s" % e, flag="error", verbose=verbose)        ColorPrint("Done. " , flag="info", verbose=verbose)        return 0    ColorPrint("Message after connection request: n" + recv, flag="debug", verbose=verbose)    hello_command = "EHLO %srn" % helloDomain    clientSocket.send(hello_command.encode())    recv1 = clientSocket.recv(1024)    recv1 = recv1.decode()    ColorPrint("Message after EHLO command:n" + recv1, flag="debug", verbose=verbose)    if recv1[:3] != '250':        ColorPrint("250 reply not received from server." + recv1, flag="error", verbose=verbose)        return 0    mail_from_command = "MAIL FROM:<%s>rn" % mail_from    clientSocket.send(mail_from_command.encode())    recv2 = clientSocket.recv(1024)    recv2 = recv2.decode()    ColorPrint("After MAIL FROM command: " + recv2, flag="debug", verbose=verbose)    rcptTo = "RCPT TO:<%s>rn" % mail_rcptTo    clientSocket.send(rcptTo.encode())    recv3 = clientSocket.recv(1024)    recv3 = recv3.decode()    if recv3[:3] == '550':        ColorPrint("Account: %s does not exist." % mail_rcptTo,  flag="error", verbose=verbose)        ColorPrint("Done. ", flag="info", verbose=verbose)        return 0    ColorPrint("Account: %s exists." % mail_rcptTo, flag="success", verbose=verbose)    ColorPrint("After RCPT TO command: %s" % recv3, flag="debug", verbose=verbose)    quit = "QUITrn"    clientSocket.send(quit.encode())    recv4 = clientSocket.recv(1024)    clientSocket.close()    ColorPrint("Done. " , flag="info", verbose=verbose)    return mail_rcptTo

if __name__ == "__main__":    '''    port = 25    verbose = False # 详细输出,可输出debug信息    mailaddr = "[email protected]" # 需要验证的邮箱地址    mail_rcptTo = mailaddr    server = DNSQuery(mailaddr)    smtpsend(server, port, mail_rcptTo)    '''    parser = argparse.ArgumentParser()    parser.add_argument("-e", "--email",                        help="Verification Email Address.", required=True)    parser.add_argument("-s", "--server",                        help="Smtp Server.")    parser.add_argument("-p", "--port",                        help="Smtp Server Port.", default=25, type=int)    parser.add_argument("-v", "--verbose",                        help="verbose info (choice in [True, False])", default=False, type=bool)
    args = parser.parse_args()
    port = args.port    verbose = args.verbose    mailaddr = args.email    mail_rcptTo = mailaddr    server = args.server    if server == None:        server = DNSQuery(mailaddr)    smtpsend(server, port, mail_rcptTo)