Перейти к содержимому

Исходный код вики Механизмы

Версия 1.4 от Alexandr Fokin на 2022/11/27 23:15
Скрыть последних авторов
Alexandr Fokin 1.1 1 |(% colspan="2" style="width:196px" %)**Механизмы**
Alexandr Fokin 1.4 2 |(% style="width:323px" %)Транзакции|(% style="width:1170px" %)Брокер допускает использование транзакций, а именно чтение группы сообщение/отправки сообщений в рамках одной транзакции.
Alexandr Fokin 1.1 3 При этом, если транзакция будет прервана по середине, то все сообщение, прочитанные в рамках этой транзакции, будут снова доступны для прочтения (не будут удалены).
Alexandr Fokin 1.4 4 |(% style="width:323px" %)Хранилище сообщение.
5 Message store|(% style="width:1170px" %)В качестве хранилища может выступать как файловая система, так и сторонние реализации провайдеров хранилища (в том числе и базы данных).
Alexandr Fokin 1.1 6 Допустимо использование топологии, когда к одному хранилищу могут быть подключены пара брокеров, причем один будет активным, а второй резервным и будет активирован и при выходе из строя первого.
Alexandr Fokin 1.4 7 |(% style="width:323px" %)Механизм подтверждения получения. Acknowledgement mode|(% style="width:1170px" %)(((
8 Параметр, отвечающий за подтверждение получения сообщения: "AcknowledgementMode"
9 [[https:~~/~~/activemq.apache.org/components/nms/msdoc/1.6.0/vs2005/Output/html/T_Apache_NMS_AcknowledgementMode.htm>>url:https://activemq.apache.org/components/nms/msdoc/1.6.0/vs2005/Output/html/T_Apache_NMS_AcknowledgementMode.htm]]
10
11 Параметр может быть задан на уровне
12 IConnection и ISession
13
14 По умолчанию данный параметр установлен в "AutoAcknowledge".
15 Сообщения автоматически подтверждаются при поступлении к consumer.
16
17 Для использования модели:
18 (Получение -> Обработка -> Подтверждение)
19 необходимо выбрать режим "ClientAcknowledge" и использовать метод message.Acknowledge()
20 )))
21 |(% style="width:323px" %)Selector.
22 Выборка сообщений из очереди по условию.|(% style="width:1170px" %)Selectors
Alexandr Fokin 1.2 23 [[https:~~/~~/activemq.apache.org/selectors>>https://activemq.apache.org/selectors]]
Alexandr Fokin 1.4 24 |(% style="width:323px" %)Задержка отправки.
25 Delayed delivery|(% style="width:1170px" %){{code language="c#"}}message.Properties["AMQ_SCHEDULED_DELAY"] = timeDelay; //NeedType: int ms{{/code}}
Alexandr Fokin 1.1 26
Alexandr Fokin 1.3 27 ----
28
29
Alexandr Fokin 1.1 30 |(% colspan="2" style="width:196px" %)**Свойства**
31 |(% style="width:196px" %)Durability|(% style="width:1267px" %)Свойство обозначающее, что сообщение сохраниться даже если нет ни одного подключенного потребителя.
32 Можно сказать, что Queue обладает свойством Durability, а Topic нет.
33 |(% style="width:196px" %)Persistence|(% style="width:1267px" %)Свойство обозначающее, что сообщение не будет потеряно в случае перезагрузки брокера (отчистки оперативной памяти).
34 Подразумевает, что все сообщения будут сохранены в определенное хранилище - Message store