1. Go to this page and download the library: Download xskit/laravel-rabbitmq library. Choose the download type require.
2. Extract the ZIP file and open the index.php.
3. Add this code to the index.php.
<?php
require_once('vendor/autoload.php');
/* Start to develop here. Best regards https://php-download.com/ */
namespace App\Jobs\OneJob
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use XsKit\LaravelRabbitMQ\Contracts\PublishJobContract;
use XsKit\LaravelRabbitMQ\Contracts\QueueNotDeclare;
class OneJob extends PublishJobContract implements QueueNotDeclare
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $data;
public function __construct($data)
{
//定义连接到队列 rabbitmq 发送路由：b.queue
$this->onConnection('rabbitmq')->onQueue('b.queue');
$this->$data = $data;
}
}
namespace App\Jobs\OneJob
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use XsKit\LaravelRabbitMQ\Contracts\ConsumeJobContract;
class OneJob extends ConsumeJobContract
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $data;
public function handle($data)
{
//在这里处理你的业务
}
}