Быстрый старт¶

Системные требования¶

TQE(MQ) поддерживает установку на следующие операционные системы (ОС):

• РЕД ОС 7.3;

• Astra Linux.

Также возможно установка на другие ОС – ALTLinux, AlmaLinux, Ubuntu, CentOS – но полноценная работоспособность не гарантируется.

Для работы приложения необходима библиотека glibc версии 2.17-260.el7_6.6 и выше. Для проверки текущей установленной версии glibc и обновления необходимо выполнить:

$ rpm -q glibc

$ yum update glibc

Установка экземпляра¶

1. Распакуйте архив с дистрибутивом TQE(MQ):

$ tar -xzf <имя_архива>.tar.gz

2. Перейдите в директорию с распакованным дистрибутивом:

$ cd message-queue-ee

Запуск приложения¶

1. Для запуска ядра TQE(MQ) выполните команду:

$ cartridge start -d

Ответ должен иметь вид:

• message-queue-ee.app... OK

2. Далее необходимо настроить конфигурацию хранилища данных для очереди сообщений.

В данном случае используются преднастроенные файлы конфигурации instances.yml и replicasets.yml. Они поставляются в дистрибутиве и после распаковки находятся в корневой директории message-queue-ee/. В них определяется топология кластера – какие узлы какую роль будут выполнять, а также задается группировка узлов по наборам реплик (replica sets) для резервирования данных.

Также на этом шаге выполняется инициализация базы данных в кластере (флаг --bootstrap-vshard).

$ cartridge replicasets setup --bootstrap-vshard

Ответ должен иметь вид:

• Set up replicasets described in /home/redos/message-queue-ee/replicasets.yml
• app... CREATED
• Replicasets are set up successfully
• Bootstrap vshard task completed successfully, check the cluster status

$ docker-compose up -d --build

Настройка конфигурации после установки¶

1. Определение параметров подключения к очереди TQE(MQ):

$ curl "localhost:8081/admin/config" -X PUT --data-binary @- <<EOF
---
queues: ["queue"]
creds:
  user: user
  pass: pass
...
EOF

где:

• queue – название очереди сообщений;

• user – имя пользователя;

• pass – пароль.

user и pass определяются пользователем и в дальнейшем используются при подключении к очередям TQE(MQ).

Отсутствие ошибок в терминале сигнализирует о корректной настройке подключения к очереди.

2. Определение параметров модуля API (gRPC-сервера):

$ cat > config.service.yml <<EOF
app_name: MESSAGE_QUEUE_EE_API
app_version: test
core_host: 0.0.0.0
core_port: 18184
grpc_host: 0.0.0.0
grpc_port: 18182

publisher:
  enabled: true
  tarantool:
    user: user
    pass: pass
    queues:
      queue:
        connections:
          routers:
            - "localhost:3301"
consumer:
  enabled: true
  polling_timeout: 500ms
  tarantool:
    user: user
    pass: pass
    queues:
      queue:
        connections:
          storage-1:
            - "localhost:3301"
EOF

Отсутствие ошибок в терминале сигнализирует о корректной настройке модуля API (gRPC-сервера).

3. Запуск модуля API (gRPC-сервера):

$ bin/message-queue-ee -d -config config.service.yml

Проверка установки приложения¶

$ ./scripts/test.sh localhost:18182
Test passed.

$ ./scripts/test.sh localhost:18182
Test failed: message id expected "1", got "2".

$ grpcurl -plaintext -d '{"queue": "queue","payload": "TestGeneratedMessage"}' \
    localhost:18182 tarantool.queue_ee.PublisherService/Publish

{
  "id": "1",
  "metadata": {
    "x-timestamp": "1707736240527095940",
    "x-timestamp-queue-ee-publish-request-persisted": "1707736240527095940",
    "x-timestamp-queue-ee-publish-request-received": "1707736240524811467",
    "x-timestamp-queue-ee-publish-request-validated": "1707736240524934370"
  }
}

$ grpcurl -plaintext -d '{"queue": "queue","cursor": ""}' \
    localhost:18182 tarantool.queue_ee.ConsumerService/Subscribe

{
  "notifications": [
    {
      "cursor": "Dv+BBAEC/4IAAQwBBgAAD/+CAAEJc3RvcmFnZS0xAQ==",
      "message": {
        "id": "1",
        "queue": "queue",
        "payload": "TestGeneratedMessage",
        "metadata": {
          "x-timestamp": "1707736240524934370",
          "x-timestamp-queue-ee-publish-request-received": "1707736240524811467",
          "x-timestamp-queue-ee-publish-request-validated": "1707736240524934370"
        }
      }
    }
  ]
}