LARAVEL5.1 中的 RabbitMQ :: 作业 class 的 handle 方法被调用而没有被队列处理?
RbbitMQ in LARAVEL5.1 :: handle method of the job class is called without processed by the queue?
laravel5.1
中的 RABBITMQ 连接设置
'rabbitmq' => [
'driver' => 'rabbitmq',
'host' => env('RABBITMQ_HOST', '127.0.0.1'),
'port' => env('RABBITMQ_PORT', 5672),
'vhost' => env('RABBITMQ_VHOST', '/'),
'login' => env('RABBITMQ_LOGIN', 'guest'),
'password' => env('RABBITMQ_PASSWORD', 'guest'),
'queue' => env('RABBITMQ_QUEUE_ABUSE_SCRIPT','abuse'), // name of the default queue,
'queue_params' => [
'passive' => env('RABBITMQ_QUEUE_PASSIVE', false),
'durable' => env('RABBITMQ_QUEUE_DURABLE', true),
'exclusive' => env('RABBITMQ_QUEUE_EXCLUSIVE', false),
'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false),
],
'exchange_params' => [
'type' => env('RABBITMQ_EXCHANGE_TYPE', 'direct'),
'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false),
'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true), // the exchange will survive server restarts
'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),
],
],
将作业推入队列的代码
$job = (new AddIp());
$this->dispatch($job);
//handle method body
public function handle()
{
$testQueue = new TestQueue();
$testQueue->process_order= '1';
$testQueue->save();
}
起始监听器
php artisan queue:listen rabbitmq
每当我尝试将作业添加到队列中时,它调用的句柄方法未经队列处理,即使我没有在队列侦听器中看到任何消息 window 所以我恳请你问我这里到底发生了什么不知道????
1) 运行 作曲家更新
2) 并重新配置 https://github.com/fintech-fab/laravel-queue-rabbitmq
3) 做以上两个就可以了。
laravel5.1
中的 RABBITMQ 连接设置'rabbitmq' => [
'driver' => 'rabbitmq',
'host' => env('RABBITMQ_HOST', '127.0.0.1'),
'port' => env('RABBITMQ_PORT', 5672),
'vhost' => env('RABBITMQ_VHOST', '/'),
'login' => env('RABBITMQ_LOGIN', 'guest'),
'password' => env('RABBITMQ_PASSWORD', 'guest'),
'queue' => env('RABBITMQ_QUEUE_ABUSE_SCRIPT','abuse'), // name of the default queue,
'queue_params' => [
'passive' => env('RABBITMQ_QUEUE_PASSIVE', false),
'durable' => env('RABBITMQ_QUEUE_DURABLE', true),
'exclusive' => env('RABBITMQ_QUEUE_EXCLUSIVE', false),
'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false),
],
'exchange_params' => [
'type' => env('RABBITMQ_EXCHANGE_TYPE', 'direct'),
'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false),
'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true), // the exchange will survive server restarts
'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),
],
],
将作业推入队列的代码
$job = (new AddIp());
$this->dispatch($job);
//handle method body
public function handle()
{
$testQueue = new TestQueue();
$testQueue->process_order= '1';
$testQueue->save();
}
起始监听器
php artisan queue:listen rabbitmq
每当我尝试将作业添加到队列中时,它调用的句柄方法未经队列处理,即使我没有在队列侦听器中看到任何消息 window 所以我恳请你问我这里到底发生了什么不知道????
1) 运行 作曲家更新
2) 并重新配置 https://github.com/fintech-fab/laravel-queue-rabbitmq
3) 做以上两个就可以了。