Объектчейн

Объект обработки цепочки обработчиков сообщений

Объект Chain — это объект обработки цепочки процессоров сообщений в fibjs, который используется для связывания ряда процессоров сообщений и их обработки в указанном порядке. Метод создания объекта Chain следующий:

1
2
3
var chain = new mq.Chain([
   func1, func2
]);

В этом методе создания и func1, и func2 являются функциональными объектами процессора сообщений. Объект Chain связывает эти процессоры вместе, образуя цепочку процессоров. При обработке каждого сообщения процессор может выполнить индивидуальную обработку сообщения, а затем передать сообщение следующему процессору для обработки. Таким образом, сообщение может быть обработано шаг за шагом до конечного состояния.

Функция вызова() объекта Chain используется для обработки сообщения или объекта. При вызове этой функции объект Chain передает сообщение или объект каждому процессору по очереди, обрабатывая его в порядке процессоров, пока все процессоры не обработают его. Во время этого процесса каждый процессор может выполнить индивидуальную обработку сообщения или объекта или передать сообщение или объект для обработки следующему процессору.

В практических приложениях объекты Chain могут применяться к различным сценариям. Например, в веб-инфраструктуре сообщения запроса могут передаваться каждому процессору последовательно для обработки; в очереди сообщений пакет сообщений может быть передан каждому процессору в последовательность для обработки. Использование объектов Chain очень гибко и может быть настроено в соответствии с реальными потребностями.

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

Конструктор

Chain

Создайте объект обработки цепочки обработчиков сообщений.

1
new Chain(Array hdlrs);

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

• hdlrs: Массив, массив процессоров

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

append

Добавить массив процессоров

1
Chain.append(Array hdlrs);

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

• hdlrs: Массив, массив процессоров

---

Добавить процессор

1
Chain.append(Handler hdlr);

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

• hdlr:Handler, встроенный процессор сообщений, функция обработки, массив обработки цепочек, объект маршрутизации, подробнее см.mq.Handler

---

invoke

Обработать сообщение или объект

1
Handler Chain.invoke(object v) async;

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

• v:object, укажите сообщение или объект для обработки

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

• Handler, возврат к следующему процессору

---

toString

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

1
String Chain.toString();

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

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

---

toJSON

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

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

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

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

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

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