异步消息队列

1. 消息队列 rabbitmq - 提供消息队列服务

rabbitmq 常用指令

• docker run -d -p 5672:5672 --name mq rabbitmq
• docker exec -it mq /bin/bash

1. 创建用户 rabbitmqctl add_user wanghu 123456

2. 配置权限 rabbitmqctl set_user_tags wanghu administrator

3. 创建一个主机(队列) : rabbitmqctl add_vhost vhost1

4. 给主机配置管理(.conf) / 读(write) / 写(read) 权限rabbitmqctl set_permissions -p vhost1 wanghu "." "." ".*"

5. 查看消息 : rabbitmqctl list_queues -p vhost1

6. 清除消息
   rabbitmqctl -p <vhost-name> purge_queue <queue-name>

2. Celery 提供消息的创建者和消费者

Celery

1. 给day001项目创建消息消费者, 指定日志及级别(-l debug) :
   celery -A day001 worker -l debug
   如果该命令不写,用下述命令
   celery -A fangall worker --pool=solo -l info

2. 创建消息生产者 : celert -A day001 beat -l debug

AMQP，即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。