我安装了以下版本的芹菜和兔子 -
芹菜 3.1.6
兔子MQ 3.1.1
我可以从 PHP 将任务发布到默认队列 -
//client.php
<?php
require 'celery-php/celery.php';
$c = new Celery('localhost', 'guest', 'guest', '/');
$result = $c->PostTask('tasks.add', array(2,2));
我的工作模块是用蟒蛇的 -
# tasks.py
from celery import Celery
celery = Celery('tasks', broker='amqp://guest:guest@localhost:5672//')
@celery.task(queue='demo', name='add')
def add(x, y):
return x + y
我像这样经营芹菜工人和客户——
# terminal window 1
$ celery -A tasks worker --loglevel=info
# terminal window 2
$ php -f client.php
这行得通。我在终端窗口 1 中看到以下输出：
Received task: tasks.add[php_52b1759141a8b3.43107845]
Task tasks.add[php_52b1759141a8b3.43107845] succeeded in 0.000701383920386s: 4
但是我想有不同的队列。对于演示，假设我只想要一个名为 demo 的队列。所以我这样经营我的芹菜工人——
$ celery -A tasks worker --loglevel=info -Q demo
但它不起作用。任务未执行。我想这可能是因为 PHP 代码将任务发布在默认队列上：芹菜（显然不在演示队列上）。
如何在 PHP 中的特定队列上发布我的任务？请帮忙。
默认情况下，您的 PHP 客户端将队列名称作为"celery"。
若要更改要发布到的队列，必须在实例化与 Celery 的连接时指定队列名称。因此，如果您使用"-Q demo"选项启动您的 Celery 工作线程，那么您在 PHP 中与 Celery 的连接应该是 -
$exchange = 'demo';
$binding = 'demo';
$c = new Celery('localhost', 'guest', 'guest', '/', $exchange, $binding);
注意：使用 -Q 选项，交换值和routing_key值与queue_name相同。
请尝试此操作并分享结果。
关于交换和绑定：
与电话服务类比，Exchange就像"电话接线员"，其唯一工作是在routing_key的帮助下"将呼叫直接发送给您"。
绑定是"您的电话号码"，它充当您的电话的routing_key。
注意：交换根据绑定（routing_key）将传入消息重定向到队列的过程是直接交换类型。AMQP很少有其他类型的交易所，你可以在AMQP文档中阅读。
你也可以参考这个芹菜页面