laravel整合rabbitmq消息队列（使用laravel-queue-rabbitmq）

官网地址：https://packagist.org/packages/vladimir-yuldashev/laravel-queue-rabbitmq#v10.2.0

1.安装插件

composer require vladimir-yuldashev/laravel-queue-rabbitmq`

报错：

因为我是laravel7的版本，因此找对应的版本

composer require vladimir-yuldashev/laravel-queue-rabbitmq:^10.2

还是报错，再来

composer require vladimir-yuldashev/laravel-queue-rabbitmq:^10.2 --ignore-platform-reqs

终于安装成功了。

这个配置根据自己的实际情况配置就可以

'rabbitmq' => [

            'driver' => 'rabbitmq',

            
            'worker' => env('RABBITMQ_WORKER', 'default'),

            'dsn' => env('RABBITMQ_DSN', null),

            

            'factory_class' => EnqueueAmqpLibAmqpConnectionFactory::class,

            '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', 'default'),

            'options' => [

                'exchange' => [

                    'name' => env('RABBITMQ_EXCHANGE_NAME'),

                    

                    'declare' => env('RABBITMQ_EXCHANGE_DECLARE', true),

                    

//                    'type' => env('RABBITMQ_EXCHANGE_TYPE', InteropAmqpAmqpTopic::TYPE_DIRECT),
                    'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false),
                    'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true),
                    'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),
                    'arguments' => env('RABBITMQ_EXCHANGE_ARGUMENTS'),
                ],

                'queue' => [

                    

                    'declare' => env('RABBITMQ_QUEUE_DECLARE', true),

                    

                    'bind' => env('RABBITMQ_QUEUE_DECLARE_BIND', true),

                    

                    '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),
                    'arguments' => env('RABBITMQ_QUEUE_ARGUMENTS'),
                ],
            ],

            

            'sleep_on_error' => env('RABBITMQ_ERROR_SLEEP', 5),

            

            'ssl_params' => [
                'ssl_on' => env('RABBITMQ_SSL', false),
                'cafile' => env('RABBITMQ_SSL_CAFILE', null),
                'local_cert' => env('RABBITMQ_SSL_LOCALCERT', null),
                'local_key' => env('RABBITMQ_SSL_LOCALKEY', null),
                'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true),
                'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', null),
            ],

        ],

QUEUE_DRIVER=rabbitmq # 走rabbitmq
RABBITMQ_HOST=rabbitmq # 我的容器是 rabbit 你们要是ip就写ip
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=

我本地使用的docker环境
安装很简单

WORKSPACE_INSTALL_AMQP=true

docker-compose build  workspace

怎么查看本地amqp的扩展是否安装成功了，php_info()

先build生成镜像

docker-compose build rabbitmq

再启容器

docker-compose up -d rabbitmq

如果启动成功了，万事大吉，但……
我这里启动了以后几秒就死掉了
查看日志

docker logs laradock_rabbitmq_1

错误信息:“cookie file /var/lib/rabbitmq/.erlang.cookie must be accessible by owner only”

解决办法：改为${DATA_PATH_HOST}/rabbitmq:/var/lib/rabbitmq/mnesia，然后重新build,重新启动就可以了。

 
  RabbitQueue::dispatch();
 
2.启队列 
winpty docker-compose exec workspace bash
php artisan queue:work rabbitmq
 
 
3.运行方法，看log里面是否有日志 
 
啦啦啦，终于完成了……