无法通过 paho-mqtt client.publish() 发送字节数组。套接字错误

Question

我正试图通过paho mqtt发送一个图像。我可以通过client.publish((发送一个简单的字符串，或者在不使用paho.client->client.publlish((的情况下，但使用publish.single((作为我的字节数组。

当尝试用client.publish((发送字节数组时，我在代理上遇到了一个套接字错误，它不会发送我的消息(No on_publish调用(。我错过了什么？

client = paho.Client()
client.on_connect = on_connect
client.on_publish = on_publish
client.connect(MQTT_BROKER, MQTT_PORT)
f = open("foo.jpg", "rb")
fileContent = f.read()
f.close()
byteArr = bytearray(fileContent)
client.publish("/data", byteArr)   # only works with strings. socket error on broker when using bytearray
# publish.single("/data", byteArr, hostname=MQTT_BROKER) # works with string and bytearray

Answer 1

如评论中所示

def on_publish(client, userdata, mid):
client.disconnect()
client.stop_loop()
client = paho.Client()
client.on_connect = on_connect
client.on_publish = on_publish
client.connect(MQTT_BROKER, MQTT_PORT)
client.loop_start()
f = open("foo.jpg", "rb")
fileContent = f.read()
f.close()
byteArr = bytearray(fileContent)
client.publish("/data", byteArr) 

client.loop_forever()不起作用的原因是，这是一个永远不会返回的阻塞调用，所以假设您在对client.publish()的调用之前插入了它，您将永远不会到达那里。