- tocdepth
2
Подключение к инстансу DMS for RocketMQ
К инстансу Distributed Message Service for RocketMQ можно подключиться с SSL и без него.
Подключение внутри VPC и публичный доступ различаются IP-адресами и портами. Для подключения внутри VPC используется порт 8100. Для публичного доступа — порт 8200.
В этих инструкциях описана настройка публичного доступа к инстансу DMS for RocketMQ.
Перед началом работы
-
Для подключения внутри сети VPC настройки VPC, подсети и группы безопасности ВМ и инстанса DMS for RocketMQ должны быть одинаковыми.
Установлен JDK версии 1.8.111 и выше и настроены переменные.
Подключение без SSL
Скачайте тестовый брокер:
wget https://dms-demo.obs.ru-moscow-1.hc.sbercloud.ru/rocketmq-tutorial.zip
Распакуйте архив:
unzip rocketmq-tutorial.zip
Перейдите в распакованный каталог:
cd rocketmq-tutorial/bin
Создайте сообщение:
sh mqadmin sendMessage -n "${Connection addresses}" -t ${Topic name} -p "hello rocketmq"
Где:
Connection addresses
— частный или публичный IP-адрес инстанса RocketMQ.Topic name
— название топика, созданного в инстансе RocketMQ.
Прервите создание сообщений комбинацией клавиш Ctrl + C.
Получите сообщение:
sh mqadmin consumeMessage -n "${Connection addresses}" -t ${Topic name}
Где:
Connection addresses
— частный или публичный IP-адрес инстанса RocketMQ.Topic name
— название топика, созданного в инстансе RocketMQ.
Прервите получение сообщений комбинацией клавиш Ctrl + C.
Подключение к инстансу RocketMQ выполнено.
Подключение с SSL
Включенная опция SSL шифрует данные перед их передачей для повышения безопасности.
Скачайте тестовый брокер:
wget https://dms-demo.obs.ru-moscow-1.hc.sbercloud.ru/rocketmq-tutorial.zip
Распакуйте архив:
unzip rocketmq-tutorial.zip
Перейдите в распакованный каталог:
cd rocketmq-tutorial/bin
Создайте сообщение:
JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "${Connection addresses}" -t ${Topic name} -p "hello rocketmq"
Где:
Connection addresses
— частный или публичный IP-адрес инстанса RocketMQ.Topic name
— название топика, созданного в инстансе RocketMQ.
Прервите создание сообщений комбинацией клавиш Ctrl + C.
Получите сообщение:
JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "${Connection addresses}" -t ${Topic name}
Где:
Connection addresses
— частный или публичный IP-адрес инстанса RocketMQ.Topic name
— название топика, созданного в инстансе RocketMQ.
Прервите получение сообщений комбинацией клавиш Ctrl + C.
Подключение к инстансу RocketMQ выполнено.
для Dev & Test