Objeto objeto integrado

Mensaje de objeto

Objeto de mensaje básico

El objeto Mensaje es compatible con mq Cada módulo se puede utilizar para construir un sistema de procesamiento de mensajes personalizado, creando métodos:

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

Herencia

#lineWidth: 1.5 #font: Helvetica,sans-Serif #fontSize: 10 #leading: 1.6 #.this: fill=lightgray #.class: fill=white [<class>object|toString();toJSON()] [<this>Message|new Message()|TEXT;BINARY|value;params;type;data;body;length;stream;lastError|read();readAll();write();json();pack();end();isEnded();clear();sendTo();readFrom()] [<class>HttpMessage] [<class>HttpRequest] [<class>HttpResponse] [<class>WebSocketMessage] [object] <:- [Message] [Message] <:- [HttpMessage] [HttpMessage] <:- [HttpRequest] [HttpMessage] <:- [HttpResponse] [Message] <:- [WebSocketMessage] Message new Message() TEXT BINARY value params type data body length stream lastError read() readAll() write() json() pack() end() isEnded() clear() sendTo() readFrom() object toString() toJSON() HttpMessage HttpRequest HttpResponse WebSocketMessage

Constructor

Message

Constructor de objetos de mensaje

1
new Message();

constante

TEXT

Especifique el tipo de mensaje 1, que representa un tipo de texto

1
const Message.TEXT = 1;

BINARY

Especifique el tipo de mensaje 2, que representa un tipo binario

1
const Message.BINARY = 2;

Atributos de miembros

value

String, el contenido básico del mensaje

1
String Message.value;

params

NArray, los parámetros básicos del mensaje

1
readonly NArray Message.params;

type

Entero, tipo de mensaje

1
Integer Message.type;

data

Valor, consulta los datos del mensaje, este atributo devolverá datos diferentes según el tipo de contenido, cuando es texto, devuelve el texto, que es json Al regresar json, Otras veces vuelven a binario

1
readonly Value Message.data;

body

SeekableStream, El objeto de flujo que contiene la parte de datos del mensaje

1
SeekableStream Message.body;

length

Long, la longitud de la parte de datos del mensaje.

1
readonly Long Message.length;

stream

Stream, Consultar el objeto de flujo cuando el mensaje readFrom

1
readonly Stream Message.stream;

lastError

Cadena, consulta y configuración del último error de procesamiento de mensajes.

1
String Message.lastError;

Función miembro

read

Lea los datos del tamaño especificado de la secuencia, este método es el alias del método de cuerpo correspondiente

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

Parámetros de llamada:

  • bytes: Entero, especifique la cantidad de datos que se leerán, el valor predeterminado es leer un bloque de datos de tamaño aleatorio, el tamaño de los datos leídos depende del dispositivo

Devolver resultado:

  • Buffer, Devuelve los datos leídos de la secuencia, si no hay datos para leer o la conexión se interrumpe, devuelve nulo

readAll

Leer todos los datos restantes de la secuencia, este método es un alias del método correspondiente de body

1
Buffer Message.readAll() async;

Devolver resultado:

  • Buffer, Devuelve los datos leídos de la secuencia, si no hay datos para leer o la conexión se interrumpe, devuelve nulo

write

Escribe los datos dados, este método es el alias del método de cuerpo correspondiente.

1
Message.write(Buffer data) async;

Parámetros de llamada:

  • data: Buffer, Dados los datos a escribir

json

Escribe los datos dados en codificación JSON

1
Value Message.json(Value data);

Parámetros de llamada:

  • data: Valor, dados los datos a escribir

Devolver resultado:

  • Value, Este método no devolverá datos

Analizar los datos del mensaje en codificación JSON

1
Value Message.json();

Devolver resultado:

  • Value, Devuelve el resultado analizado

pack

A msgpack Codificar para escribir los datos dados

1
Value Message.pack(Value data);

Parámetros de llamada:

  • data: Valor, dados los datos a escribir

Devolver resultado:

  • Value, Este método no devolverá datos

A msgpack Codificar y analizar los datos del mensaje

1
Value Message.pack();

Devolver resultado:

  • Value, Devuelve el resultado analizado

end

Establecer el final del procesamiento del mensaje actual,Chain El procesador no continúa transacciones posteriores

1
Message.end();

isEnded

Consultar si el mensaje actual ha terminado

1
Boolean Message.isEnded();

Devolver resultado:

  • Boolean, Devuelve verdadero al final

clear

Borrar el contenido del mensaje

1
Message.clear();

sendTo

Envía un mensaje formateado al objeto de transmisión dado

1
Message.sendTo(Stream stm) async;

Parámetros de llamada:

  • stm: Stream, Especifique el objeto de flujo para recibir mensajes formateados

readFrom

Leer el mensaje formateado del objeto de flujo de caché dado y analizar el objeto de relleno

1
Message.readFrom(Stream stm) async;

Parámetros de llamada:

  • stm: Stream, Especifique el objeto de flujo para leer mensajes formateados

toString

Devuelve la representación en cadena del objeto, generalmente devuelve "[Native Object]", el objeto se puede volver a implementar de acuerdo con sus propias características

1
String Message.toString();

Devolver resultado:

  • String, Devuelve la representación de cadena del objeto

toJSON

Devuelve la representación en formato JSON del objeto, generalmente devuelve una colección de atributos legibles definidos por el objeto

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

Parámetros de llamada:

  • key: Cadena, sin usar

Devolver resultado:

  • Value, Devuelve un valor que contiene JSON serializable