1883 - Pentesting MQTT (Mosquitto)

从零开始学习AWS黑客技术，成为专家 htARTE（HackTricks AWS Red Team Expert）！

支持HackTricks的其他方式：

如果您想看到您的公司在HackTricks中做广告或下载PDF格式的HackTricks，请查看订阅计划!
获取官方PEASS & HackTricks周边产品
发现PEASS家族，我们的独家NFTs
加入 💬 Discord群组 或 电报群组 或关注我们的Twitter 🐦 @carlospolopm。
通过向HackTricks和HackTricks Cloud github仓库提交PR来分享您的黑客技巧。

WhiteIntel

WhiteIntel 是一个由暗网支持的搜索引擎，提供免费功能，用于检查公司或其客户是否受到窃取恶意软件的侵害。

WhiteIntel的主要目标是打击由窃取信息的恶意软件导致的账户劫持和勒索软件攻击。

您可以访问他们的网站并免费尝试他们的引擎：

WhiteIntel

基本信息

MQ Telemetry Transport (MQTT) 被称为一种发布/订阅消息传递协议，以其极端简单和轻量性著称。该协议专门为设备能力有限、在低带宽、高延迟或不稳定连接的网络上运行的环境而设计。MQTT的核心目标包括最小化网络带宽的使用量和减少对设备资源的需求。此外，它旨在保持可靠的通信并提供一定程度的传递保证。这些目标使MQTT非常适用于蓬勃发展的机器对机器（M2M）通信和**物联网（IoT）**领域，在这些领域中，高效连接大量设备至关重要。此外，MQTT对于移动应用程序也非常有益，其中节省带宽和电池寿命至关重要。

默认端口： 1883

PORT     STATE SERVICE                 REASON
1883/tcp open  mosquitto version 1.4.8 syn-ack

检查流量

当 MQTT 代理接收到 CONNECT 数据包时，会发送回一个 CONNACK 数据包。该数据包包含一个返回码，对于理解连接状态至关重要。返回码 0x00 表示凭据已被接受，表明连接成功。另一方面，返回码 0x05 表示凭据无效，从而阻止连接。

例如，如果代理因凭据无效而拒绝连接，场景将如下所示：

{
"returnCode": "0x05",
"description": "Connection Refused, not authorized"
}

暴力破解 MQTT

MQTT 渗透测试

身份验证完全是可选的，即使正在执行身份验证，默认情况下不使用加密（凭据以明文形式发送）。仍然可以执行中间人攻击来窃取密码。

要连接到 MQTT 服务，可以使用：https://github.com/bapowell/python-mqtt-client-shell 并订阅所有主题：

> connect (NOTICE that you need to indicate before this the params of the connection, by default 127.0.0.1:1883)
> subscribe "#" 1
> subscribe "$SYS/#"

你也可以使用https://github.com/akamai-threat-research/mqtt-pwn

你也可以使用：

apt-get install mosquitto mosquitto-clients
mosquitto_sub -t 'test/topic' -v #Subscribe to 'test/topic'
mosquitto_sub -h <host-ip> -t "#" -v #Subscribe to ALL topics.

或者你可以运行这段代码尝试连接到一个没有身份验证的MQTT服务，订阅每个主题并监听它们：

#This is a modified version of https://github.com/Warflop/IOT-MQTT-Exploit/blob/master/mqtt.py
import paho.mqtt.client as mqtt
import time
import os

HOST = "127.0.0.1"
PORT = 1883

def on_connect(client, userdata, flags, rc):
client.subscribe('#', qos=1)
client.subscribe('$SYS/#')

def on_message(client, userdata, message):
print('Topic: %s | QOS: %s  | Message: %s' % (message.topic, message.qos, message.payload))

def main():
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect(HOST, PORT)
client.loop_start()
#time.sleep(10)
#client.loop_stop()

if __name__ == "__main__":
main()