Проект «SnakeProject» Михаила Козлова

⇒ FreeBSD and Nix ⇐

CISCO

Voice(Asterisk\Cisco)

Microsoft

Powershell

Python

SQL\T-SQL

1С

Общая

WEB Разработка

ORACLE SQL \ JAVA

Мото

RabbitMQ + Админка + Python простой пример

RabbitMQ + Админка + Python простой пример

Установка нужных пакетов:
# apt install rabbitmq-server

Включение и автозапуск:
# systemctl enable rabbitmq-server.service
# systemctl start rabbitmq-server.service
# rabbitmqctl status

Просмотр и включение плагинов(пример - админка):
# rabbitmq-plugins list
# rabbitmq-plugins enable rabbitmq_management
# cat /etc/rabbitmq/enabled_plugins

Заведем пользователя и дадим админские права:
# rabbitmqctl add_user roger rabbit
# rabbitmqctl set_user_tags roger administrator
# rabbitmqctl set_permissions -p / roger ".*" ".*" ".*"

Теперь админка доступна по url:
http://your_server_ip:15672/

Проведем проверку с помощью пары простых скриптов

# apt install python3-pika

Скрипт sender.py - посылает сообщение:
#!/usr/bin/env python 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()

# python3 /tmp/sender.py

# rabbitmqctl list_queues
http://your_server_ip:15672/#/queues

Скрипт receiving.py - получает сообщение:
#!/usr/bin/env python import pika connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue='hello') def callback(ch, method, properties, body): print(" [x] Received %r" % body) channel.basic_consume(callback, queue='hello', no_ack=True) print(' [*] Waiting for messages, press CTRL+C to exit') channel.start_consuming()

# python3 /tmp/receiving.py

# rabbitmqctl list_queues
http://your_server_ip:15672/#/queues

Комментарии пользователей