testmq/notify.js

const axios = require("axios");
const qs = require("qs");
const fs = require("fs");
const queue = require("queue");
const config = require("./config.json");

axios.defaults.baseURL = config.baseUrl;
const q = queue({ results: [], concurrency: 5000 });
JSON.parse(fs.readFileSync("orders.json").toString()).forEach((orderId) => {
    q.push((cb) => {
        axios
            .post(
                "/notify/adapay/ordertest/" +
                    orderId +
                    "?transactionId=" +
                    new Date().getTime()
            )
            .then((res) => {
                console.log(orderId + " ok");
                cb();
            })
            .catch((e) => {
                console.log(orderId + " fail");
                cb();
            });
    });
});

q.start(() => {
    console.log("done");
});