Redis pub/sub для асинхронного ответа/ожидания ответа на Nodejs

Вы можете сделать что-то вроде ниже. Обратите внимание, что это базовый макет. Пожалуйста, обновите логику в соответствии с вашими потребностями.

Первым шагом было бы разделить два приложения для ясности.

В приложении А:

1. Будем подписываться на канал send-company
2. Мы опубликуем конкретное сообщение на канале get-company внутри обещания.
3. Мы подождем и разрешим сообщение, как только ответ будет получен в канале компании-отправителя внутри обещания.

// import necessary modules as per your need
// import necessary modules as per your need
const Redis = require('ioredis');
const redisAppASub = new Redis();
const redisAppAPub = new Redis();

async function appA(){

    await redisAppASub.subscribe("send-company", (err, count) => {
        if (err) console.error(err?.message);
    });

    redisAppASub.on("message", async (channel, message) => {
        if (channel === "send-company") {
            console.info(message);

            // handle the received message here

            // unsubscribe if required
            // redisAppA.unsubscribe();
        }
    });

    // Possible solution for the query ["My question is, is there a way in the application A first channel call to await a return response from application B through the second channel ?"]

    async function requestDataFromAppB(){
        return new Promise((resolve, reject) => {
            redisAppAPub.publish("get-company", "requestDBData", (err) => {
                if (err) return reject(err);

                console.info("request sent to Application B");
            });

            // Temporary subscription to listen and resolve the response
            redisAppASub.once("message", (channel, message) => {
                if (channel == "send-company"){
                    resolve(message)
                }
            });
        });
    }

    // call the requestDataFromAppB and get the response
    const response = await requestDataFromAppB();        
    console.info(response, " <<--------- response received from Application B");               
}

// call as per your need
appA().catch(err => console.error(`Application A error: ${err?.message}`));

В приложении Б:

// import necessary modules as per your need
const Redis = require('ioredis');
const redisAppBSub = new Redis();
const redisAppBPub = new Redis();

async function appB(){
    console.info("Application B is starting...");

    await redisAppBSub.subscribe("get-company", (err, count) => {
        if (err) console.error(err?.message);
    });

    redisAppBSub.on("message", async (channel, message) => {
        if (channel == "get-company" && message == "requestDBData"){
        const dbData = await fetchDataFromDatabase();
        console.info(dbData, ` <<----- dbData`);

        redisAppBPub.publish("send-company", dbData, (err) => {
            if (err) console.info(err?.message)
            console.info("response sent to Application A")
        });
        }
    });

    async function fetchDataFromDatabase() {
        // Your data fetching logic here

        // Simulate fetching data with a delay using a Promise
        return new Promise((resolve) => {
            setTimeout(() => {
                resolve(JSON.stringify({data: "data from database"}));
            }, 5000);
        });
    }
}

// call as per your need
appB().catch(err => console.error(`Application B error: ${err?.message}`));