调用作为MQTT发布者的Serverless函数时遇连接拒绝问题求助

问题根源：faasD的Serverless函数运行在独立容器环境中，容器内的localhost指向容器自身，而非树莓派宿主机。本地测试正常是因为发布者和订阅者都处于宿主机的网络环境下，而函数容器无法通过localhost访问宿主机上的MQTT Broker，因此触发连接拒绝错误。

1. 修正函数中的MQTT Broker地址 #

将handler.py里的localhost替换为树莓派宿主机的局域网IP（可通过在树莓派终端执行hostname -I查看），确保容器能定位到宿主机上的Broker。同时优化代码，添加消息发送的同步处理，避免异步导致的消息丢失：

import paho.mqtt.client as mqtt

# 替换为树莓派宿主机的实际局域网IP，例如192.168.1.100
BROKER = '192.168.1.100'
PORT = 1883
TOPIC = 'topic'

def handle(req):
    """handle a request to the function
    Args:
        req (str): request body
    """
    
    client = mqtt.Client()
    try:
        client.connect(BROKER, PORT, 60)
        # 启动循环确保消息发送完成
        client.loop_start()
        client.publish(TOPIC, req)
        client.loop_stop()
        return f'Message published to topic {TOPIC}'
    except Exception as e:
        return f'Connection failed: {str(e)}'

2. 配置MQTT Broker监听所有网络接口 #

默认情况下，多数MQTT Broker（如Mosquitto）仅绑定127.0.0.1，容器无法访问。需修改Broker配置，使其监听所有网络接口：

• 打开Mosquitto配置文件（通常路径为/etc/mosquitto/mosquitto.conf）
• 找到listener配置项，修改为：

  listener 1883 0.0.0.0
  

• 重启MQTT服务生效：

  sudo systemctl restart mosquitto
  

3. 验证容器与宿主机的网络连通性 #

可通过faas-cli进入函数容器，测试是否能连通宿主机IP和MQTT端口：

# 替换<your-function-name>为你的函数名称
faas-cli exec <your-function-name> -- ping 192.168.1.100
faas-cli exec <your-function-name> -- telnet 192.168.1.100 1883

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