快捷導(dǎo)航

詳解Node.js amqplib 連接 Rabbit MQ最佳實(shí)踐

更新時(shí)間：2019年01月24日 14:21:17 作者：wangduanduan

這篇文章主要介紹了詳解Node.js amqplib 連接 Rabbit MQ最佳實(shí)踐，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧

客戶端設(shè)置connection_name

在建立連接時(shí)，設(shè)置connection_name屬性，可以在RabbitMQ Managerment 中查看到連接來自那個(gè)實(shí)例。

amqp.connect(rabbitMqAddress, {
  clientProperties: {
   connection_name: 'your host name'
  }
})

隊(duì)列屬性autoDelete durable

如無必要，建議將隊(duì)列設(shè)置成自動(dòng)刪除，這個(gè)在TCP連接斷開后，隊(duì)列會(huì)自動(dòng)刪除。另外也不要使用持久化隊(duì)列。

channel.assertQueue(queueName, {
  autoDelete: true,
  durable: false
})

connnection 和 channel管理

connnection的內(nèi)存消耗。一個(gè)connection至少要使用100kb的內(nèi)存空間，過多的connetion占用將會(huì)導(dǎo)致內(nèi)存溢出，服務(wù)崩潰等問題。(我曾遇到過生產(chǎn)系統(tǒng)，RabbitMQ連接過多，系統(tǒng)一直處于崩潰邊緣的險(xiǎn)境)

重用connection或者channel，而不要重復(fù)開關(guān)，下面給出AMQP各個(gè)階段所耗費(fèi)的tcp包，重復(fù)的開關(guān)，將會(huì)導(dǎo)致

AMQP connections: 7 TCP packages
AMQP channel: 2 TCP packages
AMQP publish: 1 TCP package (more for larger messages)
AMQP close channel: 2 TCP packages
AMQP close connection: 2 TCP packages

Total 14-19 packages (+ Acks)

一個(gè)進(jìn)程，一個(gè)channel, 一個(gè)connection，如果一個(gè)pod向RabbitMQ建立了多條tcp連接，你就要警惕了。

監(jiān)控進(jìn)程與RabbitMQ TCP連接數(shù)，將NodeJS的運(yùn)行信息寫入influxDB，并在grafana做監(jiān)控和告警。其中tcp連接數(shù)可以使用shelljs執(zhí)行命令獲取。

function getRabbitMqConnnectionCount (params) {
 shell.exec(`netstat -nt | grep ${rabbitmqHost} | wc -l`, (code, stdout, stderr) => {
  try {
   if (code === 0) {
    rabbitMqConnnectionCount = parseInt(stdout) || 0
   }
  } catch (error) {
   log.error(error.message)
  }
 })
}

參考

https://www.cloudamqp.com/blog/2017-12-29-part1-rabbitmq-best-practice.html
https://www.cloudamqp.com/blog/2018-01-08-part2-rabbitmq-best-practice-for-high-performance.html
https://www.cloudamqp.com/blog/2018-01-19-part4-rabbitmq-13-common-errors.html

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: