如何在paho.mqtt.subscribe中设置用户名密码及实现认证？

当然可以在paho.mqtt.subscribe中使用MQTT认证功能，而且实现起来非常直接——不管你用的是subscribe.simple()还是基于底层mqtt.Client的订阅方式，都能轻松配置用户名和密码。

针对你提到的subscribe_simple.py脚本，最直接的修改方式是在调用subscribe.simple()时传入认证参数，这里有两种常用的写法：

方法1：直接传入username和password参数 #

这是最直观的方式，直接在函数调用里指定用户名和密码：

import paho.mqtt.subscribe as subscribe

# 替换为你的实际配置
target_topic = "sensor/data"
mqtt_broker = "your-broker-address.com"
broker_port = 1883
your_username = "mqtt_user"
your_password = "secure_pass123"

# 带认证的订阅调用
received_msg = subscribe.simple(
    target_topic,
    hostname=mqtt_broker,
    port=broker_port,
    username=your_username,
    password=your_password
)
print(f"收到消息：{received_msg.payload.decode('utf-8')}")

方法2：通过auth字典传入参数 #

如果需要更灵活的配置（比如后续可能扩展其他认证相关参数），可以用auth参数传递一个包含username和password的字典：

import paho.mqtt.subscribe as subscribe

# 封装认证参数
auth_config = {
    "username": "mqtt_user",
    "password": "secure_pass123"
}

# 带认证的订阅调用
received_msg = subscribe.simple(
    "sensor/data",
    hostname="your-broker-address.com",
    auth=auth_config
)

关于你之前的问题 #

你提到在循环前添加参数后问题解决，本质就是补上了MQTT Broker要求的认证信息——绝大多数私有或带权限控制的MQTT服务器都会启用用户名密码认证，缺少这些参数的话，客户端会被服务器拒绝连接，从而抛出连接失败的错误。你添加的参数正好满足了Broker的认证要求，所以问题得以解决。

额外提示：复杂场景下的底层Client用法 #

如果需要实现持续订阅、自定义消息回调等复杂逻辑，也可以直接使用paho.mqtt.client.Client类，通过username_pw_set()方法设置认证：

import paho.mqtt.client as mqtt

def on_message_callback(client, userdata, msg):
    print(f"[{msg.topic}] 收到消息：{msg.payload.decode('utf-8')}")

# 初始化客户端并设置认证
client = mqtt.Client()
client.username_pw_set("mqtt_user", "secure_pass123")
client.on_message = on_message_callback

# 连接Broker并开始订阅
client.connect("your-broker-address.com", 1883, 60)
client.subscribe("sensor/data")
client.loop_forever()

内容的提问来源于stack exchange，提问作者dubis