README

此扩展用于与不同的消息队列服务进行交互。

安装

使用composer安装包

{
    "require": {
       "strong2much/yii2-queue": "dev-master"
    }
}

Or

$ composer require strong2much/yii2-queue "dev-master"

在您的配置文件中使用以下代码。您可以使用不同的服务

'queue' => [
    'class' => 'strong2much\queue\QueueManager'
    'serviceConfig' => [
        'class' => 'strong2much\queue\services\DummyQueue',
    ]
]

然后您可以这样发送消息

$msg = new \strong2much\queue\messages\TestMessage();
$msg->id = 1;
$msg->message = "Some text";
if($msg->send()) {
    echo "OK";
}

然后您可以使用管理器来处理您的消息

//To receive messages
$route = 'mq_test'; //just for example
$message = Yii::$app->queue->receiveMessage($route); //this will get first  one message from the queue

//if you specify some processing function in message model,
//then you can call it like so
if($message !== false) {
	Yii::app()->queue->processData($route, \yii\base\helpers\Json::decode($message));
}

要使用DbQueue作为您的服务，您需要应用提供的迁移。

strong2much / yii2-queue

维护者

详细信息

README

安装