testmq/index.js

const axios = require("axios");

// let q = Promise.resolve();

// for (let i = 0; i < 100; i++) {
//     q = q.then(() => {
//         return new Promise((resolve, reject) => {
//             axios
//                 .get("http://localhost:8080/testmq/send?data=" + (i + 1))
//                 .then((res) => {
//                     console.log(i + " " + res.data);
//                     resolve();
//                 });
//         });
//     });
// }
// q.then(() => {});

let c = 0;
let success = 0;
let fail = 0;
Promise.all(
    new Array(3000).fill(null).map(
        () =>
            new Promise((resolve, reject) => {
                let t = new Date().getTime();
                axios
                    .get("http://localhost:8080/teststock/test")
                    .then((res) => {
                        if (res.data === "ok") {
                            success++;
                        } else {
                            fail++;
                        }
                        resolve();
                    })
                    .catch((e) => {
                        console.log(e);
                        resolve();
                    });
            })
    )
).then((res) => {
    console.log("all done, success:" + success + ", fail:" + fail);
});