Асинхронное событие

Компонент внутреннего асинхронного вызова событий в процессе

Какую проблему решает:

• Ускоряет производительность обработки услуг. Предоставляет возможность публикации событий и асинхронной обработки на уровне процесса.
• Децентрализация сервисов. Наблюдатель и издатель не мешают друг другу, что позволяет децентрализовать отношения между ними.
• Ориентировано на события. Предоставляет отношение одного ко многим объектам.
• Конечная согласованность. Низкая задержка, конечная согласованность.

Производственные данные:

• Оптимизация службы с использованием компонента асинхронных событий [до]:
• TPS -> 2000, TP90 -> 100мс, TP99 -> 120мс
• Оптимизация службы с использованием компонента асинхронных событий [после]:
• TPS -> 2000, TP90 -> 20мс, TP99 -> 30мс

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

Пример использования:

// Создание экземпляра шины событий, использование памяти как канала
final EventBus eventBus = new EventBus(new MemoryChannel(1024));
// Регистрация потребителей
eventBus.register(new ListenerSub());
eventBus.register(new BothSub());
// Запуск шины событий
eventBus.start();

// Отправка сообщений событий (необходимо запустить перед отправкой)
eventBus.publish(new SimpleEvent());
eventBus.publish(new EventAny());
eventBus.publish(new EventA());
// Остановка шины событий
eventBus.stop();
```## Разработка плана

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