首页 文章

如何在PHP中的celery-rabbitmq队列上发布任务？

提问于
浏览 次
11

我安装了以下版本的芹菜和rabbitmq -

芹菜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

我像这样经营芹菜 Worker 和客户 -

# 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 的队列 . 所以我像这样经营我的芹菜 Worker -

$ celery -A tasks worker --loglevel=info -Q demo

但它可能是因为PHP代码在默认队列上发布任务： celery （显然不在 demo 队列上） .

如何在PHP中的特定队列上发布我的任务？请帮忙 .

php python rabbitmq celery

1 回答

  • 4

    默认情况下，Celery的PHP客户端将队列名称称为“celery” .

    要更改要发布到的队列，必须在实例化与Celery的连接时指定队列名称 . 因此，如果您使用“-Q demo”选项启动Celery工作程序，那么您在PHP中与Celery的连接应该是 -

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

    注意：使用-Q选项时，exchange和routing_key值与queue_name相同 .

    请尝试这个并分享结果 .

    About exchange and binding ：

    与电话服务类似，Exchange就像“电话接线员”，其唯一的工作就是在routing_key的帮助下“直接呼叫你” .

    然后绑定是“您的电话号码”，它充当您电话的routing_key .

    Note ：交换根据绑定（routing_key）将传入消息重定向到队列的过程是DIRECT交换类型 . AMQP几乎没有其他类型的交换，您可以在AMQP文档中阅读 .

    你也可以参考这个Celery page

    回复于

相关问题