Как отправляются сообщения в RabbitMQ
Python
Middle
Без компании
Как отправляются сообщения в RabbitMQ
Ответы
Для отправки сообщений в RabbitMQ используется библиотека `pika`. Основные шаги:
- Установка соединения с брокером
- Создание канала
- Объявление очереди (если её нет)
- Публикация сообщения
Пример кода:
```
import pika
# Установка соединения
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# Объявление очереди
channel.queue_declare(queue='hello')
# Отправка сообщения
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
print(" [x] Sent 'Hello World!'")
# Закрытие соединения
connection.close()
```
Ключевые моменты:
- `exchange` - точка маршрутизации (пустая строка для очереди по умолчанию)
- `routing_key` - имя очереди
- `body` - содержимое сообщения (должно быть строкой или bytes)
- Всегда закрывайте соединение после использования