laravel队列使用场景(Laravel使用RabbitMQ的方法示例)
类别:编程学习 浏览量:750
时间:2022-01-24 00:02:24 laravel队列使用场景
Laravel使用RabbitMQ的方法示例导语
RabbitMQ 想必大家都有了解,不做多介绍来。这里实现的是用 RabbitMQ 作为 Larvel 队列的驱动,替代 Redis。下面以 Laradock 中安装示例。
安装
- 切换到 laradock 目录,将 .env 中关于 INSTALL_AMQP 的值修改为 true
- docker-compose stop workspace php-fpm php-worker
- docker-compose build workspace php-fpm php-worker rabbitmq
- docker-compose up -d workspace php-fpm php-worker rabbitmq
扩展包安装以及配置
- 进入到 workspace 容器中,在项目目录安装扩展包 composer require vladimir-yuldashev/laravel-queue-rabbitmq
- 接下来在 config/queue.php 文件中 connections 添加 rabbitmq 配置,根据情况自行修改
|
'rabbitmq' => [ 'driver' => 'rabbitmq' , /* * Set to "horizon" if you wish to use Laravel Horizon. */ 'worker' => env( 'RABBITMQ_WORKER' , 'default' ), 'dsn' => env( 'RABBITMQ_DSN' , null), /* * Could be one a class that implements \Interop\Amqp\AmqpConnectionFactory for example: * - \EnqueueAmqpExt\AmqpConnectionFactory if you install enqueue/amqp-ext * - \EnqueueAmqpLib\AmqpConnectionFactory if you install enqueue/amqp-lib * - \EnqueueAmqpBunny\AmqpConnectionFactory if you install enqueue/amqp-bunny */ 'factory_class' => Enqueue\AmqpLib\AmqpConnectionFactory:: 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' ), /* * Determine if exchange should be created if it does not exist. */ 'declare' => env( 'RABBITMQ_EXCHANGE_DECLARE' , true), /* * Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html */ 'type' => env( 'RABBITMQ_EXCHANGE_TYPE' , \Interop\Amqp\AmqpTopic::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' => [ /* * Determine if queue should be created if it does not exist. */ 'declare' => env( 'RABBITMQ_QUEUE_DECLARE' , true), /* * Determine if queue should be binded to the exchange created. */ 'bind' => env( 'RABBITMQ_QUEUE_DECLARE_BIND' , true), /* * Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html */ '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' ), ], ], /* * Determine the number of seconds to sleep if there's an error communicating with rabbitmq * If set to false, it'll throw an exception rather than doing the sleep for X seconds. */ 'sleep_on_error' => env( 'RABBITMQ_ERROR_SLEEP' , 5), /* * Optional SSL params if an SSL connection is used * Using an SSL connection will also require to configure your RabbitMQ to enable SSL. More details can be founds here: https://www.rabbitmq.com/ssl.html */ '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), ], ], |
在 .env 中修改 QUEUE_CONNECTION 为 rabbitmq ,并添加以下值
|
RABBITMQ_WORKER=horizon RABBITMQ_HOST=rabbitmq RABBITMQ_PORT=5672 RABBITMQ_LOGIN=guest RABBITMQ_PASSWORD=guest RABBITMQ_QUEUE= default |
有两个值说明一下,因为是在 Laradock 中,所以 RABBITMQ_HOST 设置为 rabbitmq ;如果之前使用了Laravel Horizon,那么 RABBITMQ_WORKER 的设置为 horizon 就可以了。
参考资料:laravel-queue-rabbitmq
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持开心学习网。
原文链接:https://segmentfault.com/a/1190000019501459
您可能感兴趣
- java入坑rabbitmq(Python操作rabbitMQ的示例代码)
- laravel队列使用场景(Laravel使用RabbitMQ的方法示例)
- rabbitmq延迟队列原理(Rabbitmq heartbea心跳检测机制原理解析)
- rabbitmq docker配置(Docker部署Rabbitmq容器实现过程解析)
- docker 启动rabbitmq(docker安装rabbitmq无法进入管理页面的问题)
- linuxrabbitmq安装和使用教程(用docker部署RabbitMQ环境的详细介绍)
- docker rabbitmq集群部署(Docker部署rabbitmq遇到的两个问题)
- rabbitmq客户端内存占用(mysql-canal-rabbitmq 安装部署超详细教程)
- centos7rabbitmq怎么装(如何在centos上使用yum安装rabbitmq-server)
- 阿里最新财报公布 三季度营收增长3 ,将增加150亿美元回购额度 在美股价小涨(阿里最新财报公布)
- 赵薇时胖时瘦 最近变美少女 原因在这里 躺着就变瘦(赵薇时胖时瘦最近变美)
- 学会这26种姿势,你就可以和兵哥哥切磋了(你就可以和兵哥哥切磋了)
- 吴彦祖陈冠希 恩怨 ,失去曾让他流泪的女友,终遇走过18年真爱(吴彦祖陈冠希恩怨)
- 痴情男神 吴彦祖 与妻子恋爱8年,结婚10年,家庭幸福美满(痴情男神吴彦祖)
- 成功破圈,小牛电动SQi强势开 跨(小牛电动SQi强势开)
热门推荐
- php多维数组怎么转换json(php实现的数组转xml案例分析)
- mysql常用数据模型(MySQL数据库基于sysbench实现OLTP基准测试)
- 虚拟机windows server安装php环境(winxp apache用php建本地虚拟主机的方法)
- docker容器连接宿主机(docker 实现容器与宿主机无缝调用shell命令)
- MySQL自定义函数
- python爬虫并保存excel实例(Python实现爬取亚马逊数据并打印出Excel文件操作示例)
- python如何判断文件是否结束(python判断文件是否存在,不存在就创建一个的实例)
- python编程面试常见问题(分析经典Python开发工程师面试题)
- 进度条代码大全(多步骤进度条的实现原理及代码)
- css padding简写
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9