如何在PHP中在芹菜rabbitmq队列上发布任务？

Question

我已经安装了以下版本的芹菜和拉比MQ-

芹菜3.1。6
rabbitmq 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));

我的worker模块是用python编写的-

# 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中将任务发布到特定队列上？请帮忙。

Answer 1

默认情况下，芹菜PHP客户端将队列名称作为“芹菜”。

要更改要发布到的队列，必须在实例化芹菜连接时指定队列名称。因此，如果您使用“-qdemo”选项启动芹菜工人，那么您在PHP中与芹菜的连接应该是-

$exchange = 'demo'; 
$binding = 'demo'; 
$c = new Celery('localhost', 'guest', 'guest', '/', $exchange, $binding); 

注意：使用-Q选项，交换和routing_key值与queue_name相同。

请尝试并分享结果。

关于交换和绑定：

与电话服务类似，交换机就像“电话接线员”，其唯一的工作就是在路由键的帮助下“直接给您打电话”。

然后绑定为“您的电话号码”，它充当您电话的路由密钥。

注意：exchange根据绑定（路由密钥）将传入消息重定向到队列的过程是直接exchange类型。AMQP几乎没有其他类型的交换，您可以在AMQP文档中阅读。

你也可以参考这个芹菜页面