Socket.io mit dem Versprechen oder asynchrone Rückrufe

Könnte dies eine Art von anti-pattern, aber was wäre der beste Weg, um zu simulieren eine promise callback wenn emitting Daten vom client zum server mit socket.io?

Für einen event würde ich sehr viel wie es sich zu Verhalten wie ein normaler get-request, damit der client Daten an den server senden und der server antwortet mit einer Antwort und dann beheben oder die Ablehnung Versprechen.

InformationsquelleAutor Johan Nordberg | 2014-02-10

  1. 1

    Gut, Sie haben zur Nachverfolgung von Anfragen. Also ich würde anfangen mit einem "globalen" counter (es muss nicht global sein, es ist genug, dass es sichtbar ist für zwei Funktionen definiert Balg) wird inkrementiert bei jeder Anfrage (und emittiert gemeinsam mit ihm) und einer "globalen" namespace-handler. Der code kann wie folgt Aussehen:

    var COUNTER = 0,
    HANDLERS = {};

var custom_get = function(data, clb) {
    COUNTER++;
    var msg = {id: COUNTER, data: data};
    socket.emit("GET", JSON.stringify(msg));
    HANDLERS[COUNTER] = clb;    
};

socket.on("GET", function(data) {
    var res = JSON.parse(data);
    HANDLERS[res.id](res.data);
    delete HANDLERS[res.id];
});

    Nun müssen Sie nur noch sicherstellen, dass der server antwortet mit dem gleichen format, also JSON 

    {id:X, data:Y}

    sind, und verwenden die gleiche ID für die gleiche Anfrage. Sie können diesen code verwenden, wie diese:

    custom_get("test", function(res) {
    console.log(res);
});

    Können Sie spielen auch mit diesem code hinzufügen für die Beispiel-timeouts.

    Endlich haben Sie einen Blick auf JSON-RPC. Es ist ein richtiges Protokoll ist einfach, und Sie können leicht implementieren, über WebSocket.

    Schön! Ich verpasste den trick mit der id-Eigenschaft, die die Anrufe.
    Nur damit Sie wissen: es ist eine andere Herangehensweise. Wann immer Sie senden Anfragen an den server diese Anfragen gesendet werden in einer bestimmten Reihenfolge. Sie haben, um sicherzustellen, dass der server antwortet in umgekehrter Reihenfolge. Dies ist, wie Sie können-match-Anfrage mit Antwort. Art FIFO. Dies ist tatsächlich, wie HTTP mit keep-alive funktioniert. Aber es wird kompliziert, auf der Seite des Servers, um sicherzustellen, dass die Antworten sind in der richtigen Reihenfolge (+ möglicherweise gibt es einen Leistungseinbruch, wenn einige Antworten warten in der Warteschlange). Ich würde keine Ratschläge in diese Richtung. Die Art, wie ich Ihnen gezeigt habe, die oben ist viel einfacher zu implementieren und zu pflegen.
    Vielen Dank für das follow-up! Ich fange an zu denken, dass ich sollte nicht verwenden, Buchse.io für diese Art der Reaktion abhängige Anfrage, sondern einen Weg finden, um Zugriff auf den socket manager/speichern auf dem server von einem normalen get-Anfrage. Wie in einem chat vielleicht möchten Sie auch bitten, den server für eine Liste der Mitglieder in den Raum.

    InformationsquelleAutor freakish

  2. 6

    Hier ist was ich getan habe. Ich erstellte eine Funktion, die strahlt eine socket-Befehl und gibt ein Versprechen. Meine einzige Einschränkung ist ich habe nicht viel getan, mit diesem code noch nicht, so müssen Sie möglicherweise einige Optimierungen. Es erfordert auch Q für seine Versprechungen/deferreds.

    - Client-Funktion definition:

    var EmitPromise = function( socket, command, data ) {

    var deferred = Q.defer();

    socket.emit(command, data, function( response ) {

        if( typeof response === "object" ) {

            if( response.success === true ) {

                deferred.resolve(response.data);

            } else {
                if( typeof response.message === "string" ) {
                    deferred.reject( response.message );
                } else {
                    deferred.reject( "The request was not successful." )
                }
            }
        } else {

            deferred.reject( "The response to your request could not be parsed." );
        }

    });

    return deferred.promise.timeout( 30000, "The request took too long to respond." );
}

    Client-side code, um den Anruf zu tätigen:

    EmitPromise( socket, "getValue", "username" )
.then(
    function( data ) {

        console.log(data);
        return EmitPromise( socket, "getValue", "anotherValue" );

    }, function( message ) {
        console.log(message);
    }
).then(
    //Chain your commands from here
);

    Server-Seite handler

    Den wichtigsten Teil dieser Prozedur ist, dass der zweite parameter, hier genannt setValueResult muss aufgerufen werden, mit der ein Objekt mit einer "Erfolg" - Taste, hält den Wert true oder false. Dies war eine Entscheidung von mir, einen Weg, um ablehnen, die Versprechen, im Fall irgendeine Art von Fehler auf der server-Seite.

    socket.on( 'getValue', function( valueName, setValueResult ) {

    var value = getValue(valueName) //Do something with value here

    if( value ) {
        setValueResult({
            success : success,
            data : value
        });
    } else {
        setValueResult({
            success : success
            message : "Unable to retrieve value"
        });
    }
}

    InformationsquelleAutor Greg Tatum

  3. 1

    Den aktuellen sockel.io version 2.1.0 erlaubt das senden von callback-Funktionen auf dem server:

    Client

    socket.emit('ferret', 'tobi', (data) => {
  console.log(data); //data will be 'woot'
});

    Server

    socket.on('ferret', (name, callback) => {
  callback('woot');
});

    Können Sie auch ein Versprechen vor dem emittieren und lösen es in der client-callback-Funktion.

    InformationsquelleAutor Tsunamis

Schreibe einen Kommentar