ESP8226 SMTP的Micropython SSL连接问题



因此,在进行大量研究之后,我就可以使用Google的Gmail服务器发送SMTP电子邮件。我在Windows和Linux上都在Cpython中使用相同的代码,但是当我尝试在ESP8266上使用Micropython 1.9.2(最新截至9月11日)上的代码或Unix端口时,代码在第63行上锁定,但我无法弄清楚原因。

关于如何纠正这一问题的任何建议将不胜感激,因为我唯一能想到的是,Micropython的SSL实现不够,我需要尝试将Cpython SSL移植到Over上。

谢谢。

有问题的代码是:

61    heloCommand = 'EHLO Alicern'
62    ssl_clientSocket.write(heloCommand.encode())
63    recv1 = ssl_clientSocket.read(1024)
64    print(recv1)

代码(是的,我知道这很丑陋,并计划在Micropython工作后清理它):

    # Micropython
try:
  import usocket as socket
  #import base64
  import ussl as ssl
except:
# Python version 3
  import socket
  #import base64
  import ssl

msg = """From: XXX@gmail.com
To: XXX@gmail.com
Subject: Testing
Testing transmission thru python
"""
endmsg = "rn.rn"
recipient = "XXX@gmail.com"
sender = "XXX@gmail.com"
username = "XXX@gmail.com"
password = 'Mary_Had_A_Password_of_123'
# Choose a mail server (e.g. Google mail server) and call it mailserver
mailserver = "smtp.gmail.com"
port = 587
# Create socket called clientSocket and establish a TCP connection with mailserver
clientSocket = socket.socket()
clientSocket.connect(socket.getaddrinfo(mailserver, port)[0][-1])
recv = clientSocket.recv(1024)
print(recv)
print(recv[:3])
if recv[:3] != b'220':
    print('220 reply not received from server.')
# Send HELO command and print server response.
heloCommand = 'EHLO Alicern'
clientSocket.send(heloCommand.encode())
recv1 = clientSocket.recv(1024)
print(recv1)
if recv1[:3] != b'250':
    print('250 reply not received from server.')
# Request an encrypted connection
startTlsCommand = 'STARTTLSrn'
clientSocket.send(startTlsCommand.encode())
tls_recv = clientSocket.recv(1024)
print(tls_recv)
if tls_recv[:3] != b'220':
    print('220 reply not received from server')
# Encrypt the socket
#ssl_clientSocket = ssl.wrap_socket(clientSocket, ssl_version=ssl.PROTOCOL_TLSv1)
ssl_clientSocket = ssl.wrap_socket(clientSocket)
print("Secure socket created")
heloCommand = 'EHLO Alicern'
ssl_clientSocket.write(heloCommand.encode())
recv1 = ssl_clientSocket.read(1024)
print(recv1)
# Send the AUTH LOGIN command and print server response.
authCommand = 'AUTH LOGINrn'
ssl_clientSocket.write(authCommand.encode())
auth_recv = ssl_clientSocket.read(1024)
print(auth_recv)
if auth_recv[:3] != b'334':
    print('334 reply not received from server')
print("Sending username / password")
# Send username and print server response.
#uname = base64.b64encode((username).encode())
uname=b'Base64EncryptedUser=='
pword=b'Base64EncryptedPassword'
print(str(uname))
ssl_clientSocket.write(uname)
ssl_clientSocket.write('rn'.encode())
uname_recv = ssl_clientSocket.read(1024)
print(uname_recv)
if uname_recv[:3] != b'334':
    print('334 reply not received from server')
# Send password and print server response.
#pword = base64.b64encode((password).encode())
print(str(pword))
ssl_clientSocket.write(pword)
ssl_clientSocket.write('rn'.encode())
pword_recv = ssl_clientSocket.read(1024)
print(pword_recv)
if pword_recv[:3] != b'235':
    print('235 reply not received from server')
# Send MAIL FROM command and print server response.
mailFromCommand = 'MAIL FROM: <' + sender + '>rn'
ssl_clientSocket.write(mailFromCommand.encode())
recv2 = ssl_clientSocket.read(1024)
print(recv2)
if recv2[:3] != b'250':
    print('250 reply not received from server.')
# Send RCPT TO command and print server response.
rcptToCommand = 'RCPT TO: <' + recipient + '>rn'
ssl_clientSocket.write(rcptToCommand.encode())
recv3 = ssl_clientSocket.read(1024)
print(recv3)
if recv3[:3] != b'250':
    print('250 reply not received from server.')
# Send DATA command and print server response.
dataCommand = 'DATArn'
ssl_clientSocket.write(dataCommand.encode())
recv4 = ssl_clientSocket.read(1024)
print(recv4)
if recv4[:3] != b'354':
    print('354 reply not received from server.')
# Send message data.
ssl_clientSocket.write(msg.encode())
# Message ends with a single period.
ssl_clientSocket.write(endmsg.encode())
recv5 = ssl_clientSocket.read(1024)
print(recv5)
if recv5[:3] != b'250':
    print('250 reply not received from server.')
# Send QUIT command and get server response.
quitCommand = 'QUITrn'
ssl_clientSocket.write(quitCommand.encode())
recv6 = ssl_clientSocket.read(1024)
print(recv6)
if recv6[:3] != b'221':
    print('221 reply not received from server.')
clientSocket.close()

更新带有可接受的答案的代码(是的,我知道它很丑陋),读(1024)被SSL套接字替换为readline()。还需要在SSL EHLO命令之后添加一种清洁缓冲区的方法,然后添加了一个" recvCount = recv1.decode()。count(' n')",然后在第一个ehlo中,然后在ssl ehlo中的循环进行相同的计数:

    # Micropython
try:
  import usocket as socket
  #import base64
  import ussl as ssl
except:
# Python version 3
  import socket
  #import base64
  import ssl

msg = """From: XXX@gmail.com
To: XXX@gmail.com
Subject: Testing
Testing transmission thru python
"""
endmsg = "rn.rn"
recipient = "XXX@gmail.com"
sender = "XXX@gmail.com"
username = "XXX@gmail.com"
password = 'Mary_Had_A_Password_of_123'
# Choose a mail server (e.g. Google mail server) and call it mailserver
mailserver = "smtp.gmail.com"
port = 587
# Create socket called clientSocket and establish a TCP connection with mailserver
clientSocket = socket.socket()
clientSocket.connect(socket.getaddrinfo(mailserver, port)[0][-1])
recv = clientSocket.recv(1024)
print(recv)
print(recv[:3])
if recv[:3] != b'220':
    print('220 reply not received from server.')
# Send HELO command and print server response.
heloCommand = 'EHLO Alicern'
clientSocket.send(heloCommand.encode())
recv1 = clientSocket.recv(1024)
recvCount=recv1.decode().count('n')
print(recv1)
if recv1[:3] != b'250':
    print('250 reply not received from server.')
# Request an encrypted connection
startTlsCommand = 'STARTTLSrn'
clientSocket.send(startTlsCommand.encode())
tls_recv = clientSocket.recv(1024)
print(tls_recv)
if tls_recv[:3] != b'220':
    print('220 reply not received from server')
# Encrypt the socket
#ssl_clientSocket = ssl.wrap_socket(clientSocket, ssl_version=ssl.PROTOCOL_TLSv1)
ssl_clientSocket = ssl.wrap_socket(clientSocket)
print("Secure socket created")
heloCommand = 'EHLO Alicern'
ssl_clientSocket.write(heloCommand.encode())
recv1=''
for index in range(0,recvCount):
  recv1 = recv1+ssl_clientSocket.readline().decode()
print(recv1)
# Send the AUTH LOGIN command and print server response.
authCommand = 'AUTH LOGINrn'
ssl_clientSocket.write(authCommand.encode())
auth_recv = ssl_clientSocket.readline()
print(auth_recv)
if auth_recv[:3] != b'334':
    print('334 reply not received from server')
print("Sending username / password")
# Send username and print server response.
#uname = base64.b64encode((username).encode())
uname=b'Base64EncryptedUser=='
pword=b'Base64EncryptedPassword'
print(str(uname))
ssl_clientSocket.write(uname)
ssl_clientSocket.write('rn'.encode())
uname_recv = ssl_clientSocket.readline()
print(uname_recv)
if uname_recv[:3] != b'334':
    print('334 reply not received from server')
# Send password and print server response.
#pword = base64.b64encode((password).encode())
print(str(pword))
ssl_clientSocket.write(pword)
ssl_clientSocket.write('rn'.encode())
pword_recv = ssl_clientSocket.readline()
print(pword_recv)
if pword_recv[:3] != b'235':
    print('235 reply not received from server')
# Send MAIL FROM command and print server response.
mailFromCommand = 'MAIL FROM: <' + sender + '>rn'
ssl_clientSocket.write(mailFromCommand.encode())
recv2 = ssl_clientSocket.readline()
print(recv2)
if recv2[:3] != b'250':
    print('250 reply not received from server.')
# Send RCPT TO command and print server response.
rcptToCommand = 'RCPT TO: <' + recipient + '>rn'
ssl_clientSocket.write(rcptToCommand.encode())
recv3 = ssl_clientSocket.readline()
print(recv3)
if recv3[:3] != b'250':
    print('250 reply not received from server.')
# Send DATA command and print server response.
dataCommand = 'DATArn'
ssl_clientSocket.write(dataCommand.encode())
recv4 = ssl_clientSocket.readline()
print(recv4)
if recv4[:3] != b'354':
    print('354 reply not received from server.')
# Send message data.
ssl_clientSocket.write(msg.encode())
# Message ends with a single period.
ssl_clientSocket.write(endmsg.encode())
recv5 = ssl_clientSocket.readline()
print(recv5)
if recv5[:3] != b'250':
    print('250 reply not received from server.')
# Send QUIT command and get server response.
quitCommand = 'QUITrn'
ssl_clientSocket.write(quitCommand.encode())
recv6 = ssl_clientSocket.readline()
print(recv6)
if recv6[:3] != b'221':
    print('221 reply not received from server.')
clientSocket.close()

recv1 = ssl_clientocket.read(1024)

请阅读有关Micropython流语义的信息(与Python流语义相匹配,仅与一些简化相匹配):http://docs.micropython.org/en/latest/pyboard/library/uio.html?#conceptual-hierarchy

引用的语句所做的是准确要求1024个数据(Micropython遵循"缓冲流" Python语义默认情况下)。如果没有太多数据,.read()将耐心等待到足够到达(或直到发生EOF或错误发生)。

SMTP协议是面向行的,因此您需要使用.readline()

最新更新