Distributed Message Service for RocketMQ

Подключение к инстансу DMS for RocketMQ

К инстансу Distributed Message Service for RocketMQ можно подключиться с SSL и без него.

Подключение внутри VPC и публичный доступ различаются IP-адресами и портами. Для подключения внутри VPC используется порт 8100. Для публичного доступа — порт 8200.

В этих инструкциях описана настройка публичного доступа к инстансу DMS for RocketMQ.

Перед началом работы

Создан инстанс DMS for RocketMQ.
Настроены правила группы безопасности.
Создан топик.
Создана виртуальная машина.

Для подключения внутри сети VPC настройки VPC, подсети и группы безопасности ВМ и инстанса DMS for RocketMQ должны быть одинаковыми.
Установлен JDK версии 1.8.111 и выше и настроены переменные.

Подключение без SSL

Подключитесь к виртуальной машине ECS.

Скачайте тестовый брокер:

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 шифрует данные перед их передачей для повышения безопасности.

Подключитесь к виртуальной машине ECS.

Скачайте тестовый брокер:

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 выполнено.

Была ли эта статья полезна?

Поддержка Юридические документы