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
2var mq = require("mq");
var m = new mq.Message();
Herencia
Constructor
Message
Constructor de objetos de mensaje
1new Message();
constante
TEXT
Especifique el tipo de mensaje 1, que representa un tipo de texto
1const Message.TEXT = 1;
BINARY
Especifique el tipo de mensaje 2, que representa un tipo binario
1const Message.BINARY = 2;
Atributos de miembros
value
String, el contenido básico del mensaje
1String Message.value;
params
NArray, los parámetros básicos del mensaje
1readonly NArray Message.params;
type
Entero, tipo de mensaje
1Integer 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
1readonly Value Message.data;
body
SeekableStream, El objeto de flujo que contiene la parte de datos del mensaje
1SeekableStream Message.body;
length
Long, la longitud de la parte de datos del mensaje.
1readonly Long Message.length;
stream
Stream, Consultar el objeto de flujo cuando el mensaje readFrom
1readonly Stream Message.stream;
lastError
Cadena, consulta y configuración del último error de procesamiento de mensajes.
1String 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
1Buffer 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
1Buffer 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.
1Message.write(Buffer data) async;
Parámetros de llamada:
- data: Buffer, Dados los datos a escribir
json
Escribe los datos dados en codificación JSON
1Value 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
1Value Message.json();
Devolver resultado:
- Value, Devuelve el resultado analizado
pack
por msgpack Codificar para escribir los datos dados
1Value Message.pack(Value data);
Parámetros de llamada:
- data: Valor, dados los datos a escribir
Devolver resultado:
- Value, Este método no devolverá datos
por msgpack Codificar y analizar los datos del mensaje
1Value 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
1Message.end();
isEnded
Consultar si el mensaje actual ha terminado
1Boolean Message.isEnded();
Devolver resultado:
- Boolean, Devuelve verdadero al final
clear
Borrar el contenido del mensaje
1Message.clear();
sendTo
Envía un mensaje formateado al objeto de transmisión dado
1Message.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
1Message.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
1String 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
1Value Message.toJSON(String key = "");
Parámetros de llamada:
- key: Cadena, sin usar
Devolver resultado:
- Value, Devuelve un valor que contiene JSON serializable