Подключение к инстансу 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 выполнено.
- Перед началом работы
- Подключение без SSL
- Подключение с SSL