'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'), // name of the default queue,

    'exchange_declare' => env('RABBITMQ_EXCHANGE_DECLARE', true), // create the exchange if not exists
    'queue_declare_bind' => env('RABBITMQ_QUEUE_DECLARE_BIND', true), // create the queue if not exists and bind to the exchange

    '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' => [
        'name' => env('RABBITMQ_EXCHANGE_NAME', null),
        'type' => env('RABBITMQ_EXCHANGE_TYPE', 'direct'), // more info at http://www.rabbitmq.com/tutorials/amqp-concepts.html
        '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),
    ],

]

QUEUE_DRIVER=rabbitmq   # 走rabbitmq

QUEUE_CONNECTION=rabbitmq # 走rabbitmq

RABBITMQ_HOST=127.0.0.1 # IP/如果是用docker安装的rabbitmq，则写容器名称rabbit（我的容器是 rabbit ）

RABBITMQ_PORT=5672  #端口
RABBITMQ_VHOST=/
RABBITMQ_LOGIN=guest # 账号
RABBITMQ_PASSWORD=guest # 密码
RABBITMQ_QUEUE=test_queue # 队列名称。如果你没有它会默认创建 Exchanges和Queue

#ssl连接配置（如果开启，把前面#取消）
#RABBITMQ_SSL=true
#RABBITMQ_SSL_CAFILE=/path_to_your_ca_file
#RABBITMQ_SSL_LOCALCERT=
#RABBITMQ_SSL_PASSPHRASE=
#RABBITMQ_SSL_KEY=

php artisan make:job Queue

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Support\Facades\Log;

class Queue implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    private $id;
    private $title;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($id, $title)
    {
        //
        $this->id = $id;
        $this->title = $title;

    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        //
        echo 'id =='. $this->id;
        echo "\n";
        echo 'title =='. $this->title;
        Log::info('id ===>'. $this->id. 'title ====>' . $this->title);
    }
}

<?php
/**
 * Created by Kris.
 */

namespace App\Http\Controllers\Home;

use App\Jobs\Queue;

class IndexController extends BaseController
{

    public function index()
    {
        echo '这是rabbitmq的消费队列';
        $arr = [
            ['id' => 4, 'title' => '张三'],
            ['id' => 5, 'title' => '李四'],
            ['id' => 6, 'title' => '王五'],
        ];

        foreach ($arr as $v) {
            $queue = new Queue($v['id'], $v['title']);
            $this->dispatch($queue);
        }
        echo '<br>';
        echo 'ok';
    }
}

php artisan queue:work rabbitmq --queue=test_queue --tries=3