MQTT auf ubuntu System

[Linux (Gast)]

Guten Morgen,

auf einem ubuntu System habe ich einen MQTT Broker am Laufen. Nun soll 
via python Skript mit einem MQTT Client auf dem ubuntu System eine 
Nachricht veröffentlicht werden. Sobald die folgende Zeile ausgeführt 
wird

 client.connect(BROKER_ADDRESS, 1883, 60)

erscheint die Fehlermeldung:

File "PythonSkriptTest.py", line 36, in <module>
    client.connect(BROKER_ADDRESS, 1883, 60)
  File "/usr/local/lib/python3.8/dist-packages/paho/mqtt/client.py", line 941, in connect
    return self.reconnect()
  File "/usr/local/lib/python3.8/dist-packages/paho/mqtt/client.py", line 1075, in reconnect
    sock = self._create_socket_connection()
  File "/usr/local/lib/python3.8/dist-packages/paho/mqtt/client.py", line 3546, in _create_socket_connection
    return socket.create_connection(addr, source_address=source, timeout=self._keepalive)
  File "/usr/lib/python3.8/socket.py", line 808, in create_connection
    raise err
  File "/usr/lib/python3.8/socket.py", line 796, in create_connection
    sock.connect(sa)
ConnectionRefusedError: [Errno 111] Connection refused

Weiß jemand wo da das Problem liegen könnte?

Auf einem raspberry pi funktioniert dieses Skript.

[Eric (Gast)]

Vielleicht wäre es sinnvoll, die entsprechenden Skripte zu 
veröffentlichen. Wie soll man es sonst beurteilen können, wenn man sich 
die Zeilen nicht angucken kann.

[Joachim (Gast)]

Linux schrieb:
> Weiß jemand wo da das Problem liegen könnte?

Da Du lediglich eine einzige Programmzeile gepostet hast, kann man 
eigentlich nur in's Blaue raten.

Und mein Rateversuch wäre:
"BROKER_ADDRESS" ist "127.0.0.1" oder "localhost" oder so.

[Eric (Gast)]

Erste Vermutung: Auf dem Pi läuft eine andere Python Version oder auf 
dem Ubuntu System sind Module nicht installiert. Also erstmal die 
Version überprüfen, dann dein Skript veröffentlichen.

[Linux (Gast)]

Wenn ich die IP Adresse "127.0.0.1" dann wird mein Skript nicht mit 
einer Fehlermeldung abgebrochen. Wenn ich nun von einem anderen Rechner 
subscribe und publish ausführen will, welche IP Adresse müsste ich da 
verwenden? Ist es die Adresse "127.0.0.1"?

[Johannes S. (Gast)]

Linux schrieb:
> ConnectionRefusedError: [Errno 111] Connection refused

Da lauscht keiner auf IP:Port, die BROKER_ADDRESS scheint falsch zu 
sein.

[Eric (Gast)]

Natürlich die von deinem MQTT Broker!

[Linux (Gast)]

Ok eines habe ich vergessen mit zu teilen.

Auf dem pi verwende ich den Aufruf: sudo python PythonSkriptTest.py
Auf dem ubuntu System: sudo python3 PythonSkriptTest.py

[Linux (Gast)]

Die BROKER Adresse ist richtig

[Tux (Gast)]

> ConnectionRefusedError: [Errno 111] Connection refused

Dein MQTT-Broker nimmt die Anfrage von

client.connect(BROKER_ADDRESS, 1883, 60)

nicht an.

Wie ist BROKER_ADDRESS definiert? Und lauscht dann Dein MQTT-Broker auf 
dieser Adresse?

[Andreas B. (bitverdreher)]

Linux schrieb:
> Ok eines habe ich vergessen mit zu teilen.
Du hast noch mehr vergessen:

Eric schrieb:
> Vielleicht wäre es sinnvoll, die entsprechenden Skripte zu
> veröffentlichen.

[Michael H. (mha1)]

Connection Refused -> kein MQTT Broker hat sich auf der angegebenen 
Adresse registiert (IP-Adresse und Port). Läuft der Broker überhaupt ?

Auf dem Raspberry und Ubuntu eventuell laufen unterschiedliche Versionen 
eines MQTT Brokers (z.B mosquitto ?) oder die Konfigurationsdateien sind 
unterschiedlich eingestellt. Die Pakete auf dem Rapsberry sind eventuell 
auch für die häufigsten Anwendungsfälle vorkonfiguriert (auf Ubuntu eher 
nicht).

Bei Mosquitto haben sich zwischen den 1.x und 2.x Versionen die 
Defaultwerte für die Listener geändert. Das muss eventuell manuell 
angepasst werden.

[Eric (Gast)]

Linux schrieb:
> Auf dem pi verwende ich den Aufruf: sudo python PythonSkriptTest.py
> Auf dem ubuntu System: sudo python3 PythonSkriptTest.py

Ich habe dir doch bereits gesagt, Du sollst die jeweilige Python Version 
nennen:

python --version

[Rolf M. (rmagnus)]

Linux schrieb:
> ConnectionRefusedError: [Errno 111] Connection refused

Das heißt, dass der Broker unter BROKER_ADDRESS (was immer da dahinter 
stehen mag) und Port 1883 nicht erreichbar ist.

[rµ (Gast)]

Linux schrieb:
> Ok eines habe ich vergessen mit zu teilen.
>
> Auf dem pi verwende ich den Aufruf: sudo python PythonSkriptTest.py
> Auf dem ubuntu System: sudo python3 PythonSkriptTest.py

Das sudo sollte man sich in dem Fall dringend abgewöhnen.

Falls MQTT Broker nicht am selber Rechner läuft: Nachsehen auf welcher 
Adresse der MQTT Broker hört. 127.0.0.1 ist die Adresse des "Loopback 
Interfaces", die ist von aussen nicht erreichbar. Standard-Praxis unter 
linux ist, dass solche Server-Prozesse ohne Änderung der Konfiguration 
von aussen nicht erreichbar sind, das hat (auch) Sicherheitsgründe.

[Johannes S. (Gast)]

Firewall aktiv?
Was meldet netstat, ist ein process listening auf 1883?

Was soll die Python Version mit der Fehlermeldung zu tun haben, die sagt 
was schon geschrieben wurde.

[Tam H. (Firma: Tamoggemon Holding k.s.) (tamhanna)]

Denke es ist die neue Version von Mosquitto. Die lehnt Anfragen, die 
nicht von Localhost kommen, von Haus aus ab.

Du musst die Konfiguration anpassen. Weiss jetzt aber auf die Schnelle 
nicht mehr genau, was. Kann es dir aber iwann raussuchen.

[Eric (Gast)]

Johannes S. schrieb:
> Was soll die Python Version mit der Fehlermeldung zu tun haben, die sagt
> was schon geschrieben wurde.

Da der TO uns ja nicht verrät ob er per TCP oder über die sockets.py 
kommunizieren will, darf man unterschiede in der entsprechenden 
sockets.py vermuten.
Ausserdem wissen wir nicht, wie und wo der Broker läuft. In einem Docker 
Container wäre localhost zum Beispiel nicht das lo.

Mit dem derzeitigen Informationen ist eine Hilfestellung schwer zu 
leisten.

[Linux (Gast)]

Hallo Tam H., das vermute ich auch, dass die Anfragen die nicht von 
localhost kommen abgelehnt werden.

Abgespeckte Skript:

import socket
import sys
import ipaddress
import re
import time
import paho.mqtt.client as mqtt
from random import *
from datetime import datetime

SRC_PORT = 4001
DST_PORT = 4000

BROKER_ADDRESS = raw_input("Enter IP address: ")
TOPIC = raw_input("Enter topic: ")

def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))

client = mqtt.Client()
client.on_connect = on_connect

client.connect(BROKER_ADDRESS, 1883, 60)

client.loop_start()

[Linux (Gast)]

Das muss doch unter ubuntu laufen.

[Eric (Gast)]

Linux schrieb:
> Abgespeckte Skript:

Ja, das erkennt man...
Wie gesagt, Du machst Dir keine Mühe, notwendige Infos zur Verfügung zu 
stellen.
BM? Container? Python Version? Absolut nichts.
Ehrlich gesagt habe ich da auch keine grosse Lust mehr, dir zu helfen. 
Sorry.

[Joachim (Gast)]

Linux schrieb:
> Hallo Tam H., das vermute ich auch, dass die Anfragen die nicht von
> localhost kommen abgelehnt werden.

Ich gehe mittlerweile davon aus, dass Tam H. tatsächlich voll in's 
Schwarze getroffen haben mit seiner Vermutung, was die Ursache des 
Problems ist.
Nämlich, dass der MQTT-Broker "mosquitto" ist, auf dem Raspberry Pi 
selbst läuft - und nur über das loopback-Interface zu erreichen ist, 
weil es eine aktuelle Version von mosquitto >= 2.0.0 ist und Du die 
Default-Konfiguration nicht geändert hast.

Und er hat auch bereits klar gesagt, was Du in diesem Fall tun musst, um 
das Problem zu beheben: Die mosquitto-Konfigurationsdatei eben 
dahingehend ändern, dass mosquitto nicht nur auf dem loopback-Interface 
horcht.

Ich zitiere mal das mosquitto-Changelog:

Breaking changes:
- When the Mosquitto broker is run without configuring any listeners it will
  now bind to the loopback interfaces 127.0.0.1 and/or ::1. This means that
  only connections from the local host will be possible.

  Running the broker as `mosquitto` or `mosquitto -p 1883` will bind to the
  loopback interface.

  Running the broker with a configuration file with no listeners configured
  will bind to the loopback interface with port 1883.

  Running the broker with a listener defined will bind by default to `0.0.0.0`
  / `::` and so will be accessible from any interface. It is still possible to
  bind to a specific address/interface.

  If the broker is run as `mosquitto -c mosquitto.conf -p 1884`, and a
  listener is defined in the configuration file, then the port defined on the
  command line will be IGNORED, and no listener configured for it.
- All listeners now default to `allow_anonymous false` unless explicitly set
  to true in the configuration file. This means that when configuring a
  listener the user must either configure an authentication and access control
  method, or set `allow_anonymous true`. When the broker is run without a
  configured listener, and so binds to the loopback interface, anonymous
  connections are allowed.

Hättest Du von Anfang an ein paar mehr Informationen herausgerückt, 
statt uns in bester Salami-Taktik immer nur minimale unvollständige 
Informations-Häppchen hinzuwerfen, hätte man Dir schneller helfen 
können.

[Linux (Gast)]

Danke für die Info. Aber das bringt mich nun nicht wesentlich weiter.

[Linux (Gast)]

mosquitto.conf:

# Place your local configuration in /etc/mosquitto/conf.d/
#
# A full description of the configuration file is at
# /usr/share/doc/mosquitto/examples/mosquitto.conf.example

persistence true
persistence_location /var/lib/mosquitto/

log_dest file /var/log/mosquitto/mosquitto.log

include_dir /etc/mosquitto/conf.d

[Linux (Gast)]

Ich habe nun mal in der mosquitto.conf Datei den EIntrag hinzugefügt:

listener 1883 xxx.xxx.xxx.xxx

(xxx.xxx.xxx.xxx = IP-Adresse Broker)

Das Programm stützt schonmal nicht mehr ab.

[Rolf M. (rmagnus)]

Linux schrieb:
> include_dir /etc/mosquitto/conf.d

Und, was findet sich dort?

Linux schrieb:
> Ich habe nun mal in der mosquitto.conf Datei den EIntrag hinzugefügt:

Also entgegen dieser Empfehlung:

Linux schrieb:
> # Place your local configuration in /etc/mosquitto/conf.d/

[Linux (Gast)]

So wie es nun aussieht gibt es wohl noch ein weiteres Problem. Das 
ubuntu System kann keine udp Pakete empfangen. Auch ein Mqtt Connect zu 
dem Broker funktioniert von außen nicht.

[Udo (Gast)]

mosquitto.conf:

listener 1883
allow_anonymous true

half bei mir als Anfang des Jahres kein Client mehr connecten konnte.

[Linux (Gast)]

Mqtt funktioniert nun.

[Udo (Gast)]

Was war das Problem, bzw. die Lösung?

[Tam H. (Firma: Tamoggemon Holding k.s.) (tamhanna)]

Udo schrieb:
> mosquitto.conf:
>
> listener 1883
> allow_anonymous true
>
> half bei mir als Anfang des Jahres kein Client mehr connecten konnte.

Wegen der Umstellung von 1 auf 2

[Linux (Gast)]

Guten Morgen,

folgende Zeilen habe ich in der conf Datei hinzugefügt:

listener 1883
allow_anonymous true