python 接收MQTT间隔一段时间停止问题

试了很久，发现是sleep()函数问题。我不太清楚是什么问题，就是程序运行一段时间就停止了，也不会报错，有大佬知道是为什么的可以说一下么，谢谢了。下面是我实现的MQTT订阅消息代码。

import paho.mqtt.client as mqtt
from datetime import datetime
import json
import time
import pymysql as MySQLdb

MQTTHOST = "192.168.31.67"
MQTTPORT = 1883
mqttClient1 = mqtt.Client()



# 连接MQTT服务器
def on_mqtt_connect():
    mqttClient1.connect(MQTTHOST, MQTTPORT, 60)
    mqttClient1.loop_start()

# 消息处理函数
def on_message_come(lient, userdata, msg):

    #设置接收时间间隔
    # time.sleep(1);

    print(msg.topic + ":" + str(msg.payload.decode("gbk", errors='ignore'))) 
    s = json.loads(msg.payload.decode("utf-8", errors='ignore'));


# subscribe 消息订阅
def on_subscribe():
  mqttClient1.subscribe("EGC", 0) 
  mqttClient1.subscribe("EGO", 0)
  mqttClient1.on_message = on_message_come # 消息到来处理函数

def main():
    on_mqtt_connect()
    on_subscribe()
    while True:
        pass

if __name__ == '__main__':
     main()

由于这个传感器发送了很多的数据，我需要几分钟一个信息，所以就是用了sleep函数，当我使用sleep函数时，代码会自动停止，注释掉sleep后就没有这个问题。正在尝试多线程处理MQTT接收。

反馈：多线程完美解决问题

python MQTT多线程接收与数据上传MySQL_huidong_zhu的博客-CSDN博客承接上篇博客null试了很久，发现是sleep()函数问题。我不太清楚是什么问题，就是程序运行一段时间就停止了，也不会报错，有大佬知道是为什么的可以说一下么，谢谢了。下面是我实现的MQTT订阅消息代码。import paho.mqtt.client as mqttfrom datetime import datetimeimport jsonimport timeimport pymysql as MySQLdbMQTTHOST = "192.168.31.67"MQTTPORT = 1883mqttClhhttps://blog.csdn.net/huidong_zhu/article/details/121305262