Балансировка запросов к роутерам через Java-коннектор¶
В примере демонстрируется работа с повреждённым кластером под нагрузкой.
Приложение непрерывно записывает кортежи пачками через все роутеры по очереди.
Для записи используется операция replace
.
Если какой-либо роутер упал, трафик с него переключается на остальные роутеры.
Если роутер поднялся, трафик на него возвращается.
Для мониторинга используются:
Примечание
Пример стенда с Prometheus приведен в разделе Балансировщик запросов к роутерам через Go-коннектор.
Содержание:
Пререквизиты¶
Для выполнения примера требуются:
установленные Docker-образы Tarantool DB, Prometheus и Grafana;
приложение Docker Compose;
Maven;
Java версии 8+;
конфигурация Maven – для загрузки Java-коннектора. Чтобы задать эту конфигурацию, используйте инструкцию Установка клиента tarantool-java-ee;
исходные файлы примера
java_balancer
.Примечание
Есть два способа получить исходные файлы примера:
Архив с полной документацией Tarantool DB, полученный по почте или скачанный в личном кабинете tarantool.io. Пример архива:
tarantooldb-documentation-2.0.0.tar.gz
. Примерjava_balancer
расположен в таком архиве в директории./doc/examples/java_balancer/
.Отдельный архив java_balancer.tar.gz, скачанный c сайта Tarantool.
Запуск стенда¶
Для успешного запуска должны быть свободны следующие порты:
3301–3306
3000
8081
Перейдите в директорию java_balancer
:
cd ./doc/examples/java_balancer
Стенд состоит из:
кластера Tarantool DB:
2 роутера;
2 набора реплик по 2 хранилища;
1 Tarantool Cluster Manager (TCM);
кластера etcd из 3 узлов;
клиентского приложения, подающего нагрузку;
средств мониторинга – Telegraf, InfluxDB, Grafana.
Запустите всё, кроме клиентского приложения, командой:
make start
После запуска должны работать все контейнеры, кроме init_host. Также после запуска доступны следующие пользовательские интерфейсы:
http://localhost:8081 – веб-интерфейс TCM;
http://localhost:3000 – веб-интерфейс Grafana.
Для входа в веб-интерфейс TCM откройте в браузере адрес http://localhost:8081. Логин и пароль для входа:
Username:
admin
Password:
secret
В TCM откройте вкладку Stateboard.
Выберите в наборе реплик router-msk
узел router-msk
и в открывшемся окне перейдите на вкладку Terminal.
Во вкладке Terminal проверьте наличие спейса test
:
box.space
Спейс test
должен присутствовать в выводе, он создается при запуске кластера.
Панель Grafana¶
Откройте в браузере веб-интерфейс Grafana по адресу http://localhost:3000/dashboards. В списке Dashboards откройте папку General и выберите панель Tarantool 3 dashboard в выпадающем списке. Проверьте, что графики показывают данные за последние 5 минут, а частота обновления равна 5 секундам:
Разверните панель Tarantool network activity и откройте график Processed requests. Чтобы развернуть график на полный экран, нажмите на графике кнопку … (Menu) в правом верхнем углу и нажмите в выпадающем меню кнопку View. Выберите роутеры на графике, используя один из способов ниже:
Нажмите на название
router-msk
и, зажавShift
, нажмите наrouter-spb
.Используйте переключатель сверху (Instances), чтобы выбрать роутеры на уровне всего дашборда.
После перейдите на панель Tarantool operations statistics и откройте график REPLACE space requests. Выберите все узлы, кроме роутеров:
Увеличение нагрузки¶
Откройте вторую вкладку локального терминала.
В этой вкладке перейдите в директорию java_balancer
:
cd ./doc/examples/java_balancer
Запустите клиентское приложение:
mvn clean compile
mvn exec:java -Dexec.mainClass="org.example.App"
На графиках теперь заметна растущая нагрузка:
растет число обработанных запросов на роутерах:
растет число операций
replace
в единицу времени:
Проверьте, что в спейсе test
появились данные.
Для этого в веб-интерфейсе TCM перейдите на вкладку Tuples и выберите в списке спейс test
.
Откроется новая вкладка с содержимым кортежей спейса test
.
Имитация отказа роутера¶
В первом терминале перейдите в директорию cluster
:
cd cluster
Чтобы имитировать отказ роутера, выполните следующую команду:
docker compose stop tarantool-router-msk
Теперь в TCM во вкладке Stateboard узел router-msk
отмечен серым – это значит, что он отключен.
График запросов изменится так:
Нагрузка на второй роутер увеличилась вдвое. График для второго роутера выглядит так:
Роста нагрузки на этом графике нет.
График прерывается, так как роутер не работает и метрики с него не поступают.
Количество операций replace
при этом не изменилось:
Восстановление роутера¶
Для запуска первого роутера выполните следующую команду в директории cluster
:
docker compose start tarantool-router-msk
В TCM во вкладке Stateboard видно, что узел router-msk
восстановлен.
Нагрузка на второй роутер уменьшилась вдвое, появились данные по нагрузке с первого:
Число операций replace
не изменилось:
Остановка стенда¶
Для остановки стенда:
В первом локальном терминале вернитесь в директорию
java_balancer
:cd ./doc/examples/java_balancer
Выполните следующую команду:
make stop
Во втором локальном терминале выполните команду
Ctrl + Z
.