producer.js

let amqp = require('amqplib');
 
class RabbitMQ {
    constructor() {
        this.hosts = [];
        this.index = 0;
        this.length = this.hosts.length;
        this.open = amqp.connect(this.hosts[this.index]);
    }
    sendQueueMsg(queueName, msg, errCallBack) {
        let self = this;
 
        self.open
            .then(function (conn) {
                return conn.createChannel({
                    host: '127.0.0.1', 
                    port: 5672, 
                    login: 'guest', 
                    password: 'guest', 
                    vhost: '/'
                });
            })
            .then(function (channel) {
                return channel.assertQueue(queueName).then(function (ok) {
                    return channel.sendToQueue(queueName, new Buffer(msg), {
                        persistent: true
                    });
                })
                .then(function (data) {
                    if (data) {
                        errCallBack && errCallBack("success");
                        channel.close();
                    }
                })
                .catch(function () {
                    setTimeout(() => {
                        if (channel) {
                            channel.close();
                        }
                    }, 500)
                });
            })
            .catch(function () {
                let num = self.index++;
 
                if (num <= self.length - 1) {
                    self.open = amqp.connect(self.hosts[num]);
                } else {
                    self.index == 0;
                }
            });
    }
}
 
let mq = new RabbitMQ();
mq.sendQueueMsg('testQueue', '123', (error) => {
    console.log(error)
})