tocdepth

2

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

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

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

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

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

  1. Создан инстанс DMS for RocketMQ.

  2. Настроены правила группы безопасности.

  3. Создан топик.

  4. Создана виртуальная машина.

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

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

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

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

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

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

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

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

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

    Где:

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

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

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

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

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

    Где:

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

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

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

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

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

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

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

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

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

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

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

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

    Где:

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

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

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

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

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

    Где:

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

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

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

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

Запустили Evolution free tier
для Dev & Test
Получить