TP6使用 think |
您所在的位置：网站首页 › tp6异步 › TP6使用 think |
|
###TP6 队列 TP6 中使用 think-queue 可以实现普通队列和延迟队列。 think-queue 是thinkphp 官方提供的一个消息队列服务，它支持消息队列的一些基本特性： 消息的发布，获取，执行，删除，重发，失败处理，延迟执行，超时控制等 队列的多队列， 内存限制 ，启动，停止，守护等 消息队列可降级为同步执行 消息队列实现过程1、通过生产者推送消息到消息队列服务中 2、消息队列服务将收到的消息存入redis队列中（zset） 3、消费者进行监听队列，当监听到队列有新的消息时，获取队列第一条 4、处理获取下来的消息调用业务类进行处理相关业务 5、业务处理后，需要从队列中删除消息 composer 安装 think-queue composer require topthink/think-queue 配置文件安装完 think-queue 后会在 config 目录中生成 queue.php，这个文件是队列的配置文件。 tp6中提供了多种消息队列的实现方式，默认使用sync，我这里选择使用Redis。 return [ 'default' => 'redis', 'connections' => [ 'sync' => [ 'type' => 'sync', ], 'database' => [ 'type' => 'database', 'queue' => 'default', 'table' => 'jobs', 'connection' => null, ], 'redis' => [ 'type' => 'redis', 'queue' => 'default', 'host' => env('redis.host', '127.0.0.1'), 'port' => env('redis.port', '6379'), 'password' => env('redis.password','123456'), 'select' => 0, 'timeout' => 0, 'persistent' => false, ], ], 'failed' => [ 'type' => 'none', 'table' => 'failed_jobs', ], ]; 创建目录及队列消费类文件在 app 目录下创建 queue 目录，然后在该目录下新建一个抽象类 Queue.php 文件，作为基础类 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |