RabbitMQ MCP Server

RabbitMQ MCP Server

MCP сервер для работы с RabbitMQ с полной поддержкой SSL/CA сертификатов.

Репозиторий: https://github.com/sobue-code/rabbitmq_mcp

Возможности

• Полная поддержка SSL/TLS с CA сертификатами
• Управление очередями (создание, удаление, очистка)
• Управление exchanges (создание, удаление)
• Привязка очередей к exchanges
• Публикация сообщений
• Чтение сообщений из очередей
• Проверка статуса соединения

Установка

Вариант 1: Из GitHub (рекомендуется)

Добавьте в конфигурацию MCP (~/.config/opencode/opencode.json или .mcp.json в проекте):

{
  "mcpServers": {
    "rabbitmq": {
      "command": "uvx",
      "args": [
        "--from",
        "git+https://github.com/sobue-code/rabbitmq_mcp.git",
        "rabbitmq-mcp-altqa"
      ],
      "env": {
        "RABBITMQ_HOST": "your-rabbitmq-host.com",
        "RABBITMQ_PORT": "5671",
        "RABBITMQ_USER": "your-username",
        "RABBITMQ_PASSWORD": "your-password",
        "RABBITMQ_VHOST": "your-vhost",
        "RABBITMQ_USE_SSL": "true",
        "RABBITMQ_CA_CERT": "/path/to/your/ca_cert.pem"
      }
    }
  }
}

Вариант 2: Локальная установка (для разработки)

# Клонировать репозиторий
git clone https://github.com/sobue-code/rabbitmq_mcp.git
cd rabbitmq_mcp

# Установить зависимости
uv sync

Конфигурация для локальной установки:

{
  "mcpServers": {
    "rabbitmq": {
      "command": "uv",
      "args": [
        "run",
        "--directory",
        "/path/to/rabbitmq_mcp",
        "rabbitmq-mcp-altqa"
      ],
      "env": {
        "RABBITMQ_HOST": "your-rabbitmq-host.com",
        "RABBITMQ_PORT": "5671",
        "RABBITMQ_USER": "your-username",
        "RABBITMQ_PASSWORD": "your-password",
        "RABBITMQ_VHOST": "your-vhost",
        "RABBITMQ_USE_SSL": "true",
        "RABBITMQ_CA_CERT": "/path/to/your/ca_cert.pem"
      }
    }
  }
}

Переменные окружения

| Переменная | Описание | По умолчанию | |------------|----------|--------------| | RABBITMQ_HOST | Хост RabbitMQ | localhost | | RABBITMQ_PORT | Порт | 5672 | | RABBITMQ_USER | Имя пользователя | guest | | RABBITMQ_PASSWORD | Пароль | guest | | RABBITMQ_VHOST | Виртуальный хост | / | | RABBITMQ_USE_SSL | Использовать SSL (true/false) | false | | RABBITMQ_CA_CERT | Путь к CA сертификату | (нет) | | RABBITMQ_HEARTBEAT | Интервал heartbeat (сек) | 3600 | | RABBITMQ_SOCKET_TIMEOUT | Таймаут сокета (сек) | 5 |

Доступные инструменты

Управление соединением

• rabbitmq_connect — Подключиться к RabbitMQ
• rabbitmq_disconnect — Отключиться
• rabbitmq_status — Проверить статус соединения

Очереди

• rabbitmq_declare_queue — Создать очередь (quorum по умолчанию)
• rabbitmq_delete_queue — Удалить очередь
• rabbitmq_purge_queue — Очистить очередь
• rabbitmq_queue_message_count — Количество сообщений
• rabbitmq_get_message — Получить сообщение

Exchanges

• rabbitmq_declare_exchange — Создать exchange
• rabbitmq_delete_exchange — Удалить exchange

Связи

• rabbitmq_bind_queue — Привязать очередь к exchange
• rabbitmq_unbind_queue — Отвязать очередь

Публикация

• rabbitmq_publish — Опубликовать в exchange
• rabbitmq_publish_to_queue — Опубликовать напрямую в очередь

Примеры использования

Подключение

Вызови rabbitmq_connect

Проверка статуса

Проверь статус соединения через rabbitmq_status

Создание очереди

Создай quorum очередь "my-queue" через rabbitmq_declare_queue

Публикация сообщения

Опубликуй сообщение {"task": "test"} в exchange "" с routing key "my-queue"

Получение сообщения

Получи сообщение из очереди "my-queue" через rabbitmq_get_message

Разработка

# Клонировать и установить
git clone https://github.com/sobue-code/rabbitmq_mcp.git
cd rabbitmq_mcp
uv sync

# Тестирование сервера
echo '{"jsonrpc":"2.0","method":"initialize","params":{"protocolVersion":"2024-11-05","capabilities":{},"clientInfo":{"name":"test","version":"1.0"}},"id":1}' | uv run rabbitmq-mcp-altqa

Лицензия

Apache-2.0