python3＋Tornado＋Celery＋Rabbitmq3.7.16实现异步队列任务

在之前的一篇文章中提到了用Django+Celery+Redis实现了异步任务队列[1]，只不过消息中间件使用了redis，redis作为消息中间件可谓是差强人意，功能和性能上都不如Rabbitmq，所以本次使用tornado框架结合celery，同时消息中间件使用Rabbitmq来实现异步发邮件，并且使用flower来监控任务队列。

首先安装rabbitmq

Mac os直接运行brew命令安装

Win10系统就要下载安装包进行安装了，由于rabbitmq是基于erlang的，所以要首先安装erlang

1、首先，下载并运行Erlang for Windows 安装程序 （地址：http://www.erlang.org/downloads）下载完毕并安装（注意：安装目录请选择默认目录）

安装成功后，启用web管理UI，进入RabbitMQ Serverrabbitmq_server-3.6.6sbin，输入命令rabbitmq-plugins enable rabbitmq_management

在系统的开始菜单里找到RabbitMQ的启动菜单，启动服务

浏览器输入，http://localhost:15672/，使用默认用户guest/guest进入网页端控制台：

代表没有问题了

然后安装tornado和celery，注意指定版本号

需要注意一点，由于python3.7中async已经作为关键字存在，但是有的三方库还没有及时修正，导致它们自己声明的变量和系统关键字重名，所以我们要深入三方库的源码，帮他们修改async关键字为async_my，需要修改的文件夹和文件包含但不限于：

/site-packages/pika/adapters/libev_connection.py

/site-packages/celery下面的文件

/site-packages/kombu下面的文件夹

在tornado项目下新建一个任务队列文件task.py：

然后编写服务端代码:

路由器代码:

程序入口代码server.py:

进入项目目录，分别启动tornado服务，celery服务，以及flower服务

访问网址http://localhost:8000/celery 用来触发异步任务

后台服务显示任务返回值：

进入flower在线任务监控网址：http://localhost:5555/

至此，整个流程就走完了。

引用链接

Django+Celery+Redis实现了异步任务队列:https://v3u.cn/a_id_54