Главная

/

Шина данных (ESB)

Сервис событий

Шина данных для мгновенного обмена информации между любыми ИТ-системами.

Стоимость ПО “Сервис Событий” - 490 000 рублей.

Высокая производительность

Шина способна доставлять десятки тысяч сообщений в секунду

Интеграция с 1С

Синхронизация любой версии 1С с требуемыми информационными системами

Масштабируемость

Позволяет масштабировать бизнес и снимает технические ограничения

Удобство в управлении

Наличие интерфейса для администрирования, настройки, диагностики и обработки сообщений

Проблемы передачи данных в интернет-торговле

Некорректное отображение наличия товаров

Между учетной системой и онлайн-магазином информация передается с ошибками и опозданием. Это приводит к финансовым потерям, а также негативно влияет на репутацию

Ошибки в сроках доставки

Отклонения в сроках доставки связаны с некорректной синхронизацией информации между системой склада и интернет-магазином

Расхождение в финансовых данных

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

Потеря оформленных заказов

Ошибки при передаче оформленного заказа из интернет-магазина на склад. Данные о заказе могут теряться при высоких нагрузках на систему и не доходить до склада, соответственно не поступать в сборку, что приводит к репутационным издержкам и падению продаж

Эффекты от внедрения «Сервиса событий»

Стабильность передачи данных

Гарантированная передача данных между ИТ-системами в требуемом порядке

Высокая производительность

Автоматизация ручных операций и оптимизация бизнес-процессов

Интеграция с внешними сервисами

Интеграция с различными внешними сервисами, например, платежными системами, доставкой, ЭДО и другими

Каталог готовых решений

Доступ к библиотеке готовых компонентов, модулей и коннекторов

Гибкость развертывания

Вариативность развертывания, включая запуск в контейнерах и на виртуальных машинах

Выгоды от внедрения «Сервиса событий»

Быстрый старт

Для запуска сервиса не требуются специализированные ИТ-компетенции

Экономия на ресурсах

Настройка коммуникаций и обмена данными между системами без участия разработчиков

Мониторинг системы

Своевременное получение информации об инцидентах в системе и ведение отчетности в простом и удобном интерфейсе

Масштабируемость системы

Снятие технических ограничений, способствующее масштабированию бизнеса

Экосистема разработчиков

Возможность взаимодействия с внешними разработчиками для расширения функциональности платформы

Новые тренды в электронной коммерции. Топ-5 инструментов для развития бизнеса

Персональная эксперт-сессия

«Сервис событий» для стратегического развития

Позволяет увеличить темп цифровизации компании

Способствует масштабированию ИТ-инфраструктуры

Увеличивает количество метрик для анализа бизнеса

Помогает разрабатывать новые цифровые сервисы

Снижает расходы на ИТ

Ускоряет процесс вывода продуктов на рынок

Новые тренды в электронной коммерции. Топ-5 инструментов для развития бизнеса

Персональная эксперт-сессия

Технологический Стек

Общая архитектура сервиса

1

Шина данных — точка обмена для всех сервисов. Принимает сообщения в формате json по https-протоколу.

2

При получении сообщения от паблишера оно помещается в очередь брокера сообщений.

3

Если доставить сообщения кому-то из адресатов невозможно, сервис повторяет отправку через определенный интервал времени.

4

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

Сервис №1

Сервис событий

Публикация

Очередь

Публикация

Сервис №2

Сервис №3

Синхронный режим работы

Сервис ждет обработку события от подписчика и после переходит к следующему сообщению

Асинхронный режим работы

Сервис не ожидает обработки события от подписчика, переходя сразу к следующему сообщению

Функциональные характеристики

Использование защищенного транспорта для обмена сообщениями

Ведение статистики и истории обмена сообщениями

Масштабируемость транспортной системы и маршрутизация сообщений

Возможность расширения списка и типов
используемых «каналов» путем подключения микросервисов

Снижение транзакционных издержек при обмене данными между различными подразделениями

Гарантированная доставка сообщений

Предоставление метрик о работоспособности приложения

Синхронный
и асинхронный режим обмена сообщениями

Наличие web-интерфейса для администрирования, настройки,
диагностики и отладки работы шины

Развертывание системы обмена данными
на транспортном уровне и на уровне бизнес-логики

Административная панель

В приложение был добавлен функционал для администрирования проекта: сбор статистики сообщений, предоставление метрик о работоспособности приложения.

Сбор статистики сообщений

Данная страница предоставляет информацию об обработке сообщений шиной данных.

Требования для установки и эксплуатации

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

Используемые технологии:

Язык программирования Java 11. Программы на Java транслируются в байт-код, который затем выполняется виртуальной машиной Java (JVM). JVM — это программа, которая обрабатывает байтовый код и передает инструкции оборудованию как интерпретатор. Достоинством подобной реализации является независимость байт-кода от операционной системы и оборудования, что позволяет выполнять Java-приложения на любом устройстве, для которого существует JVM. Другой важной особенностью технологии Java является гибкая система безопасности благодаря тому, что исполнение программы полностью контролируется виртуальной машиной. Любые операции, которые превышают установленные полномочия программы (например, попытка несанкционированного доступа к данным или соединения с другим компьютером) вызывают немедленное прерывание.

Spring Boot

Это полезный проект, целью которого является упрощение создания приложений на основе фрайморка Spring. Обладает большим функционалом, но его наиболее значимыми особенностями являются: управление зависимостями, автоматическая конфигурация и встроенные контейнеры сервлетов.

Spring Data

Дополнительный удобный механизм для взаимодействия с сущностями базы данных, организации их в репозитории, извлечение данных, изменение.

Spring Email

Предоставляет вам API чтобы отправлять email.

Spring Security

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

PostgreSQL

Свободная объектно-реляционная система управления базами данных (СУБД).

Liquibase

Независимая от базы данных библиотека для отслеживания, управления и применения изменений схемы базы данных.

RabbitMQ

Программный брокер сообщений на основе стандарта AMQP. Его основная цель ‒ принимать и отдавать сообщения. Его можно представлять себе, как почтовое отделение: когда Вы бросаете письмо в ящик, Вы можете быть уверены, что рано или поздно почтальон доставит его адресату. В этой аналогии RabbitMQ является одновременно и почтовым ящиком, и почтовым отделением, и почтальоном.

Elasticsearch

Это одна из самых популярных поисковых систем в области Big Data, масштабируемое нереляционное хранилище данных с открытым исходным кодом, аналитическая NoSQL-СУБД с широким набором функций полнотекстового поиска.

Quartz

Это фреймворк планирования заданий с открытым исходным кодом.

Guava Cache

Выполняет локальное кеширование данных.

Apache POI

API, который позволяет программистам создавать, изменять и отображать файлы MS Office с помощью программ Java.

Требования к среде:

Рекомендуемые системные требования для корректной работы сервиса событий:

Linux

Операционная система

2x2,00 ГГц

Процессор

4 Гб

Объём оперативной памяти

Docker

Установленный на сервере

Инструкция по эксплуатации

События

Событие – сущность связующая источник и приемник данных внутри шины данных, с настроенными параметрами.

Создание нового события
Поиск – поиск по # и наименованию (по совместному ключу)
# - уникальный id события
Подписчики – кол-во подписчиков у этого события (кому уходит событие из СС)
Описание – описание сути события
Редактирование (карандаш) – кнопка для перехода на страницу редактирования события
Очистить все публикации события (белая корзина) – удаляет все публикации по этому событию, хранящиеся в базе
Удалить событие (черная корзина) – удаляет событие

Создание события

Основное

Уникальный код события – уникальный идентификатор события для определения и взаимосвязи при передачи данных
Наименование – название события
Описание – описание сути события
Сохранить – принятие параметров и создание события
Наименование – название события
Назад – переход к списку событий

Поиск и индексация:

Добавить – добавление поля из структуры тела события для возможности поиска в публикациях (ключ в формате JSON)

Подписчики

Подписчики – сущности приема события из шины данных (у одного события их может быть несколько).

Добавить – добавление нового подписчика
Поиск - поиск по # и наименованию (по совместному ключу)
Метод – метод доступа по HTTP стандарту
Адрес – URL адрес получения публикации
URL асинхронного режима – URL адрес получения публикации в асинхронном режиме
Асинхронный режим – включен ли асинхронный режим у подписчика
Редактирование(карандаш черный) – редактирование подписчика
Удалить – удаление подписчика

Создание подписчика

Событие – событие, которое отправляется подписчику
Сервис – подключенный сервис на который уходит событие
Метод – метод доступа по HTTP стандарту
URL – URL адрес получения события
Доставка публикаций:

Активность – включение доставки публикации подписчику
Получать собственные публикации – включение возможности получения публикации внутри одного сервиса (сервис сам отправляет себе публикацию)

Асинхронность:

Асинхронный режим – включение асинхронного режима (до 10 параллельных процессов возможно)
URL асинхронного режима – адрес, где обрабатываются события при наличии очереди на обработку событий

Заголовки (данные формата ключ-значение для получения доступа к сервису для принятия им публикации):

Ключ – ключ при отправке для проверки сервисом
Значение – значение при отправке для проверки сервисом
Удалить – удаление заголовка

Дополнительные параметры – идентично заголовкам, возможные дополнительные параметры необходимые для принятия сервисом, также в формате ключ-значение
Сохранить – принятие параметров и сохранение подписчика
Назад – возвращение к списку подписчиков

Публикации

Публикации – данные принимаемые и отправляемые шиной данных по заданным параметрам (собственно то для чего существует шина).

Добавить – добавление публикации
Фильтр – параметры для сортировки по списку публикаций:

Событие – наименование события
Дата создания с – дата создания начало поиска
Время – время создания начало поиска
Дата создания по – дата создания конец поиска
Время – время создания конец поиска
Ключ связи – связь между подписчиком и сервисом, при наличии
Подписчик – какому подписчику адресовано
Сервис – сервис отправки
Состояние:

Любая
Добавлена
Переопубликация (при нажати повторная публикация, только администратор)
Запущен
Выполнена
Ошибка (до 3х ошибок, после переопубликация)

Расширенный поиск по событию – дополнительные параметры для фильтрации (задаются при создании события в разделе «поиск и индексация»
Применить – применение введенных параметров фильтра
Очистить – удаление параметров фильтрации

Тело публикации:

Номер и дата/время публикации
Сервис отправки
Наименование события
URL сервиса получения
Содержание в формате JSON
Состояние

У администратора есть возможность редактирования и создания публикации (отправка принудительно из шины данных).

Настройки

Сервисы – подключение новых сервисов к шине данных.

Добавить – создание нового подключения сервиса
Поиск - поиск по # и имени (по совместному ключу)
Акт. – активен ли сервис
Описание – описание сервиса
Токен – токен для подключения к сервису для передачи публикации
Url статуса работы задачи – для механизма отслеживания выполнения событий в асинхронном режиме
Редактирование (карандаш черный) – редактирование параметров сервиса
Удалить – удаление сервиса