Versuchen, eine Azure Service Bus-Warteschlange mit einem in Node.js geschriebenen WebJob abzufragen. Ich habe 2 WebJobs erstellt. Das erste ist auf Anfrage und sendet 10 eindeutige Nachrichten an die Warteschlange. Der zweite Job ist kontinuierlich und fragt die Warteschlange nach Nachrichten ab.

Betrachtung der folgenden Probleme:

Die Abfrage ist LANGSAM. Der Empfang von 10 Nachrichten dauert durchschnittlich etwa 10 Minuten. Siehe Beispielprotokolldetails unten. Grundsätzlich unbrauchbar bei dieser Geschwindigkeit. Die ganze Verzögerung ist vom Erhalten einer Antwort vonreceiveQueueMessage. Die Antwortzeiten variieren zwischen 0 Sekunden und ~ 120 Sekunden mit einem Durchschnitt von 60 Sekunden.

Die Nachrichten werden in zufälliger Reihenfolge empfangen. Nicht FIFO.

Manchmal werden Nachrichten zweimal empfangen, obwohl sie im ReceiveAndDelete-Modus gelesen werde{isReceiveAndDelete:true} und mit{isPeekLock:false} mit den gleichen Ergebnissen).

Wenn die Warteschlange leer ist, sollte die Empfangsanforderung einen Tag lang geöffnet bleiben, sie wird jedoch nach 230 Sekunden immer ohne Nachrichtenfehler zurückgegeben. Laut Dokumentation beträgt die Höchstdauer 24 Tage, daher weiß ich nicht, woher 230 Sekunden kommen:

Das maximale Zeitlimit für einen blockierenden Empfangsvorgang in Service Bus-Warteschlangen beträgt 24 Tage. REST-basierte Zeitlimits haben jedoch einen Maximalwert von 55 Sekunden.

rundsätzlich funktioniert nichts wie angekündigt. Was mache ich falsch

Nachrichtentestauftrag senden:

var uuid = require('node-uuid');
var azure = require('azure');
var serviceBus = azure.createServiceBusService(process.env.busSearchConnectionString);
var messagesToSend = 10;

sendMessage(0);

function sendMessage(count)
{
    var message = {
        body: 'test message',
        customProperties: {
            message_number: count,
            sent_date: new Date
        },
        brokerProperties: {
            MessageId: uuid.v4() //ensure that service bus doesn't think this is a duplicate message
        }
    };

    serviceBus.sendQueueMessage(process.env.busSearchQueueName, message, function(err) {

        if (!err) {
            console.log('sent test message number ' + count.toString());
        } else {
            console.error('error sending message: ' + err);
        }

    });

    //wait 5 seconds to ensure messages are received by service bus in correct order
    if (count < messagesToSend) {
        setTimeout(function(newCount) {
            //send next message
            sendMessage(newCount);
        }, 5000, count+1);
    }
}    

Nachricht empfangen Fortlaufender Job:

console.log('listener job started');
var azure = require('azure');
var serviceBus = azure.createServiceBusService(process.env.busSearchConnectionString);
listenForMessages(serviceBus);

function listenForMessages(serviceBus)
{
    var start = process.hrtime();
    var timeOut = 60*60*24; //long poll for 1 day
    serviceBus.receiveQueueMessage(process.env.busSearchQueueName, {timeoutIntervalInS: timeOut, isReceiveAndDelete: true}, function(err, message) {

        var end = process.hrtime(start);
        console.log('received a response in %ds seconds', end[0]);

        if (err) {

            console.log('error requesting message: ' + err);
            listenForMessages(serviceBus);

        } else {

            if (message !== null && typeof message === 'object' && 'customProperties' in message && 'message_number' in message.customProperties) {

                console.log('received test message number ' + message.customProperties.message_number.toString());
                listenForMessages(serviceBus);

            } else {

                console.log('invalid message received');
                listenForMessages(serviceBus);

            }

        }

    });
}

Sample Log Output:

[05/06/2015 21:50:14 > 8c2504: SYS INFO] Status changed to Running
[05/06/2015 21:50:14 > 8c2504: INFO] listener job started
[05/06/2015 21:51:23 > 8c2504: INFO] received a response in 1s seconds
[05/06/2015 21:51:23 > 8c2504: INFO] received test message number 0
[05/06/2015 21:51:25 > 8c2504: INFO] received a response in 2s seconds
[05/06/2015 21:51:26 > 8c2504: INFO] received test message number 4
[05/06/2015 21:51:27 > 8c2504: INFO] received a response in 1s seconds
[05/06/2015 21:51:27 > 8c2504: INFO] received test message number 7
[05/06/2015 21:51:28 > 8c2504: INFO] received a response in 0s seconds
[05/06/2015 21:51:29 > 8c2504: INFO] received test message number 9
[05/06/2015 21:51:49 > 8c2504: INFO] received a response in 20s seconds
[05/06/2015 21:51:49 > 8c2504: INFO] received test message number 1
[05/06/2015 21:53:35 > 8c2504: INFO] received a response in 106s seconds
[05/06/2015 21:53:35 > 8c2504: INFO] received test message number 1
[05/06/2015 21:54:26 > 8c2504: INFO] received a response in 50s seconds
[05/06/2015 21:54:26 > 8c2504: INFO] received test message number 5
[05/06/2015 21:54:35 > 8c2504: INFO] received a response in 9s seconds
[05/06/2015 21:54:35 > 8c2504: INFO] received test message number 9
[05/06/2015 21:55:28 > 8c2504: INFO] received a response in 53s seconds
[05/06/2015 21:55:28 > 8c2504: INFO] received test message number 2
[05/06/2015 21:57:26 > 8c2504: INFO] received a response in 118s seconds
[05/06/2015 21:57:26 > 8c2504: INFO] received test message number 6
[05/06/2015 21:58:28 > 8c2504: INFO] received a response in 61s seconds
[05/06/2015 21:58:28 > 8c2504: INFO] received test message number 8
[05/06/2015 22:00:35 > 8c2504: INFO] received a response in 126s seconds
[05/06/2015 22:00:35 > 8c2504: INFO] received test message number 3
[05/06/2015 22:04:25 > 8c2504: INFO] received a response in 230s seconds
[05/06/2015 22:04:25 > 8c2504: INFO] error requesting message: No messages to receive
[05/06/2015 22:08:16 > 8c2504: INFO] received a response in 230s seconds    
[05/06/2015 22:04:25 > 8c2504: INFO] error requesting message: No messages to receive