如何解决paho mqtt:尝试连接到代理并且无法订阅时的结果代码 5
我正在尝试订阅一个主题以检索一些数据,但它不起作用。在连接时,我被发送回结果代码 rc = 5。这个问题的根源是什么?我该怎么做才能修复它?
import paho.mqtt.client as mqtt
import json
import pub_message_pb2 as pub_message
from google.protobuf.json_format import Parse
#variables
appsKey = "CFB08A20046AB5FCE58158B38359CCF4"
appKey = "2B7E151628AED2A6ABF7158809CF4F3C"
DevAddr = "0033DABF"
MQTT_HOST = "addr"
CLIENT_ID = "centos"
BROKER_PORT = 2883
CA_CERT = "caCert.pem"
CERTFILE = "ServerCert.pem"
KEYFILE = "ServerKey.pem"
MQTT_KEEPALIVE_INTERVAL = 45
def on_log(client,userdata,level,buf):
print("log: ",buf)
def on_publish(client,mid):
print("Published...")
client = mqtt.Client(CLIENT_ID,clean_session=False,userdata=None,transport="tcp")
def on_connect(client,flags,rc):
if int(rc) == 0:
print("Succesful connection")
client.subscribe("user/3/device/8cf9572000023509/uplink")
print("Error ! Result code {}".format(rc))
def on_message(client,msg):
print(msg.payload)
client = mqtt.Client(CLIENT_ID,clean_session=True,transport="tcp")
client.tls_set(ca_certs=CA_CERT)
client.username_pw_set(username="xxx",password="xxx")
client.on_connect = on_connect # Define callback function for successful connection
client.on_message = on_message
client.connect(MQTT_HOST,BROKER_PORT,MQTT_KEEPALIVE_INTERVAL)
client.on_log = on_log
client.loop_forever()
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。