在 Nodejs 上使用 DNS 发现 Consul 服务

Question

TL; 博士

大家好，我正在尝试通过Consul DNS 接口从用 Express 编写的 nodejs 前端调用 nodejs 后端微服务，但出现错误。

我正在使用nodejs dns api为唯一节点应用程序设置 dns，以便对本地 Consul DNS 接口进行后续 dns.resolve() 调用。

目标

我希望能够向我的后端服务发出 http 请求，而无需在我的客户端代码中连接其 IP 和端口。我也不想编写自定义代码来查询 Consul HTTP API，以便在我需要调用它时为我的服务获取 ip:port 对。

问题

问题是，当我使用axios（类似于request）对后端服务进行 HTTP 调用时，我总是收到错误消息，因为它无法解析地址。Axios 似乎没有使用我之前设置的 dns：

dns.setServers(['127.0.0.1:8600']);

更新_1

使用 consul 的 -recursor 命令行选项将虚拟机 (/etc/resolv.conf) 的 dns 设置为 localhost e，使用默认 dns 一切正常！我仍然想了解我在仅在我的 nodejs 应用程序上设置 dns 时做错了什么。

设置

• 1 个带有 nodejs 进程的 FE 节点，运行带有 Expressjs 的简单网络服务器。在 app.get('/') 路由中，它通过 consul 和 axios（如请求）对名为 be01 的后端服务进行 REST POST 调用。
• 2 带有 nodejs 进程的 BE 节点运行一个简单的 web 服务器，Expressjs 公开 REST api。
• 1 个 Consul 节点，Consul 作为服务器运行。
• 每个节点都有自己的 consul 代理运行并加入集群。
• TCP端口正确打开

这是服务器：

这是来自领事 UI：

在 FE 节点上运行 consul 成员我得到：

agent-server  10.0.1.7:8301  alive   server  1.0.1  2         dc1  <all>
agent-be-01   10.0.1.5:8301  alive   client  1.0.1  2         dc1  <default>
agent-be-02   10.0.1.6:8301  alive   client  1.0.1  2         dc1  <default>
agent-fe      10.0.1.4:8301  alive   client  1.0.1  2         dc1  <default>

如果我在 FE 节点上运行dig @localhost -p 8600 be01.service.consul SRV，我会正确地得到这个结果（如 Consul 文档中所示）：

root@NGINXLB:~/node8080$ dig @localhost -p 8600 be01.service.consul SRV

; <<>> DiG 9.9.5-3ubuntu0.16-Ubuntu <<>> @localhost -p 8600 be01.service.consul SRV
; (1 server found)
;; global options: +cmd
;; Got answer:
;; ->>HEADER<<- opcode: QUERY, status: NOERROR, id: 43367
;; flags: qr aa rd; QUERY: 1, ANSWER: 2, AUTHORITY: 0, ADDITIONAL: 5
;; WARNING: recursion requested but not available

;; OPT PSEUDOSECTION:
; EDNS: version: 0, flags:; udp: 4096
;; QUESTION SECTION:
;be01.service.consul.       IN  SRV

;; ANSWER SECTION:
be01.service.consul.    0   IN  SRV 1 1 8081 agent-be-02.node.dc1.consul.
be01.service.consul.    0   IN  SRV 1 1 8080 agent-be-01.node.dc1.consul.

;; ADDITIONAL SECTION:
agent-be-02.node.dc1.consul. 0  IN  A   10.0.1.6
agent-be-02.node.dc1.consul. 0  IN  TXT "consul-network-segment="
agent-be-01.node.dc1.consul. 0  IN  A   10.0.1.5
agent-be-01.node.dc1.consul. 0  IN  TXT "consul-network-segment="

;; Query time: 2 msec
;; SERVER: 127.0.0.1#8600(127.0.0.1)
;; WHEN: Fri Dec 01 10:09:00 UTC 2017
;; MSG SIZE  rcvd: 246

这是 BE 服务代码：

var express = require('express');
var bodyParser = require('body-parser');
var app = express();
var jsonParser = bodyParser.json()
var urlencodedParser = bodyParser.urlencoded({ extended: false })

app.post('/api/getUserTiles', jsonParser, function (req, res) {
  console.log("> API request for '/api/getUserTiles'");
  if (!req.body) { return res.sendStatus(400) }
  else {
    var user = req.body.user;
    console.log("User: " + user);
    res.json({
      "authorizedTiles": [
        {"tileID": "profile"}
        ,{"tileID": "search"}
        ,{"tileID": "test"}
      ],
      "email": "max@google.com",
      "userName":"Max",
      "has_error": false,
      "error_message": ""
    });
  }
});

var server = app.listen(8080, function () {
  var host = server.address().address
  var port = server.address().port
  console.log("Example app listening at http://%s:%s", host, port)
})

使用它的 ip:port 和 curl 从 FE 调用它没有问题：

root@NGINXLB:~/node8080$ curl -d="user=Max" -X POST http://10.0.1.5:8080/api/getUserTiles
{"authorizedTiles":[{"tileID":"profile"},{"tileID":"search"},{"tileID":"test"}],"email":"max@google.com","userName":"Max","has_error":false,"error_message":""}

简化的 FE 节点上的 Web 服务是这样的：

var axios = require('axios');
var dns = require('dns');
var consul = require('consul')();

dns.setServers(['127.0.0.1:8600']);
//console.log(dns.getServers());

dns.resolveSrv("be01.service.consul", function(err, records){
        console.log("\nDNS SRV query");
        if(err){
                console.log(err);
        }else{
                console.log(records);
        }
});

consul.health.service({
        "service": "be01",
        "dc": "dc1",
        "passing": true
        }, function(err, result){
                console.log("\nConsul.health.service query:");
                if(err){console.log(err); throw err;}
                else if(result.length > 0){
                        for(var i=0; i<result.length; i++){
                                console.log(result[i].Node.Address + ":" + result[i].Service.Port);
                        }
                }
});

axios.post("http://be01.service.consul/api/getUserTiles", {'user':'Max'})
  .then(function(response){
      if (response.data.has_error) {
       console.log("\nRESPONSE HAS ERROR!");
      }else {
        console.log("\nSUCCESS!");
      }
  })
  .catch(function(err) {
        console.log("\nERROR CALLING THE BE SERVICE");
  });

运行它我得到以下结果：

root@NGINXLB:~/node8080$ node app.js 

DNS SRV query
[ { name: 'agent-be-01.node.dc1.consul',
    port: 8080,
    priority: 1,
    weight: 1 },
  { name: 'agent-be-02.node.dc1.consul',
    port: 8081,
    priority: 1,
    weight: 1 } ]

Consul.health.service query:
10.0.1.5:8080
10.0.1.6:8081

ERROR CALLING THE BE SERVICE
{ Error: getaddrinfo ENOTFOUND be01.service.consul be01.service.consul:80
    at errnoException (dns.js:50:10)
    at GetAddrInfoReqWrap.onlookup [as oncomplete] (dns.js:92:26)
  code: 'ENOTFOUND',
  errno: 'ENOTFOUND',
  syscall: 'getaddrinfo',
  hostname: 'be01.service.consul',
  host: 'be01.service.consul',
  port: 80,
  ...
  ...

结论

正如您所看到的，nodejs 客户端正在调用 be 服务，但它无法解析“be01.service.consul”。此外，它使用端口 80 而不是 Consul DNS 接口提供的 8080 或 8081。我错过了什么？

Answer 1

问题是 axios 正在使用dns.lookup它不使用 所设置的服务器dns.setServers。dns.lookup并且dns.resolve不要使用相同的机制来解决。

在纯节点中，可能的选项是在调用 axios 之前使用将域名解析为 IPdns.resolve*或类似此拦截器示例的内容（我还没有尝试过）。

可能更好的解决方案不是在节点中执行此操作，而是使用本地运行的consul 代理的绑定选项来执行 dns 解析。