При использовании системы MQ
, например RabbitMQ
, Google Pub/Sub
.
Должен ли я создавать канал / очередь сообщений во время выполнения приложения?Или сначала создать его вручную?
Например, при использовании Google Pub/Sub
создать topic
во время выполнения.
async function createTopic(topicName: string): Promise<any> {
const topicInstance = pubsubClient.topic(topicName);
const [exists] = await topicInstance.exists();
if (exists) {
logger.info(`${topicName} topic is existed`);
return;
}
return pubsubClient
.createTopic(topicName)
.then((data) => {
logger.info(`Create topic ${topicName} successfully`);
return data;
})
.catch((err) => logger.error(err));
}
Особенно с учетом процессов разработки, развертывания и непрерывной интеграции.
Я прочитал из книги, что создание очереди сообщений в режиме реального времени не очень полезно.