Advanced
Тема интерфейса

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

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

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

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

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

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

  2. Установлен JDK версии 1.8.111 и выше и настроены переменные.

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

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

    wget https://dms-demo.obs.ru-moscow-1.hc.sbercloud.ru/rocketmq-tutorial.zip
  2. Распакуйте архив:

    unzip rocketmq-tutorial.zip
  3. Перейдите в распакованный каталог:

    cd rocketmq-tutorial/bin
  4. Создайте сообщение:

    sh mqadmin sendMessage -n "${Connection addresses}" -t ${Topic name} -p "hello rocketmq"

    Где:

    • Connection addresses — частный или публичный IP-адрес инстанса RocketMQ.

    • Topic name — название топика, созданного в инстансе RocketMQ.

  5. Прервите создание сообщений комбинацией клавиш Ctrl + C.

  6. Получите сообщение:

    sh mqadmin consumeMessage -n "${Connection addresses}" -t ${Topic name}

    Где:

    • Connection addresses — частный или публичный IP-адрес инстанса RocketMQ.

    • Topic name — название топика, созданного в инстансе RocketMQ.

  7. Прервите получение сообщений комбинацией клавиш Ctrl + C.

Подключение к инстансу RocketMQ выполнено.

Подключение с SSL

Включенная опция SSL шифрует данные перед их передачей для повышения безопасности.

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

    wget https://dms-demo.obs.ru-moscow-1.hc.sbercloud.ru/rocketmq-tutorial.zip
  2. Распакуйте архив:

    unzip rocketmq-tutorial.zip
  3. Перейдите в распакованный каталог:

    cd rocketmq-tutorial/bin
  4. Создайте сообщение:

    JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "${Connection addresses}" -t ${Topic name} -p "hello rocketmq"

    Где:

    • Connection addresses — частный или публичный IP-адрес инстанса RocketMQ.

    • Topic name — название топика, созданного в инстансе RocketMQ.

  5. Прервите создание сообщений комбинацией клавиш Ctrl + C.

  6. Получите сообщение:

    JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "${Connection addresses}" -t ${Topic name}

    Где:

    • Connection addresses — частный или публичный IP-адрес инстанса RocketMQ.

    • Topic name — название топика, созданного в инстансе RocketMQ.

  7. Прервите получение сообщений комбинацией клавиш Ctrl + C.

Подключение к инстансу RocketMQ выполнено.