const hosts = [
'rabbitmq-node1:5672',
'rabbitmq-node2:5672',
'rabbitmq-node3:5672'
];
const connection = await amqp.connect({
port: 5672,
username: 'guest',
password: 'guest',
hosts: hosts, // specify the cluster nodes
heartbeat: 60 // send a health check every 60 seconds to check that the connection is still active
});
1条答案
按热度按时间2guxujil1#
你用的是什么版本?
如果您使用的是
0.5.0
或更早版本,则可以使用以下配置:否则如果是高于0.5.0的版本,我认为amqplib不会再考虑这种指定主机的能力了,实际上应该会
在它后面,RabbitMQ在连接期间提供节点的其他URL。