如何对所有列表（数组）项目进行操作？

Question

我尝试创建简单的监控工具，用于 ping 配置文件中的所有服务。对所有项目同时运行 ping 命令。目前我可以按索引 ping 单个元素，如何为每个人执行此操作？

config/host.yml

    default:
      server:
        port: 3000
      hosts:
        type: 'CaP AC'
    development:
      hosts:
      type: 'CaP AC'
      model: 'RBcAPGi-5acD2nD'
      location: 'Office'
      list:
        - host: '10.10.10.10'
          user: 'admin'
          password: 'password'
          name: 'cap-1'
        - host: '10.10.4.5'
          user: 'admin'
          password: 'password'
          name: 'cap-2'

控制器/update.js

const Hosts = require('./hosts');
const Monitor = require('ping-monitor');

module.exports = {
  Ping: function (config) {
      return new Promise(function (resolve, reject) {
          config.hosts.list.forEach(cap => {
              let pong = new Monitor({
                  website: "http://"+config.host,
                  interval: 1,
                  config: {
                      intervalUnits: "seconds"
                  },
                  ignoreSSL: true
              })
              pong.on('up', function (res, state) {
                  console.log('Service up!');
              });

              pong.on('error', function (error, res) {
                  console.error(error);
              });
          })
      })

  }

控制器/hosts.js

var hosts = [];
module.exports = hosts;

index.js

const config = yaml_config.load(__dirname + '/config/host.yml');
const Update = require('./controllers/update');
const Hosts = require('./controllers/hosts');

Update.Ping(config).then(result => {
  result.forEach(cap => {
      console.log(cap +result)
  }).catch((err) => {
      console.log(err)
  });
})

Answer 1

您可以将每个监视器包装在一个 Promise 中，并在打印收到的状态之前等待所有这些 Promise。以下是一些可以帮助您的示例代码：

module.exports = {
  Ping: function (config) {
        const monitorPromises = config.hosts.list.map(currConfig => {
            return new Promise((resolve) => {
                const currMonitor = new Monitor({
                    website: "http://" + currConfig.host,
                    interval: 1,
                    config: {
                        intervalUnits: "seconds"
                    },
                    ignoreSSL: true
                });
                currMonitor.on('up', function (res, state) {
                    resolve(`${res.website}:${res.port} is up.`);
                });

                currMonitor.on('down', function (res) {
                    resolve(`${res.website} is down!, statusMessage:  ${res.statusMessage}`);
                });

                currMonitor.on('stop', function (res, state) {
                    resolve(`${res.website} monitor has stopped.`);
                });

                currMonitor.on('error', function (error, res) {
                    resolve(error);
                });

                currMonitor.on('timeout', function (error, res) {
                    resolve(error);
                });
            });
        });
        console.log("done");
        return Promise.all(monitorPromises);
    }
};

然后在你的调用者中，你可以这样做：

Update.Ping(config).then(monitors => {
  monitors.forEach(result => {
      console.log(result);
  }).catch((err) => {
      console.log(err)
  });
})