ich habe hier zwei Code-Snippets für einen Chat mit MQTT. Meine Frage ist, ob und wie man das hin bekommt, dass man die Nachrichten in dem Terminal abschicken kann, indem auch die Nachrichten ankommen, also dass ich nicht ein Extra Terminal zum Subscriben muss.
Code: Alles auswählen
#Subscribe
import paho.mqtt.client as mqtt
ip = "localhost"
topic = "chat"
user= "User"
def on_connect(client, userdata, flags, rc):
client.subscribe(topic)
def on_message(client, userdata, message):
print(str(message.payload.decode("utf-8")))
def main():
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect(ip)
client.loop_forever()
main()
#Publish
import paho.mqtt.client as mqtt
client = mqtt.Client()
client.connect("localhost")
while True:
eingabe = input("Bitte Nachricht eingeben: ")
client.publish("chat", eingabe)