tp6监听事件+消息队列实现发邮件

任务队列实现

这里采用的是发邮件的形式

一、首先下载任务队列queue类

composer require topthink/think-queue

查看自己的配置文件：
config下queue.php

<?php
return ['default'     => 'database', //这里采用的是数据库形式存储'connections' => ['sync'     => ['type' => 'sync',],'database' => ['type'       => 'database','queue'      => 'default','table'      => 'jobs',  //表名'connection' => null,],'redis'    => ['type'       => 'redis','queue'      => 'default','host'       => '127.0.0.1','port'       => 6379,'password'   => '','select'     => 0,'timeout'    => 0,'persistent' => false,],],'failed'      => ['type'  => 'none','table' => 'failed_jobs',],
];

建立jobs数据表：

CREATE TABLE `jobs` (`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,`queue` varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL,`payload` longtext COLLATE utf8mb4_unicode_ci,`attempts` tinyint(3) unsigned DEFAULT NULL,`reserve_time` int(10) unsigned DEFAULT NULL,`available_time` int(10) unsigned DEFAULT NULL,`create_time` int(10) unsigned NOT NULL,PRIMARY KEY (`id`),KEY `zfw_jobs_queue_index` (`queue`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

建立任务队列：app\job\test.php

public function fire(Job $job,$data){if ($job->attempts()>3){Log::error('Test执行失败');}else{//发给谁$to = '123456789@qq.com';//标题$title = 'XXXXXX';//内容$content = "XXXXXX";//调用封装好的Email类(new sendEmail())->sendMail($to,$title,$content);//执行成功后删除队列$job->delete();}}

使用模型监听事件（此处注意在模型内完成）

//执行添加
public static function add($data){return self::create($data);}
//监听添加成功之后
public static function onAfterInsert($user){Queue::later(60,'app\job\Test',$user,'Test');}

执行任务

php think queue:listen --queue Test  //执行队列nohup php think queue:listen --queue Test&   //不以守护进程执行

tp6监听事件+消息队列实现发邮件相关推荐

Spring Boot监听事件同步和异步使用
废话前言: 代码环境:WIN7+IDEA+JAD1.8+Spring Boot 2.0 首先说一下我为什么使用事件,比如现在创建一个订单但是我创建成功后要给客户发送一条短信和一个邮件提醒,本身没创建订 ...
electron ipcRenderer渲染进程发送事件， ipcMain主进程监听事件
ipcMain 从主进程到渲染进程的异步通信.它处理从渲染器进程(网页)发送出来的异步和同步信息. 从渲染器进程发送的消息到主进程的异步通信. 主进程: import { app, BrowserWi ...
nginx监听事件流程
在前面的几篇文章中已经分析了master进程.work进程的初始化流程.但一直没有分析监听socket的创建流程,nginx服务器只有在创建socket, 绑定socet,监听socket执行完成后, ...
Android——监听事件总结
各种监听事件 1.按钮 Button (1)点击监听 btn_1.setOnClickListener(new View.OnClickListener() { (2)长按监听 btn_1.setOn ...
iOS OC与JS交互(WebView监听事件)
在iOS应用的开发过程中,我们经常会使用到WebView,当我们对WebView进行操作的时候,有时会需要进行源生的操作.那么我记下来就与大家分享一下OC与JS交互. 首先先说第一种方法,并没有牵扯O ...
利用勾子监视系统或进程中的各种事件消息，截获发往目标窗口的消息并进行处理
钩子实际上是一个处理消息的程序段,通过系统调用,把它挂入系统.每当特定的消息发出,在没有到达目的窗口前,钩子程序就先捕获该消息,亦即钩子函数先得到控制权.这时钩子函数即可以加工处理 ...
HTML学习14-js 内置对象 Date() 常用的日期的方法定时器倒计时监听事件
内置对象内置对象: 内置对象就是指这个语言自带的一些对象,供开发者使用,这些对象提供了一些常用的或是最基本而必要的功能. 手机买来就能发短信就能打电话日期函数 ( Date() ) 这个函数 ( ...
ROS中 Python/C++ 键盘按键监听事件
ROS中 Python/C++ 键盘按键监听事件这几天在肝全国智能驾驶大赛,真就挺累的:抓狂思考,手搓代码,疯狂编译,要命运行.在这趟火车上,被各种各样的问题卡住甚至卡死,就很难受好吧.至今,我深深 ...
Cocos 发射和监听事件事件派送(TypeScript)
监听和发射事件监听事件事件处理是在节点(cc.Node)中完成的.对于组件,可以通过访问节点 this.node 来注册和监听事件. 事件监听函数 on 可以传第三个参数 target,用于绑定响 ...

tp6监听事件+消息队列实现发邮件

tp6监听事件+消息队列实现发邮件相关推荐

最新文章

热门文章