我有一个小的Python服务器,我可以POST命令来控制我的LIFX灯。从邮递员我可以尽可能多地发送垃圾邮件并且永远不会看到错误,但我想要做的是构建几个使用NodeMCU板触发灯的墙壁开关,从那里,我收到了ECONNABORTED错误大约五分之一的请求。
在我寻找解决方案的任何地方,问题实际上是一个配置错误的服务器或配置错误的客户端,但我想知道我是否还有其他事情在这里发生。我的服务器代码很简单,而且,正如我所说,除了我的NodeMCU板之外,它似乎可以在任何地方触发。
卖弄.朋友:
from machine import Pin, reset
from time import sleep
import urequests
# set these two pins as required to up/down
buttonUp = Pin(4, Pin.IN, Pin.PULL_UP)
buttonDown = Pin(5, Pin.IN, Pin.PULL_UP)
light = "LightName"
# button can be pressed, held or double pressed
# press = 1x press, 1x release in .5 seconds
# hold = 1x press, 0x release
# double = 2x press, 2x release in .5 seconds
def detectPress():
pressed = False
press = 0
direction = 'up'
release = 0
if not buttonUp.value() or not buttonDown.value:
pressed = True
if not buttonDown.value():
direction = 'down'
while buttonUp.value() and buttonDown.value():
sleep(.01) # wait for a button push
for x in range(8):
if pressed == False:
if not buttonUp.value():
direction = 'up'
pressed = True
press += 1
if not buttonDown.value():
direction = 'down'
pressed = True
press += 1
else:
if direction == 'up':
if buttonUp.value():
pressed = False
release += 1
else:
if buttonDown.value():
pressed = False
release += 1
sleep(.1)
return press, release, direction
error_count = 0
while True:
if error_count >= 5:
print ("Too many errors. Resetting...")
reset()
pressed, released, direction = detectPress()
sleep_time = .1
if pressed >= released:
packet = {"light": light}
if pressed == released:
if pressed == 0:
held = True
else:
held = False
else:
held = True
if pressed > 1:
double = True
else:
double = False
if double is True:
packet["level"] = "full"
if held is True and double is False:
packet["dim"] = direction
sleep_time = 0.8 # don't spam the server/crash the board
if held is False and double is False:
if direction == 'up':
packet["level"] = 'on'
else:
packet["level"] = 'off'
print (pressed, released, direction, held, double, packet)
try:
response = urequests.post("http://192.168.1.10:7990/lights", headers={'Connection': 'Close'}, json = packet)
if error_count > 0:
error_count -= 1
urequests.usocket.reset()
except Exception as e:
error_count += 1
print ("Error sending packet {}: {} - error count is at {} retrying...".format(packet, repr(e), error_count))
urequests.usocket.reset()
sleep(1)
try:
response = urequests.post("http://192.168.1.10:7990/lights", headers={'connection': 'Close'}, json = packet)
except Exception as e:
error_count += 1
print ("retry failed")
pass
pass
print ("waiting {}".format(sleep_time))
sleep(sleep_time)
我怀疑这是一个套接字问题,但不知道还有什么可以调试它。
在重新设置时,我几乎可以保证前4或5次传输都能正常工作。我还可以保证按住一个按钮(每隔一秒触发一次命令)将在3或4次传输后失败。
有时重试工作,更常见的是他们没有。
失败后的大部分时间,等待5秒然后再次尝试将起作用,但有时它不会。
大多数情况下,经过长时间延迟(> 1分钟)后的初始按压将起作用,但有时则不会。
好的,垃圾收集解决了它。现在我可以按下按钮,它每次都有效!我可以调整延迟以尽可能紧。如果忙碌而不仅仅是粗暴的延迟,查询输入会很好,但是嘿......
这是发出请求的my循环:
gc.enable()
while True:
time.sleep_ms(250)
if (btn1.value() == 0):
urequests.post(url, data=json.dumps(data_play))
time.sleep_ms(650)
while (btn1.value() == 0):
time.sleep_ms(200)
pass
gc.collect()
在尝试了解决这个问题的所有内容之后,我得出结论,问题是ESP8266无法处理来自服务器的初始握手。我认为它可能无法管理网络上的流量,因此它会占用。在服务器上运行wireshark当我收到失败的响应时,我看到几个TCP Spurious Retransmission
s。
我订购了ESP32板,应该让我测试一下我的理论。
编辑:我终于解决了问题是,请求在整个地方打开套接字。因此,我们需要正确关闭响应:
response = urequests.post(url, ...)
...
response.close()
这解决了我的问题,虽然我无法解释的是为什么套接字没有在帖子的末尾关闭,这似乎是库的功能。