php代码实现tp5监听队列,thinkPHP5的队列使用

1、下载tp5的完全包，里面含有queue的扩展。如果没有执行如下命令:

composer require topthink/think-queue 1.1.4

2、执行第二步：

执行的队列:

namespace app\admin\controller;

use think\queue\Job;

use think\Db;

class Work{

public function fire(Job $job, $data)

{

//执行业务逻辑

$isJobDone = Db::name('order_queue')->insert([

'utime' =>time(),

'email' =>$data

]);

if ($isJobDone) { //成功删除任务 $job->delete(); } else { //任务轮询4次后删除 if ($job->attempts() > 3) { // 第1种处理方式：重新发布任务,该任务延迟10秒后再执行 //$job->release(10); // 第2种处理方式：原任务的基础上1分钟执行一次并增加尝试次数 //$job->failed(); // 第3种处理方式：删除任务 $job->delete(); } } }

}?>

业务文件 Controller

public function queue()

{

// \think\Queue::push('app\admin\controller\Queue@fire', '284560@qq.com', $queue = '777');

// \think\Queue::push('app\common\queue\QueueClient@sendMAIL', '28456049@qq.com', $queue = null);

\think\Queue::push('app\admin\controller\Work@fire', '28456049@qq.com', $queue = '好队列');

echo 'ok';

}

后台监听:

php think queue:listen

php代码实现tp5监听队列,thinkPHP5的队列使用相关推荐

laravel 任务队列_Laravel5.5之事件监听、任务调度、队列
流程: 1.1 创建event php artisan make:event UserLogin LoginController.php /*** The user has been authenti ...
Laravel5.5之事件监听、任务调度、队列
一.事件监听流程: 1.1 创建event php artisan make:event UserLogin LoginController.php /*** The user has been a ...
android锁屏代码分析,Android 监听锁屏、解锁、开屏功能代码
1.首先定义 ScreenListener package com.app.lib; import android.content.BroadcastReceiver; import android. ...
微信怎么绑定消息服务器吗,fastweixin: 极其方便的实现微信公众平台服务端开发，2行代码完成服务器绑定，3行代码实现用户消息监听...
fastweixin 作者:peiyu 快速搭建微信公众平台服务器简单封装了所有与微信服务器交互的消息:文本消息.图片消息.图文消息等等提供了基于springmvc以及基于servlet框架的控制 ...
mysql报错代码10051_zabbix_server 不能监听端口tcp 10051(示例代码)
rhel6.7下安装zabbix 监控,zabbix服务启动但不能监听10051端口安装环境rhel6.7, 监控软件版本zabbix-2.2.1 mysql版本5.1 安装配置全部OK, 1.st ...
java监听微信_fastweixin: 极其方便的实现微信公众平台服务端开发，2行代码完成服务器绑定，3行代码实现用户消息监听...
fastweixin 作者:peiyu 快速搭建微信公众平台服务器简单封装了所有与微信服务器交互的消息:文本消息.图片消息.图文消息等等提供了基于springmvc以及基于servlet框架的控制 ...
基于Redisson实现的延时队列RedissonDelayedQueue实现websocket服务端心跳监听
简介基于Redis的Redisson分布式延迟队列(Delayed Queue)结构的 RDelayedQueue. Java对象在实现了RQueue接口的基础上提供了向队列按要求延迟添加项目的功能 ...
一行代码实现Okhttp,Retrofit,Glide下载上传进度监听
2019独角兽企业重金招聘Python工程师标准>>> 发表上篇文章我一行代码都不写实现Toolbar!你却还在封装BaseActivity? 已是一个月前的事情~ 上篇文章的研究 ...
canal 监听不到数据变化_数据的异构实战（二）手写迷你版同步工程
点击上方"Java知音",选择"置顶公众号" 技术文章第一时间送达! 上一期讲到了通过canal订阅mysql的binlog日志并且转换为对象,那么这一次我们将 ...

php代码实现tp5监听队列,thinkPHP5的队列使用

php代码实现tp5监听队列,thinkPHP5的队列使用相关推荐

最新文章

热门文章