Конвейер обработки сообщений для потоков - RU2004108867A

Реферат

1. Способ обработки сообщений в системе обмена сообщениями с буфером заданного размера для отправки и приема сообщений через одно или более средств передачи сообщений, который снижает требования к буферу для по меньшей мере части сообщения, тем самым позволяя системе обмена сообщениями посылать или принимать относительно большие сообщения с помощью буфера заданного размера, содержащий следующие операции: определение одного или более обработчиков сообщений, каждый из которых идентифицирует соответствующую операцию обработки для выполнения над объектом сообщения, который содержит по меньшей мере поточную часть с ориентированным на поток интерфейсом; идентифицирование и упорядочивание одного или более обработчиков сообщений для включения в конфигурируемый конвейер сообщений; и вызов одного или более обработчиков сообщений конвейера сообщений для обработки объекта сообщения, при этом по меньшей мере один обработчик сообщений заключает в оболочку по меньшей мере одну поточную часть объекта сообщения соответствующей операцией обработки, которая подлежит выполнению в будущем, без того, чтобы материализовать в буфере эту по меньшей мере одну поточную часть объекта сообщения.

2. Способ по п.1, по которому конвейер содержит множество обработчиков сообщений и каждый из этого множества обработчиков сообщений последовательно заключает в оболочку по меньшей мере одну поточную часть объекта сообщения соответствующей операцией обработки, так что множество операций обработки наслаивается на эту по меньшей мере одну поточную часть объекта сообщения.

3. Способ по п.1, по которому объект сообщения содержит одну или более частей заголовков и по меньшей мере одну корпусную часть, а корпусная часть содержит по меньшей мере одну поточную часть объекта сообщения.

4. Способ по п.3, по которому объект сообщения содержит объект сообщения простого протокола доступа к объекту (SOAP).

5. Способ по п.4, по которому система обмена сообщениями представляет собой промежуточный пункт, ответственный за маршрутизацию объекта сообщения.

6. Способ по п.5, по которому промежуточный пункт материализует по меньшей мере один заголовок для маршрутизации сообщения без необходимости материализовать по меньшей мере одну поточную часть объекта сообщения.

7. Способ по п.1, по которому система обмена сообщениями представляет собой конечный пункт, а способ также содержит операцию записи объекта сообщения в поток переноса сообщений, при этом операция записи объекта сообщения в поток переноса заставляет выполняться по меньшей мере одну операцию обработки над по меньшей мере одной поточной частью объекта сообщения.

8. Способ по п.1, по которому система обмена сообщениями содержит потребителя сообщений, а способ содержит также операцию материализации потребителем сообщений по запросу по меньшей мере одной поточной части объекта сообщения.

9. Способ по п.1, который также содержит операцию создания определения объекта сообщения для объекта сообщения, причем определение объекта сообщения определяет по меньшей мере одну поточную часть и соответствующий ориентированный на поток интерфейс для объекта сообщения.

10. Способ по п.1, по которому определяют множество конвейеров сообщений, а способ также содержит операцию вызова одного или более обработчиков сообщений каждого конвейера сообщений для обработки объекта сообщения.

11. Способ по п.10, по которому по меньшей мере один из конвейеров сообщений вкладывается в другой конвейер сообщений.

12. Компьютерный программный продукт для системы обмена сообщениями с буфером заданного размера для отправки и приема сообщений через одно или более средств передачи сообщений, содержащий один или более машинно-читаемых носителей данных, несущих исполняемые компьютером команды, которые воплощают способ обработки сообщений, который снижает требования к буферу для по меньшей мере части сообщения, тем самым позволяя системе обмена сообщениями посылать или принимать относительно большие сообщения с помощью буфера заданного размера, содержащий следующие операции: определение одного или более обработчиков сообщений, каждый из которых идентифицирует соответствующую операцию обработки для выполнения над объектом сообщения, который содержит по меньшей мере поточную часть с ориентированным на поток интерфейсом; идентифицирование и упорядочивание одного или более обработчиков сообщений для включения в конфигурируемый конвейер сообщений; и вызов одного или более обработчиков сообщений конвейера сообщений для обработки объекта сообщения, при этом по меньшей мере один обработчик сообщений заключает в оболочку по меньшей мере одну поточную часть объекта сообщения соответствующей операцией обработки, которая подлежит выполнению в будущем, без того, чтобы материализовать в буфере эту по меньшей мере одну поточную часть объекта сообщения.

13. Компьютерный программный продукт по п.12, в котором конвейер содержит множество обработчиков сообщений, и каждый из этого множества обработчиков сообщений последовательно заключает в оболочку по меньшей мере одну поточную часть объекта сообщения соответствующей операцией обработки, так что множество операций обработки наслаивается на эту по меньшей мере одну поточную часть объекта сообщения.

14. Компьютерный программный продукт по п.12, в котором объект сообщения содержит одну или более прикрепленных частей.

15. Компьютерный программный продукт по п.12, в котором вызов одного или более обработчиков сообщений конвейера сообщений происходит до того, как назначается поток по меньшей мере одной поточной части объекта сообщения.

16. Компьютерный программный продукт по п.12, в котором система обмена сообщениями представляет собой конечный пункт, а способ также содержит операцию считывания объекта сообщения из потока переноса сообщений, при этом операция считывания объекта сообщения в поток переноса заставляет выполняться по меньшей мере одну операцию обработки над по меньшей мере одной поточной частью объекта сообщения.

17. Компьютерный программный продукт по п.12, в котором объект сообщения содержит одну или более непоточных частей, а способ также содержит операцию сохранения этих одной или более частей в буфере.

18. Компьютерный программный продукт по п.12, в котором система обмена сообщениями содержит потребителя сообщений, а способ содержит также операцию материализации потребителем сообщений по запросу по меньшей мере одной поточной части объекта сообщения.

19. Компьютерный программный продукт по п.12, в котором способ содержит также операцию записи объекта сообщения на множество средств переноса для доставки ко множеству конечных пунктов без того, чтобы материализовать в буфере по меньшей мере одну поточную часть объекта сообщения.

20. Компьютерный программный продукт по п.12, в котором определяется множество конвейеров сообщений, а способ также содержит операцию вызова одного или более обработчиков сообщений каждого конвейера сообщений для обработки объекта сообщения.

21. Способ обработки сообщений в системе обмена сообщениями с буфером заданного размера для отправки и приема сообщений через одно или более средств передачи сообщений, который снижает требования к буферу для по меньшей мере части сообщения, тем самым позволяя системе обмена сообщениями посылать или принимать относительно большие сообщения с помощью буфера заданного размера, содержащий следующие шаги: обеспечение одного или более обработчиков сообщений, каждый из которых идентифицирует соответствующую операцию обработки для выполнения над объектом сообщения, который содержит по меньшей мере одну поточную часть с ориентированным на поток интерфейсом; обеспечение конвейера сообщений, содержащего упорядоченную совокупность одного или более обработчиков сообщений; и обработка объекта сообщения одним или более обработчиками сообщения в конвейере сообщений, при этом по меньшей мере один обработчик сообщений инкапсулирует эту по меньшей мере одну поточную часть объекта сообщения соответствующей функцией ее обработки без того, чтобы материализовать в буфере по меньшей мере одну поточную часть объекта сообщения.

22. Способ по п.21, по которому шаг обеспечения конвейера сообщений содержит операции идентификации и упорядочения одного или более обработчиков сообщений.

23. Способ по п.21, по которому конвейер содержит множество обработчиков сообщений, и каждый из этого множества обработчиков сообщений последовательно заключает в оболочку по меньшей мере одну поточную часть объекта сообщения соответствующей операцией обработки, так что множество операций обработки наслаивается на эту по меньшей мере одну поточную часть объекта сообщения.

24. Способ по п.21, по которому объект сообщения содержит одну или более прикрепленных частей.

25. Способ по п.21, по которому вызов одного или более обработчиков сообщений конвейера сообщений происходит до того, как назначается поток по меньшей мере одной поточной части объекта сообщения.

26. Способ по п.21, по которому система обмена сообщениями представляет собой конечный пункт, а способ также содержит шаг приема объекта сообщения от другого конечного или промежуточного пункта, при этом шаг приема объекта сообщения заставляет выполняться по меньшей мере одну операцию обработки над по меньшей мере одной поточной частью объекта сообщения.

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

28. Способ по п.21, по которому система обмена сообщениями содержит потребителя сообщений, а способ содержит также операцию материализации потребителем сообщений по запросу по меньшей мере одной поточной части объекта сообщения.

29. Способ по п.21, который содержит также шаг дублирования объекта сообщения для доставки ко множеству конечных пунктов, без материализации объекта сообщения для доставки ко множеству конечных пунктов без того, чтобы материализовать в буфере по меньшей мере одну поточную часть объекта сообщения.

30. Способ по п.21, по которому предусматривается множество конвейеров сообщений, а способ содержит также шаг обработки объекта сообщения каждым из одного или более обработчиков сообщений каждого конвейера сообщений.

31. Компьютерный программный продукт для системы обмена сообщениями с буфером заданного размера для отправки и приема сообщений через одно или более средств передачи сообщений, содержащий один или более машинно-читаемых носителей данных, несущих исполняемые компьютером команды, которые воплощают способ обработки сообщений, который снижает требования к буферу для по меньшей мере части сообщения, тем самым позволяя системе обмена сообщениями посылать или принимать относительно большие сообщения с помощью буфера заданного размера, содержащий следующие шаги: обеспечение одного или более обработчиков сообщений, каждый из которых идентифицирует соответствующую операцию обработки для выполнения над объектом сообщения, который содержит по меньшей мере одну поточную часть с ориентированным на поток интерфейсом; обеспечение конвейера сообщений, содержащего упорядоченную совокупность одного или более обработчиков сообщений; и обработку объекта сообщения одним или более обработчиками сообщения в конвейере сообщений, при этом по меньшей мере один обработчик сообщений инкапсулирует эту по меньшей мере одну поточную часть объекта сообщения соответствующей функцией ее обработки без того, чтобы материализовать в буфере по меньшей мере одну поточную часть объекта сообщения.

32. Компьютерный программный продукт по п.31, в котором шаг обеспечения конвейера сообщений содержит операции идентифицирования и упорядочения одного или более обработчиков сообщений.

33. Компьютерный программный продукт по п.31, в котором конвейер содержит множество обработчиков сообщений и каждый из этого множества обработчиков сообщений последовательно заключает в оболочку по меньшей мере одну поточную часть объекта сообщения соответствующей операцией обработки, так что множество операций обработки наслаивается на эту по меньшей мере одну поточную часть объекта сообщения.

34. Компьютерный программный продукт по п.31, в котором объект сообщения содержит одну или более частей заголовков и по меньшей мере одну корпусную часть, а корпусная часть содержит по меньшей мере одну поточную часть объекта сообщения.

35. Компьютерный программный продукт по п.34, в котором объект сообщения содержит объект сообщения простого протокола доступа к объекту (SOAP).

36. Компьютерный программный продукт по п.35, в котором система обмена сообщениями представляет собой промежуточный пункт, ответственный за маршрутизацию объекта сообщения.

37. Компьютерный программный продукт по п.36, в котором промежуточный пункт материализует по меньшей мере один заголовок для маршрутизации сообщения без необходимости материализовать по меньшей мере одну поточную часть объекта сообщения.

38. Компьютерный программный продукт по п.31, в котором система обмена сообщениями представляет собой конечный пункт, а способ также содержит шаг отправки объекта сообщения к другому конечному пункту, при этом шаг отправки объекта сообщения заставляет выполняться по меньшей мере одну операцию обработки над по меньшей мере одной поточной частью объекта сообщения.

39. Компьютерный программный продукт по п.31, в котором система обмена сообщениями содержит потребителя сообщений, а способ содержит также операцию материализации потребителем сообщений по запросу по меньшей мере одной поточной части объекта сообщения.

40. Компьютерный программный продукт по п.31, который содержит также шаг конкретизации определения объекта сообщения для объекта сообщения, причем это определение объекта сообщения определяет по меньшей мере одну поточную часть и соответствующий ориентированный на поток интерфейс для объекта сообщения.

41. Компьютерный программный продукт по п.31, в котором предусматривается множество конвейеров сообщений, а способ также содержит шаг обработки объекта сообщения одним или более обработчиками сообщений каждого конвейера сообщений.

42. Компьютерный программный продукт по п.41, в котором по меньшей мере один из конвейеров сообщений вкладывается в другой конвейер сообщений.