Business Event Framework

Question

Я создаю сайт для социальных сетей. Я ищу легко масштабируемая среда с открытым исходным кодом для обработки событий.

например, когда пользователь выполняет какие-либо действия на веб-сайте, он вызывает событие определенного типа для бэкэнда. Ряд слушателей будет ждать для этого типа события, и как только те, кто слушает событие, они будут делать некоторая логика приложения для этого события, например отправка сообщений электронной почты / смс, или интеллектуального анализа данных или запустить лампочку .. буквально что-нибудь.

Кто-нибудь знает такие рамки? Дайте мне знать, если я не достаточно ясно.

Спасибо, Nilesh

Answer 1

Посмотрите на структуру аксона .

Axon Framework помогает создавать масштабируемые, расширяемые и обслуживаемые приложения при поддержке разработчиков применяют командный запрос Архитектурный шаблон сегрегации ответственности (CQRS). Это делает это обеспечение реализации наиболее важных строительных блоков, таких как в качестве агрегатов, репозиториев и шин событий (механизм диспетчеризации для событий). Кроме того, Axon обеспечивает поддержку аннотаций, которые позволяет создавать агрегаты и прослушиватели событий, не привязывая код для аксона конкретной логики. Это позволяет вам сосредоточиться на своем бизнесе логика, а не сантехника, и помогает вам сделать ваш код проще проверить в изоляции.

Answer 2

JMS обеспечивает это. Отправьте сообщение в тему, и все слушатели этой темы получат сообщение.

Доступно несколько бесплатных реализаций (ActiveMQ, JBoss Messaging и т. Д.)

Answer 3

Может Hazelcast интересен для вас, например, он предлагает распределенные прослушиватели и события среди других интересных функций для распределенных приложений, таких как распределенные карты, блокировки, распределенная тема для обмена сообщениями публикации / подписки и т. Д..

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