Objecte objecte incorporat

Objecte Missatge

Objecte missatge bàsic

Els objectes missatge són compatibles ambmqCada mòdul es pot utilitzar per crear un sistema de processament de missatges personalitzat. El mètode de creació és:

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

relació hereditària

%0 object object toString() toJSON() Message Message new Message() TEXT BINARY value params type data body length stream lastError read() readAll() write() json() pack() end() isEnded() clear() sendTo() readFrom() object->Message HttpMessage HttpMessage Message->HttpMessage WebSocketMessage WebSocketMessage Message->WebSocketMessage HttpRequest HttpRequest HttpMessage->HttpRequest HttpResponse HttpResponse HttpMessage->HttpResponse

Constructor

Message

Constructor d'objectes de missatge

1
new Message();

constant

TEXT

Especifiqueu el tipus de missatge 1, que representa un tipus de text

1
const Message.TEXT = 1;

BINARY

Especifiqueu el tipus de missatge 2, que representa un tipus binari

1
const Message.BINARY = 2;

propietats dels membres

value

String, el contingut bàsic del missatge

1
String Message.value;

params

NArray, els paràmetres bàsics del missatge

1
readonly NArray Message.params;

type

Sencer, tipus de missatge

1
Integer Message.type;

data

Valor, consulta les dades del missatge. Aquest atribut retornarà dades diferents segons el tipus de contingut. Quan sigui text, es retornarà el text.jsontornar quanjson, en cas contrari, retorna binari

1
readonly Value Message.data;

body

SeekableStream, un objecte de flux que conté la part de dades del missatge

1
SeekableStream Message.body;

length

Long, la longitud de la part de dades del missatge

1
readonly Long Message.length;

stream

Stream, l'objecte de flux quan es consulta el missatge readFrom

1
readonly Stream Message.stream;

lastError

Encadena, consulta i defineix l'últim error de processament del missatge

1
String Message.lastError;

funció de membre

read

Llegeix dades de la mida especificada del flux. Aquest mètode és un àlies del mètode corresponent del cos.

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

Paràmetres de trucada:

  • bytes: Sencer, especifica la quantitat de dades que s'han de llegir. El valor predeterminat és llegir blocs de dades de mida aleatòria. La mida de les dades llegides depèn del dispositiu.

Resultats de retorn:

  • Buffer, retorna les dades llegides del flux. Si no hi ha dades per llegir o la connexió s'interromp, es retorna null.

readAll

Llegeix totes les dades restants del flux. Aquest mètode és un àlies del mètode corresponent de body.

1
Buffer Message.readAll() async;

Resultats de retorn:

  • Buffer, retorna les dades llegides del flux. Si no hi ha dades per llegir o la connexió s'interromp, es retorna null.

write

Escriu les dades donades. Aquest mètode és un àlies del mètode corresponent al cos.

1
Message.write(Buffer data) async;

Paràmetres de trucada:

  • data:Buffer, donades les dades a escriure

json

Escriu les dades proporcionades en codificació JSON

1
Value Message.json(Value data);

Paràmetres de trucada:

  • data: Valor, tenint en compte les dades a escriure

Resultats de retorn:

  • Value, aquest mètode no retorna dades

Analitzeu les dades del missatge com a codificació JSON

1
Value Message.json();

Resultats de retorn:

  • Value, retorna el resultat analitzat

pack

permsgpackLa codificació escriu les dades donades

1
Value Message.pack(Value data);

Paràmetres de trucada:

  • data: Valor, tenint en compte les dades a escriure

Resultats de retorn:

  • Value, aquest mètode no retorna dades

permsgpackCodificació i anàlisi de les dades del missatge

1
Value Message.pack();

Resultats de retorn:

  • Value, retorna el resultat analitzat

end

Establir el final del processament del missatge actual,ChainEl processador no continua amb les transaccions posteriors

1
Message.end();

isEnded

Consulta si el missatge actual ha acabat

1
Boolean Message.isEnded();

Resultats de retorn:

  • Boolean, torna veritable quan s'hagi acabat

clear

Esborra el contingut del missatge

1
Message.clear();

sendTo

Envia un missatge amb format a l'objecte de flux donat

1
Message.sendTo(Stream stm) async;

Paràmetres de trucada:

  • stm:Stream, especifica l'objecte de flux que rep el missatge amb format

readFrom

Llegeix el missatge amb format de l'objecte del flux de memòria cau donat i analitza l'objecte emplenat

1
Message.readFrom(Stream stm) async;

Paràmetres de trucada:

  • stm:Stream, especifica l'objecte de flux per llegir missatges amb format

toString

Retorna la representació de cadena de l'objecte. En general, es retorna "[Objecte natiu]". L'objecte es pot tornar a implementar segons les seves pròpies característiques.

1
String Message.toString();

Resultats de retorn:

  • String, retorna la representació de cadena de l'objecte

toJSON

Retorna una representació en format JSON de l'objecte, generalment retornant una col·lecció de propietats llegibles definides per l'objecte.

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

Paràmetres de trucada:

  • key: Corda, no utilitzada

Resultats de retorn:

  • Value, retorna un valor que conté JSON serializable