umqtt: keepalive feature doesn’t function correctly

Aperta
#909 2 commenti 1 reazione 0 assegnatari Vedi su GitHub

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà
3/5
Tempo stimato
1-2 giorni
Idoneità per principianti
48/100
Tipo di issue
Bug
Chiarezza
Abbastanza chiara
Stato di attività
Ferma
Stack tecnologico
python
Ambito
networking

Direzione di ricerca

Parti dall’implementazione di MQTTClient di umqtt.simple utilizzata dall’esempio e traccia il modo in cui viene gestito l’argomento keepalive mentre wait_msg() è bloccata. Riproduci il problema con Mosquitto o HiveMQ usando keepalive=15; il lavoro è completato quando il client invia i ping richiesti e rimane connesso oltre il timeout del broker, con una copertura di regressione per questo comportamento.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

Hi!

Here’s some example code to reproduce the issue:

import ssl
import machine
import network
from umqtt.simple import MQTTClient

client_id = machine.unique_id().hex()
mqtt_server = 'XXX.s1.eu.hivemq.cloud'
mqtt_user = 'XXX'
mqtt_password = 'XXX'
mqtt_topic_sub = b'test/topic'

wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect('XXX','XXX')

ssl_context = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)

def mqtt_connect():
    client = MQTTClient(client_id, mqtt_server, 8883, mqtt_user, mqtt_password, 15, ssl_context)
    client.connect()
    print('Connected to %s MQTT Broker'%(mqtt_server))
    return client

def reconnect():
    print('Failed to connect to the MQTT Broker. Reconnecting...')
    machine.reset()
    
def callback(topic, msg):
    print(topic, msg)

try:
    client = mqtt_connect()
    client.set_callback(callback)
    client.subscribe(mqtt_topic_sub)
except OSError as e:
    reconnect()
while True:
    client.wait_msg()

The library allows setting the keepalive to any value (default is 0, which disables it). However, when you set a keepalive value, the library does not automatically send pings to the server as expected. This causes the server to disconnect the client after 1.5 times the specified keepalive duration.

Are there any possible solutions to this?

I tested this with Mosquitto and HiveMQ serverless.

Lingua principale
Python
Stelle
2.9k
Fork
1.1k
Merge medio
7g 6h
PR unite (30g)
3

Guida per i contributori

Apri la guida per i contributori

Come iniziare

  1. Leggi tutta la issue e poi la guida ai contributi del progetto.
  2. Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
  3. Fai un fork del repository e lavora su un branch.
  4. Apri una pull request che faccia riferimento al numero della issue.

Altre issue di micropython/micropython-lib

Tutte le issue di micropython/micropython-lib

Issue simili

Altre issue su Python

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.