Изменения документа Apache Active MQ

Сводка

• Свойства страницы (1 изменено, 0 добавлено, 0 удалено)

Подробности

Свойства страницы

Содержимое

...	...	@@ -1,33 +1,40 @@
	1	+**Компоненты:**
1	1
2		-Документация:
3		-https://activemq.apache.org/components/nms/msdoc/1.6.0/vs2005/Output/html/N_Apache_NMS.htm
	3	+* Producer - производитель сообщений.
	4	+* Consumer - потребитель сообщений.
	5	+* Queues - Очередь сообщений.
	6	+В очередь могут писать несколько производителей.
	7	+Очередь могут читать несколько потребителей одновременно, при сообщения будут распределяться между ними (а не дублироваться).
	8	+После подтверждения прочтения сообщение удаляется из очереди.
	9	+* Topics - Топик выполняет функцию широковещательного канала.
	10	+Топик не хранит сообщения, а распространяет отправленное в него сообщение на всех подключенных к нему потребителей.
4	4
5	5
6		-Основные объекты взаимодействия:
	13	+В рамках брокера используются следующие термины:
7	7
8		-1) IConnection
9		-connection.Start()
	15	+* Durability - свойство обозначающее, что сообщение сохраниться даже если нет ни одного подключенного потребителя.
	16	+Можно сказать, что Queue обладает свойством Durability, а Topic нет.
	17	+* Persistence - свойство обозначающее, что сообщение не будет потеряно в случае перезагрузки брокера (отчистки оперативной памяти).
	18	+Подразумевает, что все сообщения будут сохранены в определенное хранилище - Message store.
	19	+* Message store - хранилище сообщение.
	20	+В качестве хранилища может выступать как файловая система, так и сторонние реализации провайдеров хранилища (в том числе и базы данных).
	21	+Допустимо использование топологии, когда к одному хранилищу могут быть подключены пара брокеров, причем один будет активным, а второй резервным и будет активирован и при выходе из строя первого.
10	10
11		-2) ISession
12		-connection.CreateSession()
13	13
14		-3) IQueuq
15		-session.GetQueue(name)
	24	+Брокер допускает использование транзакций, а именно чтение группы сообщение/отправки сообщений в рамках одной транзакции.
	25	+При этом, если транзакция будет прервана по середине, то все сообщение, прочитанные в рамках этой транзакции, будут снова доступны для прочтения (не будут удалены).
16	16
17		-4.1) IMessageProducer
18		-session.CreateProducer(session)
19	19
20		-4.2) IMessageConsumer
21		-session.CreateConsumer(
22		- session,
23		- selector,
24		- false
25		- )
	28	+**Материалы:**
26	26
27		-Клиент:
28		-https://www.nuget.org/packages/Apache.NMS.ActiveMQ/ provides OpenWire
29		-https://www.nuget.org/packages/Apache.NMS.AMQP/ provides AMQP
	30	+Понимание брокеров сообщений. Изучение механики обмена сообщениями посредством ActiveMQ и Kafka. Глава 2. ActiveMQ
	31	+https://habr.com/ru/post/471268/
30	30
31		-Материалы:
32		-[[Выборка сообщений из очереди по условию. Selector>>https://activemq.apache.org/selectors]]
	33	+Документация:
	34	+https://activemq.apache.org/components/nms/msdoc/1.6.0/vs2005/Output/html/N_Apache_NMS.htm
33	33
	36	+Selector. Выборка сообщений из очереди по условию.
	37	+https://activemq.apache.org/selectors
	38	+
	39	+Message Groups. JMSXGroupID
	40	+https://activemq.apache.org/message-groups