生产者和消费者之间的 RabbitMQ 消息延迟

Question

我在RabbitMQ服务器上运行node.js amqp-node客户端。我以两种不同的方式设置了一个简单的发布/消费测试 - 每种方式都会产生不同的延迟，我无法弄清楚原因。延迟是从发送消息到传递消息的时间测量的。

第一种方法使用两个单独的进程 - 一个用于发布应用程序 - 一个用于使用应用程序。它产生的延迟约为 4 毫秒。第二种方法仅使用一个应用来生产和消费。这会产生大约 40 毫秒的延迟。谁能向我解释这种行为为什么？谢谢你的时间。

方法#1生产者：

var amqp = require('amqp'),
    connection = amqp.createConnection({host:'localhost'}),
    testExchange = {};
connection.on('ready', function(){
    testExchange = connection.exchange('testExchange', {type:'topic', autoDelete:true});
    testMessage();
});
function testMessage(){
    console.log('message sent');
    testExchange.publish('test.message', { msg:'testMessage', time: new Date().getTime() });
    setTimeout(testMessage, 500);
}

方法 #1 消费者

var amqp = require('amqp'),
    connection = amqp.createConnection({host:'localhost'}),
connection.on('ready', function(){
    var testExchange = connection.exchange('testExchange', {type:'topic', autoDelete:true});
    var testQ = connection.queue('testQ', function(queue){
        queue.bind('testExchange', 'test.#');
        queue.subscribe( function(message){
            console.log('message received');
            var now = new Date().getTime();
            console.log(now-message.time);
        });
    });
});

方法#2生产者和消费者

var amqp = require('amqp'),
    connection = amqp.createConnection({host:'localhost'}),
    testExchange = {};
connection.on('ready', function(){
    testExchange = connection.exchange('testExchange', {type:'topic', autoDelete:true});
    var testQ = connection.queue('testQ', function(queue){
        queue.bind('testExchange', 'test.#');
        queue.subscribe( function(message){
            console.log('message received');
            var now = new Date().getTime();
            console.log(now-message.time);
        });
        testMessage();
    });
});
function testMessage(){
    console.log('message sent');
    testExchange.publish('test.message', { msg:'testMessage', time: new Date().getTime() });
    setTimeout(testMessage, 500);
}

Answer 1

在第一种方法中，您有两个与 RabbitMQ 服务器的独立连接，而在第二种方法中，您为生产者（发送者）和消费者（接收者）共享相同的连接。诚然，考虑到本地主机 RabbitMQ 服务器，您每秒 2 条的消息速率非常低，因此我们可以忽略任何网络延迟，但我怀疑 RabbitMQ 或节点.js amqp 实现在发送方和接收方在同一连接上多路复用时会减慢速度。

干杯！