Objektnachricht
Basisnachrichtenobjekt
Das Message-Objekt ist kompatibel mit mq Jedes Modul kann verwendet werden, um ein benutzerdefiniertes Nachrichtenverarbeitungssystem zu erstellen und Methoden zu erstellen:
1
2var mq = require("mq");
var m = new mq.Message();
Nachlass
Konstrukteur
Message
Nachrichtenobjektkonstruktor
1new Message();
Konstante
TEXT
Geben Sie den Nachrichtentyp 1 an, der einen Texttyp darstellt
1const Message.TEXT = 1;
BINARY
Geben Sie Nachrichtentyp 2 an, der einen binären Typ darstellt
1const Message.BINARY = 2;
Mitgliedsattribute
value
String, der grundlegende Inhalt der Nachricht
1String Message.value;
params
NArray, die grundlegenden Parameter der Nachricht
1readonly NArray Message.params;
type
Ganzzahl, Nachrichtentyp
1Integer Message.type;
data
Wert, fragt die Daten der Nachricht ab, dieses Attribut gibt je nach Inhaltstyp unterschiedliche Daten zurück, wenn es sich um Text handelt, gibt es den Text zurück, der ist json Bei der Rückkehr json, Andere Zeiten kehren zu binär zurück
1readonly Value Message.data;
body
SeekableStream, Das Stream-Objekt, das den Datenteil der Nachricht enthält
1SeekableStream Message.body;
length
Long, die Länge des Datenteils der Nachricht
1readonly Long Message.length;
stream
Stream, Fragt das Stream-Objekt ab, wenn die Nachricht readFrom
1readonly Stream Message.stream;
lastError
String, Abfrage und Einstellung des letzten Fehlers der Nachrichtenverarbeitung
1String Message.lastError;
Mitgliederfunktion
read
Liest die Daten der angegebenen Größe aus dem Stream, diese Methode ist der Alias der entsprechenden Methode von body
1Buffer Message.read(Integer bytes = -1) async;
Aufrufparameter:
- bytes: Integer, geben Sie die zu lesende Datenmenge an, standardmäßig wird ein Datenblock zufälliger Größe gelesen, die Größe der gelesenen Daten hängt vom Gerät ab
Ergebnis zurückgeben:
- Buffer, Die aus dem Stream gelesenen Daten zurückgeben, wenn keine Daten zum Lesen vorhanden sind oder die Verbindung unterbrochen ist, dann null zurückgeben
readAll
Lies alle verbleibenden Daten aus dem Stream, diese Methode ist ein Alias der entsprechenden Methode von body
1Buffer Message.readAll() async;
Ergebnis zurückgeben:
- Buffer, Die aus dem Stream gelesenen Daten zurückgeben, wenn keine Daten zum Lesen vorhanden sind oder die Verbindung unterbrochen ist, dann null zurückgeben
write
Schreiben Sie die angegebenen Daten, diese Methode ist der Alias der entsprechenden Methode von body
1Message.write(Buffer data) async;
Aufrufparameter:
- data: Buffer, Angesichts der zu schreibenden Daten
json
Schreiben Sie die angegebenen Daten in JSON-Codierung
1Value Message.json(Value data);
Aufrufparameter:
- data: Wert, gegeben die zu schreibenden Daten
Ergebnis zurückgeben:
- Value, Diese Methode gibt keine Daten zurück
Analysieren Sie die Daten in der Nachricht in JSON-Codierung
1Value Message.json();
Ergebnis zurückgeben:
- Value, Das geparste Ergebnis zurückgeben
pack
von msgpack Codieren, um die angegebenen Daten zu schreiben
1Value Message.pack(Value data);
Aufrufparameter:
- data: Wert, gegeben die zu schreibenden Daten
Ergebnis zurückgeben:
- Value, Diese Methode gibt keine Daten zurück
von msgpack Codieren und Parsen der Daten in der Nachricht
1Value Message.pack();
Ergebnis zurückgeben:
- Value, Das geparste Ergebnis zurückgeben
end
Setzen Sie das Ende der aktuellen Nachrichtenverarbeitung,Chain Der Prozessor setzt nachfolgende Transaktionen nicht fort
1Message.end();
isEnded
Abfrage, ob die aktuelle Nachricht zu Ende ist
1Boolean Message.isEnded();
Ergebnis zurückgeben:
- Boolean, Gib am Ende true zurück
clear
Inhalt der Nachricht löschen
1Message.clear();
sendTo
Senden Sie eine formatierte Nachricht an das angegebene Stream-Objekt
1Message.sendTo(Stream stm) async;
Aufrufparameter:
- stm: Stream, Geben Sie das Stream-Objekt an, um formatierte Nachrichten zu empfangen
readFrom
Lesen Sie die formatierte Nachricht aus dem angegebenen Cache-Stream-Objekt und analysieren Sie das Füllobjekt
1Message.readFrom(Stream stm) async;
Aufrufparameter:
- stm: Stream, Geben Sie das Stream-Objekt zum Lesen formatierter Nachrichten an
toString
Gibt die String-Darstellung des Objekts zurück, gibt im Allgemeinen "[Native Object]" zurück, das Objekt kann entsprechend seiner eigenen Eigenschaften neu implementiert werden
1String Message.toString();
Ergebnis zurückgeben:
- String, Gibt die String-Darstellung des Objekts zurück
toJSON
Gibt die Darstellung des Objekts im JSON-Format zurück, gibt im Allgemeinen eine Sammlung von lesbaren Attributen zurück, die durch das Objekt definiert sind
1Value Message.toJSON(String key = "");
Aufrufparameter:
- key: String, unbenutzt
Ergebnis zurückgeben:
- Value, Gibt einen Wert zurück, der JSON serialisierbar enthält