Встроенный объект объекта

ОбъектСообщение

Базовый объект сообщения

Объекты сообщений совместимы сmqКаждый модуль можно использовать для создания собственной системы обработки сообщений.Метод создания:

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

отношения наследства

%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

Конструктор

Message

Конструктор объекта сообщения

1
new Message();

постоянный

TEXT

Укажите тип сообщения 1, который представляет тип текста.

1
const Message.TEXT = 1;

BINARY

Укажите тип сообщения 2, представляющий двоичный тип.

1
const Message.BINARY = 2;

свойства члена

value

Строка, основное содержание сообщения.

1
String Message.value;

params

NArray, основные параметры сообщения

1
readonly NArray Message.params;

type

Целое число, тип сообщения

1
Integer Message.type;

data

Значение, запрос данных сообщения. Этот атрибут будет возвращать разные данные в зависимости от типа контента. Если это текст, будет возвращен текст.jsonвернуться, когдаjson, в противном случае возвращается двоичный файл

1
readonly Value Message.data;

body

SeekableStream, объект потока, содержащий часть данных сообщения

1
SeekableStream Message.body;

length

Long, длина части данных сообщения.

1
readonly Long Message.length;

stream

Stream, объект потока при запросе сообщения readFrom

1
readonly Stream Message.stream;

lastError

Строка, запрос и установка последней ошибки обработки сообщения

1
String Message.lastError;

функция-член

read

Чтение данных указанного размера из потока.Этот метод является псевдонимом соответствующего метода тела.

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

Параметры звонка:

  • bytes: целое число, указывает объем считываемых данных.По умолчанию считываются блоки данных случайного размера.Размер считываемых данных зависит от устройства.

Результаты возврата:

  • Buffer, возвращает данные, считанные из потока. Если данных для чтения нет или соединение прервано, возвращается значение null.

readAll

Считайте все оставшиеся данные из потока.Этот метод является псевдонимом соответствующего метода тела.

1
Buffer Message.readAll() async;

Результаты возврата:

  • Buffer, возвращает данные, считанные из потока. Если данных для чтения нет или соединение прервано, возвращается значение null.

write

Запишите данные.Этот метод является псевдонимом соответствующего метода в теле.

1
Message.write(Buffer data) async;

Параметры звонка:

  • data:Buffer, учитывая данные, которые нужно записать

json

Записывает данные в кодировке JSON.

1
Value Message.json(Value data);

Параметры звонка:

  • data: Значение, учитывая данные для записи.

Результаты возврата:

  • Value, этот метод не возвращает данные

Разобрать данные в сообщении как кодировку JSON.

1
Value Message.json();

Результаты возврата:

  • Value, возвращает результат анализа

pack

кmsgpackКодирование записывает данные данные

1
Value Message.pack(Value data);

Параметры звонка:

  • data: Значение, учитывая данные для записи.

Результаты возврата:

  • Value, этот метод не возвращает данные

кmsgpackКодирование и анализ данных в сообщении

1
Value Message.pack();

Результаты возврата:

  • Value, возвращает результат анализа

end

Установить окончание обработки текущего сообщения,ChainПроцессор не продолжает выполнение последующих транзакций

1
Message.end();

isEnded

Запросить, закончилось ли текущее сообщение

1
Boolean Message.isEnded();

Результаты возврата:

  • Boolean, возвращает true по завершении

clear

Очистить содержимое сообщения

1
Message.clear();

sendTo

Отправляет форматированное сообщение данному объекту потока.

1
Message.sendTo(Stream stm) async;

Параметры звонка:

  • stm:Stream, указывает объект потока, который получает форматированное сообщение

readFrom

Считывает отформатированное сообщение из заданного объекта потока кэша и анализирует заполненный объект.

1
Message.readFrom(Stream stm) async;

Параметры звонка:

  • stm:Stream, указывает объект потока для чтения форматированных сообщений

toString

Возвращает строковое представление объекта. Обычно возвращается «[Native Object]». Объект может быть повторно реализован в соответствии с его собственными характеристиками.

1
String Message.toString();

Результаты возврата:

  • String, возвращает строковое представление объекта

toJSON

Возвращает представление объекта в формате JSON, обычно возвращая коллекцию читаемых свойств, определенных объектом.

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

Параметры звонка:

  • key: Строка, не используется.

Результаты возврата:

  • Value, возвращает значение, содержащее сериализуемый JSON