
Rust-CLI für MQTT-Penetrationstests: Subscribe/Publish, Broker-Fingerprinting, ACL-Probing, Topic-Enumeration, Credential-Brute-Force und Last-Will-Injection über TLS/mTLS.
Ein Rust-basiertes MQTT-Penetrationstest-Tool für die Kommandozeile.
$ nix-shell
$ cargo build --release
Die Binärdatei befindet sich unter target/release/mqattack.
Erfordert Rust 1.80+, einen C-Compiler und OpenSSL-Entwicklungs-Header.
$ cargo build --release
Für Nix- oder NixOS-Nutzer ist ein Paket verfügbar. Beachten Sie, dass die neuesten Releases möglicherweise nur
im unstable-Kanal vorhanden sind.
$ nix-env -iA nixos.mqattack
Alle Befehle teilen einen gemeinsamen Satz von Verbindungs- und Authentifizierungsoptionen:
Connection options:
-H, --host <HOST> Broker hostname or IP [default: localhost]
-p, --port <PORT> Broker port [default: 1883]
-u, --username <USER> Username
-P, --password <PASS> Password (mutually exclusive with --jwt)
--jwt <TOKEN> JWT token sent as MQTT password
--client-id <ID> MQTT client identifier [default: mqattack]
--keepalive <SECS> Keep-alive interval [default: 60]
TLS options:
--tls Enable TLS with system root CAs
--cafile <PATH> Custom CA certificate in PEM format (implies --tls)
--cert <PATH> Client certificate for mTLS in PEM format (requires --key)
--key <PATH> Client private key for mTLS in PEM format (requires --cert)
--insecure Disable certificate verification — for testing only
$ mqattack subscribe [OPTIONS] -t <TOPIC>...
-t, --topic <TOPIC> Topic filter, repeatable
-q, --qos <QOS> QoS level 0/1/2 [default: 0]
-C, --count <N> Exit after N messages
--hex Print payload as hexadecimal
# Subscribe to all topics
$ mqattack subscribe -t '#'
# Subscribe to multiple filters, exit after 5 messages
$ mqattack subscribe -t 'home/#' -t 'sensors/#' -C 5
# Plaintext with credentials
$ mqattack subscribe -H 192.168.1.10 -u admin -P secret -t '#'
# TLS using system root CAs (default port 8883)
$ mqattack subscribe --tls -H broker.example.com -p 8883 -t '#'
# TLS with a custom CA
$ mqattack subscribe --cafile ca.crt -H broker.example.com -p 8883 -t '#'
# mTLS with client certificate
$ mqattack subscribe --cert client.crt --key client.key --cafile ca.crt \
-H broker.example.com -p 8883 -t '#'
# JWT authentication over TLS
$ mqattack subscribe --tls --jwt 'eyJhbGci...' -H broker.example.com -p 8883 -t '#'
# Self-signed cert — skip verification
$ mqattack subscribe --insecure -H 192.168.1.10 -p 8883 -t '#'
# Collect for 5 seconds, print a grouped summary
$ mqattack sys-info -H 192.168.1.10
# Longer collection window
$ mqattack sys-info -H broker.example.com --tls -p 8883 -w 15
# Stream values live
$ mqattack sys-info -H 192.168.1.10 --live
$ mqattack publish [OPTIONS] -t <TOPIC> -m <MESSAGE>
-t, --topic <TOPIC> Target topic
-m, --message <MSG> Payload; use '-' to read from stdin
-q, --qos <QOS> QoS level 0/1/2 [default: 0]
-r, --retain Set the retain flag
# Publish a simple message
$ mqattack publish -t test/topic -m 'hello'
# Publish with QoS 1 and retain flag
$ mqattack publish -H 192.168.1.10 -t alerts/door -m 'open' -q 1 -r
# Pipe payload from stdin
$ echo '{"cmd":"reboot"}' | mqattack publish -t device/1/cmd -m -
# Publish over TLS with JWT
$ mqattack publish --tls --jwt 'eyJhbGci...' \
-H broker.example.com -p 8883 -t device/1/cmd -m 'reboot'
# mTLS publish
$ mqattack publish --cert client.crt --key client.key --cafile ca.crt \
-H broker.example.com -p 8883 -t test -m 'hello'
Identifizieren Sie die Broker-Software und -Version, indem Sie $SYS/# abonnieren und
die gesammelten Nachrichten analysieren. Es werden keine Pakete über ein standardmäßiges SUBSCRIBE hinaus
gesendet – der Broker gibt sich durch das preis, was er veröffentlicht.
Erkannte Broker und ihre Erkennungssignale:
| Broker | Erkennungssignal |
|---|---|
| Mosquitto | $SYS/broker/version-Wert beginnt mit mosquitto version |
| HiveMQ | $SYS/broker/version-Wert beginnt mit HiveMQ |
| VerneMQ | $SYS/broker/version-Wert beginnt mit VerneMQ |
| EMQX | Topics unter $SYS/brokers/ (Plural); Knotenname aus dem Topic-Pfad extrahiert |
| NanoMQ | Topics unter dem $SYS/nanomq/-Namespace |
| RabbitMQ | $SYS/broker/version-Wert enthält rabbitmq |
Die Konfidenz wird als high gemeldet, wenn eine bekannte Signatur übereinstimmt, als low, wenn
$SYS/broker/version vorhanden, aber nicht erkannt wird, und als unknown, wenn $SYS
zugänglich ist, aber keine identifizierenden Informationen liefert.
$ mqattack fingerprint [OPTIONS]
-w, --wait <SECS> Collection window in seconds [default: 5]
--verbose Print all collected $SYS messages after the summary
Beispiele
# Fingerprint a broker on the default port
$ mqattack fingerprint -H 192.168.1.10
# Longer collection window for slow brokers, then dump everything
$ mqattack fingerprint -H 192.168.1.10 -w 10 --verbose
# Fingerprint over TLS with credentials
$ mqattack fingerprint --cafile ca.crt -H broker.example.com -p 8883 \
-u admin -P secret
Beispielausgabe (Mosquitto):
[+] Broker Fingerprint
Software: Mosquitto
Version: 2.0.18
Confidence: high
Build info: With OpenSSL 3.0.2 15 Mar 2022
Uptime: 12345 seconds
Clients connected: 3
Clients total: 47
Messages received: 1082
Messages sent: 2341
[*] 47 $SYS message(s) collected (use --verbose to see all)
Prüfen Sie Subscribe- und/oder Publish-Berechtigungen für ein Topic oder eine Liste von Topics.
Jeder Test verbindet sich neu mit dem Broker und inspiziert die zurückgegebene SubAck/PubAck.
Ergebnisse werden als ALLOWED, DENIED, INCONCLUSIVE (keine Bestätigung
erhalten) oder SKIPPED gemeldet.
Hinweis: Publish-Probes erfordern QoS 1 oder 2 (
-q 1oder-q 2), um eine Broker-Bestätigung zu erhalten. QoS 0 liefert für Publish immerINCONCLUSIVE.
$ mqattack check-acl [OPTIONS] (-t <TOPIC> | -w <FILE>)
-t, --topic <TOPIC> Single topic to probe (mutually exclusive with --wordlist)
-w, --wordlist <FILE> File with one topic per line (mutually exclusive with --topic)
--no-subscribe Skip subscribe permission tests
--no-publish Skip publish permission tests
--payload <TEXT> Payload used for publish probes [default: mqattack]
-q, --qos <QOS> QoS for publish probes (1 or 2) [default: 1]
--wait <SECS> Seconds to wait for a broker response per test [default: 5]
# Test a single topic (both subscribe and publish)
$ mqattack check-acl -H 192.168.1.10 -u admin -P secret -t 'home/lights/1'
# Test all topics from a wordlist, subscribe only
$ mqattack check-acl -H 192.168.1.10 -w topics.txt --no-publish
# Test publish permissions only with QoS 2
$ mqattack check-acl -H 192.168.1.10 -t 'cmd/device/1' --no-subscribe -q 2