分类导航

程序问答发布时间：2022-06-01 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了我怎样才能以随机方式为每个 mqtt 客户端发布多条随机消息，而不是使用 python 客户端按顺序发布到同一个代理？，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决我怎样才能以随机方式为每个 mqtt 客户端发布多条随机消息，而不是使用 python 客户端按顺序发布到同一个代理？？

开发过程中遇到我怎样才能以随机方式为每个 mqtt 客户端发布多条随机消息，而不是使用 python 客户端按顺序发布到同一个代理？的问题如何解决？下面主要结合日常开发的经验，给出你关于我怎样才能以随机方式为每个 mqtt 客户端发布多条随机消息，而不是使用 python 客户端按顺序发布到同一个代理？的解决方法建议，希望对你解决我怎样才能以随机方式为每个 mqtt 客户端发布多条随机消息，而不是使用 python 客户端按顺序发布到同一个代理？有所启发或帮助；

这是我的python客户端代码，用于发布10个发布者的消息，我希望每个发布者不按顺序发送多条消息，例如客户端1可以发布消息然后客户端5然后客户端1可以再次发送另一条消息然后客户端9，以及以此类推。

import paho.mqtt.clIEnt as mqtt
import time
import os
import random

#variables
MQTT_HOST = "127.0.0.1"
MQTT_PORT = 1883
MQTT_KEEPAliVE_INTERVAL = 5
MQTT_topIC = "sampletopic"
MQTT_MSG = "Hello MQTT"
publishers = []
num_publishers = 10


#CallBACk Functions
def on_log(clIEnt,userdata,level,buf):
    print("log: "+buf)

def on_connect(clIEnt,flags,rC):
    if rc == 0 :
        print("connected OK"+str(clIEnt))
        mqttc.publish(MQTT_topIC,MQTT_MSG)
    else:
        print("Bad connection returned code = ",rC)

def on_disconnect(clIEnt,rc=0):
    print("disconnected result code " +str(rC))

def on_message(clIEnt,msg):
    topic = msg.topic
    m_decode = str(msg.payload.decode("utf-8","ignore"))
    print("message received",m_decodE)
       
def on_publish(clIEnt,mID):
    print("message Published...")
    time.sleep(random.randint(3,9))# sleep for 10 seconds before next call
    
for i in range(num_publishers):
    #Initiate MQTT ClIEnt
    ID = "Publisher "+str(i)
    clIEnt = mqtt.ClIEnt(ID)
    publishers.append(clIEnt)
        
try:

    for mqttc in publishers:

        #Binding CallBACk Functions
        mqttc.on_connect = on_connect
        mqttc.on_disconnect = on_disconnect
        mqttc.on_message = on_message
        mqttc.on_publish = on_publish
        # mqttc.on_log = on_log

        #connect with MQTT broker
        mqttc.connect(MQTT_HOST,MQTT_PORT,MQTT_KEEPAliVE_INTERVAL)

        #loop network
        mqttc.loop_start()
        time.sleep(0.5)

    while True:
        pass

except KeyboardInterrupt:
   print("interrupted by keyboard")

os._exit(0)