1

我是 emqtt 的新手。我正在尝试使用 emq_auth_http 但它不起作用。

我有这 3 个请求来控制一些数据并将状态为 200 的数据发回。

app.post('/mqtt/auth', function(req, res) {
console.log('This is body ', req.body);
res.status(200).send(req.body);
});
app.post('/mqtt/superuser', function(req, res) {
console.log('This is body in superuser ', req.body);
res.status(200).send(req.body);
});
app.get('/mqtt/acl', function(req, res) {
console.log('This is params in acl ', req.params);
res.status(200).send(req.body);
});

请求在邮递员上运行良好。

我已经用 docker 在 windows 上配置了我的 emqtt。我已将配置文件放在 /etc/plugins/emq_auth_http.conf 中。

这是我的配置文件

## Variables: %u = username, %c = clientid, %a = ipaddress, %P = password, %t = topic

auth.http.auth_req = http://127.0.0.1:3000/mqtt/auth
auth.http.auth_req.method = post
auth.http.auth_req.params = clientid=%c,username=%u,password=%P

auth.http.super_req = http://127.0.0.1:3000/mqtt/superuser
auth.http.super_req.method = post
auth.http.super_req.params = clientid=%c,username=%u

## 'access' parameter: sub = 1, pub = 2
auth.http.acl_req = http://127.0.0.1:3000/mqtt/acl
auth.http.acl_req.method = get
auth.http.acl_req.params = 
access=%A,username=%u,clientid=%c,ipaddr=%a,topic=%t

然后我从仪表板启用了 emq_auth_http

现在,当我尝试将我的 mqtt 客户端连接到我的服务器时,它没有调用 api。它记录

09:28:29.642 [error] Unexpected HTTP Request: POST /mqtt/auth
09:28:29.644 [error] Client(19645050-9d1b-4c50-acf9- 
c1fe7e69eea8@172.17.0.1:60968): Username 'username' login failed for 404

有什么我错过的吗?为什么它不工作?

谢谢

4

1 回答 1

1

容器中的 127.0.0.1 是指容器本身,而不是主机。您应该设置主机 ip,您可以通过发出/sbin/ip route|awk '/default/ { print $3 }'可以在此处找到的命令从容器中获取主机 ip

ps:这样你可以得到docker机器的ip而不是主机,如果你的服务是由windows提供的,你可以从容器10.0.75.1到达主机的ip。您可以在 如何从 Windows 10 上的容器连接到 docker 主机(Docker for Windows)中找到它

于 2019-02-20T07:39:07.390 回答