Сообщение объекта
Основной объект сообщения
Объект Message совместим с каждым модулем mq и может использоваться для создания собственной системы обработки сообщений. Метод создания:
1
2var mq = require("mq");
var m = new mq.Message();
Наследование
Конструктор
Message
Конструктор объекта сообщения
1new Message();
постоянный
TEXT
Укажите тип сообщения 1, который представляет тип текста
1const Message.TEXT = 1;
BINARY
Укажите тип сообщения 2, который представляет двоичный тип
1const Message.BINARY = 2;
Атрибуты члена
value
Строка, основное содержание сообщения
1String Message.value;
params
NArray, основные параметры сообщения
1readonly NArray Message.params;
type
Целое число, тип сообщения
1Integer Message.type;
data
Значение, запросить данные сообщения
1readonly Value Message.data;
body
SeekableStream , объект потока, содержащий часть сообщения с данными.
1SeekableStream Message.body;
length
Long, длина части данных сообщения
1readonly Long Message.length;
stream
Stream , объект потока при запросе сообщения readFrom
1readonly Stream Message.stream;
lastError
Строка, запрос и установка последней ошибки обработки сообщения
1String Message.lastError;
Функция члена
read
Считывать данные указанного размера из потока, этот метод является псевдонимом соответствующего метода тела
1Buffer Message.read(Integer bytes = -1) async;
Параметры звонка:
- bytes : целое число, укажите количество данных для чтения, по умолчанию считываются блоки данных произвольного размера, размер считываемых данных зависит от устройства
Результат возврата:
- Buffer , возвращает данные, прочитанные из потока, если нет данных для чтения или соединение прервано, возвращает null
readAll
Прочитать все оставшиеся данные из потока, этот метод является псевдонимом соответствующего метода тела
1Buffer Message.readAll() async;
Результат возврата:
- Buffer , возвращает данные, прочитанные из потока, если нет данных для чтения или соединение прервано, возвращает null
write
Запишите указанные данные, этот метод является псевдонимом соответствующего метода тела
1Message.write(Buffer data) async;
Параметры звонка:
- data : Buffer , в который записываются данные
json
Запишите данные в кодировке JSON
1Value Message.json(Value data);
Параметры звонка:
- data : Значение, заданное для записываемых данных
Результат возврата:
- Value , этот метод не вернет данные
Анализируйте данные в сообщении в кодировке JSON
1Value Message.json();
Результат возврата:
- Value , возвращает проанализированный результат
end
Установите текущую обработку сообщения на завершение, и процессор Chain не будет продолжать последующие транзакции.
1Message.end();
isEnded
Запросить, закончилось ли текущее сообщение
1Boolean Message.isEnded();
Результат возврата:
- Boolean , в конце вернуть true
clear
Очистить содержание сообщения
1Message.clear();
sendTo
Отправить отформатированное сообщение заданному объекту потока
1Message.sendTo(Stream stm) async;
Параметры звонка:
- stm : Stream , указывает объект потока, который получает форматированные сообщения
readFrom
Прочтите отформатированное сообщение из данного объекта потока кэша и проанализируйте объект заполнения
1Message.readFrom(Stream stm) async;
Параметры звонка:
- stm : Stream , указывает объект потока для чтения форматированных сообщений
toString
Возвращает строковое представление объекта, обычно возвращает «[Native Object]», объект может быть повторно реализован в соответствии с его собственными характеристиками.
1String Message.toString();
Результат возврата:
- String , возвращает строковое представление объекта
toJSON
Возвращает представление объекта в формате JSON, обычно возвращает набор читаемых атрибутов, определенных объектом.
1Value Message.toJSON(String key = "");
Параметры звонка:
- key : строка, не используется
Результат возврата:
- Value , возвращает значение, содержащее сериализуемый JSON