使用redis队列和linux的计划任务实现邮件队列的队列发送
1、增加了一个扩展类Queue.php
2、代码里改了一下tp自带的redis类,增加了下面几个方法/**
* 插入队列
* @param $k
* @param $value
* @return bool
* @author sunnier <xiaoyao_xiao@126.com>
*/
public function push($k,$value){
$value = (is_object($value) || is_array($value)) ? json_encode($value) : $value;
$result=$this->handler->lpush($this->options['prefix'].$k,$value);
if($result){
return true;
}else{
return false;
}
}

/**
* 弹出队列
* @param $name
* @return array|mixed
* @author sunnier <xiaoyao_xiao@126.com>
*/
public function pop($name,$sendtimeout=0){
if(empty($sendtimeout)){
$timeout=$this->options['timeout'];
}else{
$timeout=$sendtimeout;
}
$keys=array($this->options['prefix'].$name);
$value = $this->handler->brPop($keys,$timeout);
$jsonData = json_decode( $value[1], true );
return ($jsonData === NULL) ? $value[1]: $jsonData;
}

/**
* 获取队列长度
* @param $name
* @return int
* @author sunnier <xiaoyao_xiao@126.com>
*/
public function len($name){
return $this->handler->lLen($this->options['prefix'].$name);
}

/**
* 删除队列
* @param $name
* @return int
* @author sunnier <xiaoyao_xiao@126.com>
*/
public function del($name){
return $this->handler->del($this->options['prefix'].$name);
}3、写了一个function中的方法用来发送邮件function think_send_mail($to, $name, $subject = '', $body = '', $attachment = null){
//插入到邮件表中,并插入redis等待发送
$mid=session('uid');
if(empty($mid)){
$mid=0;
}
$data=array(
'member_id'=>$mid,
'email'=>$to,
'send_name'=>$name,
'title'=>$subject,
'content'=>$body,
'send_times'=>1,
'create_time'=>time(),
);
$emailSendLog=M('EmailSendLog');
if($id=$emailSendLog->add($data)){
//添加成功之后插入redis
vendor('Queue');
$data['id']=$id;
$queque=\Think\My\Queue::getInstance('emailsend');
if($queque->myPush($data)){
return true;
}else{
return false;
}
}else{
//echo $emailSendLog->getError();
return false;
}
}4、重新写了一个cli.php用来使用命令行模式的tp执行控制器ScheduleController.class.php
5、crontab的配置见图,其中有一个code参数是get传输的值,自己随便改,主要是防止方法被乱调用

评论() 相关

收藏

赞

课本小明

ThinkPHP 是一个免费开源的,快速、简单的面向对象的 轻量级PHP开发框架 ,创立于2006年初,遵循Apache2开源协议发布,是为了敏捷WEB应用开发和简化企业应用开发而诞生的。ThinkPHP从诞生以来一直秉承简洁实用的设计原则,在保持出色的性能和至简的代码的同时,也注重易用性。并且拥有众多的原创功能和特性,在社区团队的积极参与下,在易用性、扩展性和性能方面不断优化和改进,已经成长为国内最领先和最具影响力的WEB应用开发框架,众多的典型案例确保可以稳定用于商业以及门户级的开发。