RabbitMQ مدیریت‌شده برای صف و پیام‌رسانی

پیام‌ها گم نمی‌شوند

RabbitMQ پیام‌ها را تا وقتی مصرف‌کننده تأیید نکند نگه می‌دارد. با exchange های direct، topic و fanout می‌توانید صف کار، pub/sub، مسیریابی بر اساس کلید و RPC بسازید.

برای Celery در Django، کارگرهای Node.js با amqplib یا سرویس‌های Go با amqp091، فقط RABBITMQ_URL را بخوانید. پنل Management برای دیدن صف‌ها و نرخ پیام‌ها در دسترس است.

از ساخت تا اتصال

1. ساخت

   broker با نسخه‌ی پیش‌فرض 4 ساخته می‌شود.

   --type rabbitmq

2. لینک به اپ

   RABBITMQ_URL به تولیدکننده و مصرف‌کننده‌ها تزریق می‌شود.

   --prefix RABBITMQ

3. استفاده

   صف‌ها و exchange ها از کد ساخته می‌شوند.

   amqp://

خروجی ساخت سرویس

$ sakoocloud db create --name broker --type rabbitmq
✔ Provisioning broker · db_4n8x2p
ℹ Ready in ~90s. Get credentials: sakoocloud db credentials db_4n8x2p
$ sakoocloud apps link-db db_4n8x2p --app my-api --prefix RABBITMQ
✔ Linked database. Env vars injected under RABBITMQ_*.
# RABBITMQ_URL=amqp://app:••••@…:5672

ساخت broker

با CLI یا از کنسول.

sakoocloud db create --name broker --type rabbitmq

تنظیمات

اتصال از اپ

تولیدکننده و مصرف‌کننده همان رشته را می‌خوانند.

import amqp from "amqplib";

const conn = await amqp.connect(process.env.RABBITMQ_URL);
const ch = await conn.createChannel();
await ch.assertQueue("emails", { durable: true });

import os
from celery import Celery

app = Celery("tasks", broker=os.environ["RABBITMQ_URL"])

خطاهای رایج

sakoocloud db public-access <db-id>
sakoocloud db credentials <db-id>

پرسش‌های متداول

جزئیات بیشتر در راهنمای RabbitMQ در مستندات و مرجع CLI.