ObjectMessage

Grundlegendes Nachrichtenobjekt

Nachrichtenobjekte sind kompatibel mitmqMit jedem Modul kann ein benutzerdefiniertes Nachrichtenverarbeitungssystem erstellt werden. Die Erstellungsmethode ist:

1
2
var mq = require("mq");
var m = new mq.Message();

Erbschaftsverhältnis

Konstrukteur

Message

Konstruktor für Nachrichtenobjekte

1
new Message();

Konstante

TEXT

Geben Sie den Nachrichtentyp 1 an, der einen Texttyp darstellt

1
const Message.TEXT = 1;

---

BINARY

Geben Sie den Nachrichtentyp 2 an, der einen Binärtyp darstellt

1
const Message.BINARY = 2;

Mitgliedereigenschaften

value

String, der grundlegende Inhalt der Nachricht

1
String Message.value;

---

params

NArray, die Grundparameter der Nachricht

1
readonly NArray Message.params;

---

type

Ganzzahl, Nachrichtentyp

1
Integer Message.type;

---

data

Wert: Fragen Sie die Daten der Nachricht ab. Dieses Attribut gibt je nach Inhaltstyp unterschiedliche Daten zurück. Wenn es sich um Text handelt, wird der Text zurückgegeben.jsonwann zurückkommenjson, andernfalls wird binär zurückgegeben

1
readonly Value Message.data;

---

body

SeekableStream, ein Stream-Objekt, das den Datenteil der Nachricht enthält

1
SeekableStream Message.body;

---

length

Long, die Länge des Nachrichtendatenteils

1
readonly Long Message.length;

---

stream

Stream, das Stream-Objekt beim Abfragen der Nachricht readFrom

1
readonly Stream Message.stream;

---

lastError

String, Abfrage und Setzen des letzten Fehlers der Nachrichtenverarbeitung

1
String Message.lastError;

Mitgliedsfunktion

read

Liest Daten der angegebenen Größe aus dem Stream. Diese Methode ist ein Alias ​​der entsprechenden Methode von body.

1
Buffer Message.read(Integer bytes = -1) async;

Aufrufparameter:

• bytes: Ganzzahl, gibt die Menge der zu lesenden Daten an. Standardmäßig werden Datenblöcke zufälliger Größe gelesen. Die Größe der gelesenen Daten hängt vom Gerät ab.

Rückgabeergebnisse:

• Buffer, gibt die aus dem Stream gelesenen Daten zurück. Wenn keine Daten zum Lesen vorhanden sind oder die Verbindung unterbrochen ist, wird null zurückgegeben.

---

readAll

Liest alle verbleibenden Daten aus dem Stream. Diese Methode ist ein Alias ​​der entsprechenden Methode von body.

1
Buffer Message.readAll() async;

Rückgabeergebnisse:

• Buffer, gibt die aus dem Stream gelesenen Daten zurück. Wenn keine Daten zum Lesen vorhanden sind oder die Verbindung unterbrochen ist, wird null zurückgegeben.

---

write

Schreiben Sie die angegebenen Daten. Diese Methode ist ein Alias ​​der entsprechenden Methode im Hauptteil.

1
Message.write(Buffer data) async;

Aufrufparameter:

• data:Buffer, angesichts der zu schreibenden Daten

---

json

Schreibt die angegebenen Daten in JSON-Codierung

1
Value Message.json(Value data);

Aufrufparameter:

• data: Wert angesichts der zu schreibenden Daten

Rückgabeergebnisse:

• Value, diese Methode gibt keine Daten zurück

---

Analysieren Sie die Daten in der Nachricht als JSON-Codierung

1
Value Message.json();

Rückgabeergebnisse:

• Value, gibt das analysierte Ergebnis zurück

---

pack

vonmsgpackBeim Codieren werden die angegebenen Daten geschrieben

1
Value Message.pack(Value data);

Aufrufparameter:

• data: Wert angesichts der zu schreibenden Daten

Rückgabeergebnisse:

• Value, diese Methode gibt keine Daten zurück

---

vonmsgpackCodieren und Parsen der Daten in der Nachricht

1
Value Message.pack();

Rückgabeergebnisse:

• Value, gibt das analysierte Ergebnis zurück

---

end

Legen Sie das Ende der aktuellen Nachrichtenverarbeitung fest.ChainDer Prozessor fährt mit nachfolgenden Transaktionen nicht fort

1
Message.end();

---

isEnded

Abfrage, ob die aktuelle Nachricht beendet ist

1
Boolean Message.isEnded();

Rückgabeergebnisse:

• Boolean, gibt true zurück, wenn es fertig ist

---

clear

Klarer Nachrichteninhalt

1
Message.clear();

---

sendTo

Sendet eine formatierte Nachricht an das angegebene Stream-Objekt

1
Message.sendTo(Stream stm) async;

Aufrufparameter:

• stm:Stream, gibt das Stream-Objekt an, das die formatierte Nachricht empfängt

---

readFrom

Liest die formatierte Nachricht aus dem angegebenen Cache-Stream-Objekt und analysiert das aufgefüllte Objekt

1
Message.readFrom(Stream stm) async;

Aufrufparameter:

• stm:Stream, gibt das Stream-Objekt zum Lesen formatierter Nachrichten an

---

toString

Gibt die Zeichenfolgendarstellung des Objekts zurück. Im Allgemeinen wird „[Native Object]“ zurückgegeben. Das Objekt kann gemäß seinen eigenen Eigenschaften neu implementiert werden.

1
String Message.toString();

Rückgabeergebnisse:

• String, gibt die Zeichenfolgendarstellung des Objekts zurück

---

toJSON

Gibt eine Darstellung des Objekts im JSON-Format zurück und gibt im Allgemeinen eine Sammlung lesbarer Eigenschaften zurück, die vom Objekt definiert werden.

1
Value Message.toJSON(String key = "");

Aufrufparameter:

• key: Zeichenfolge, nicht verwendet

Rückgabeergebnisse:

• Value, gibt einen Wert zurück, der JSON serialisierbar enthält