Балансировка запросов к роутерам через 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:
adminPassword:
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.