Уже лучше, теперь дальше - как выглядит коннектор к реббиту?

если он из переменных окружения берет реквизиты - то покажите их

25 ответов

43 просмотра

async waitForConnection(interval = 1000, maxRetry) { console.log('... connecting to Queue ...') if (maxRetry > 0) { if (this.retry > maxRetry) { throw new Error('Exceeded Max Retry. Exiting ...') } this.retry++ } try { await this.connect() console.log('... connected to Queue ...') } catch (err) { console.log('Could not connect to Queue, retrying...') await this.wait(interval) await this.waitForConnection(maxRetry) } } async wait(time) { return new Promise((resolve) => setTimeout(resolve, time)) } async connect() { // connect to rabbitmq this.connection = await amqplib.connect(this.connectionString) // create connection this.channel = await this.connection.createChannel() // create exchange await this.channel.assertExchange(this.exchangeName, this.exchangeType, { durable: this.exchangeDurable, }) // create queue await this.channel.assertQueue(this.queueName, { durable: this.queueDurable, }) // set prefetch count this.channel.prefetch(this.prefetchCount) // bind queue to exchange await this.channel.bindQueue( this.queueName, this.exchangeName, this.routingKey ) return null } создание коннекта let RmqNotifications = await RMQConn({ exchangeType: 'direct', exchangeName: 'notifications', queueName: 'notifications', routingKey: 'notifications', })

Aleksey-Barabanov Автор вопроса
Aleksey Barabanov
connectionString как выглядит?

const connectionString = `amqp://${user}:${pass}@${host}:${port}` из ENV данные

module.exports.RMQConn = async function (initObj) { try { if (!instance) { instance = new QueueClient(initObj) await instance.waitForConnection(1000) } return instance } catch (err) { console.log(err.message) } } создание коннекта let RmqNotifications = await RMQConn({ exchangeType: 'direct', exchangeName: 'notifications', queueName: 'notifications', routingKey: 'notifications', })

хм.. странно. Думал что если сеть отваливается amqplib в on disconnect сообщить должна об этом, а вот выходит что нифига не так.. но я понял, пойду переписывать

вот такое есть this.connection.on('connect', () => { console.log('Connected!') }) this.connection.on('disconnect', (params) => { console.log('Disconnected: ', params.err) }) this.connection.on('connectFailed', (params) => { console.log('connectFailed: ', params) }) this.connection.on('unblocked', () => { console.log('Unblocked') }) this.connection.on('blocked', (params) => { console.log('Blocked, reason: ', params.reason) })

Vadim
А что за либа?

черт, сори, я перепутал либы )))) думал такое есть в amqplib, а он оесть только в amqp-connection-manager наверное ее проще заюзать будет, чем с нуля писать

а с чем это связано? разрушение каналов имею ввиду архитектура самого кролика? или внешние факторы?

Алекс
а с чем это связано? разрушение каналов имею ввиду...

С сетью, с опоздавшими хэртбитами, с проксей, если она стоит перед кроликом, с протоколом (например, если произошло исключение в процессе работы с каналом, то с ним уже ничего сделать нельзя).

А куда деваться, это нода, там единственный рекомендуемый клиент и тот без 1.0 версии в 2024м

Ну нода в целом в плане экосистемы по нулям

Владислав Килин
Ну нода в целом в плане экосистемы по нулям

Есть там и свои либы, аналогов которым нет. Скажем, лучше, чем жс, мы не нашли либы для рендера пдф, работы с браузером и даже для работы с smpp (не smtp).

Vadim
Есть там и свои либы, аналогов которым нет. Скажем...

На дотнетике есть божественные либы для пдф, даже в годы до неткора. Но может у вас конечно особые кейсы были

Владислав Килин
И зря!)

Да ну, он же специфический. Только под винду работает(л) (или уже нет?). Там только NServiceBus крутой, как я знаю, многие по нему джавовские либы пилили.

Похожие вопросы

Обсуждают сегодня

Скажите пожалуйста это известное поведение? configVersion: 1 project: test image: test from: alpine:3 docker: ENV: PATH: ${PATH}:/test/bin Получаю вот такие переменные ...
Eugene Shutov
2
Может кто подсказать, есть ли какая-то особенность по настройке RabbitMQ + ClickHouse внутри одного композ файла (в общую сеть добавил)? Интересную ошибку ловлю в реббите: 0...
Виктор FabulouS
5
Добрый день. после перехода на NELM, деплой стал падать с ошибкой: werf converge --env staging Version: v1.2.301 Using werf config render file: /tmp/werf-config-render-174704...
Sergey Ponomarev
4
Господа, кто-то трогал github advanced security в сравнении с сонаркубом бесплатным? Какие преимущества (помимо штук GHAS, нерелевантных для сравнения с сонаром)?
Peter H.
5
В чем разница между командами при авторизации в харборе? werf cr login -u username -p password harbor.example.com werf build --repo-container-registry='harbor' --repo-harbor-...
Виталий Кудрявцев
4
Привет всем, у многих в команде devsecops присутствуют безопасники или отделы безопасников? Или же чаще разработчики эти функции на себя берут, развиваясь в эту сторону? Я инж...
Андрей
2
Чем принципиально отличается ack от reject (requeue=false)? Оба же удаляют сообщения из очереди?
Юрий
54
Здравствуйте! Прохожу самоучитель и у меня возникла проблема "Руководства Spring Boot Реалистичные приложения Работа с базой данных" https://ru.werf.io/guides/java_springboot/...
Vladimir job
2
Здрасьте! Сейчас рекомендуется запускать сборку werf внутри kubernetes? Пока не получается использовать github action runner controller без privileged режима для пода. А с pr...
Vyacheslav
2
всем привет, а в каких ситуациях и почему такое возникает? Error: helm upgrade have failed: UPGRADE FAILED: an error occurred while rolling back the release. original upgrade...
Dmitry Ovcharov
7
Карта сайта