redis实现消息队列教程详解数据库

redis实现消息队列教程(ps:这个消息队列因为是每秒插入一次数据 对于实时性比较高的就不要用消息队列了 就是直接插入数据库)

第一步:读取redis队列 并且存入数据库 后再移除 代码如下

 

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2016/10/18
 * Time: 17:00
 */
 
file_put_contents('log.log', date("Y-m-d H:i:s") . " " . var_export('测试每秒请求', TRUE) . PHP_EOL, FILE_APPEND | LOCK_EX);
require_once 'queenchuli/common/mysql.php';
 
redisc('tutorial-list',99,'mobantestinfo');
 

/**
 * @param $key redis key
 * @param $percount 一次性操作多少数据
 * @param $table 要插入的数据库
 */
function redisc($key,$percount,$table){
 
 $redis = new Redis();
 $redis->connect('127.0.0.1', 6379);
 $redis->auth('zhiweiredis');
 
 $arList = $redis->lrange($key, 0, $percount);
 
 if(!empty($arList)){
 foreach ($arList as $k=>$v){
 $arList[$k]=json_decode($v,true);
 }
 for ($i = 0; $i < $percount; $i++) {
 $redis->rPop($key);
 }
 $db = new mysql();
 $isOk=inserts($arList, $table);
 if ($isOk==1) {
 
 } else {
 //如果失败 就记录sql语句
 file_put_contents('/data/web/mircoweb/wwwroot/Public/queenchuli/moban/log.log', date("Y-m-d H:i:s") . " " . var_export($isOk, TRUE) . PHP_EOL, FILE_APPEND | LOCK_EX);
 }
 }
}
 

/**
 * 插入数组记录的操作
 * @param array $array
 * @param string $table
 * @return boolean
 */
function inserts($array, $table)
{
 
 $i = 0;
 $arraynew=array();
 foreach ($array as $k => $v) {
 if ($i == 0) {
 //运行一次就可以了
 $keys = join(',', array_keys($v));
 }
 
 $val='('.join(',',$v).')';
 $arraynew[]=$val;
 $i++;
 }
 
 $values = join(',',$arraynew);
 $sql = "insert {$table}({$keys}) VALUES {$values}";
 
 $res = mysql_query($sql);
 if ($res) {
 return 1;
 } else {
 return $sql;
 }
}
 

// some code
 
?>

第二步 shell脚本写定时器每秒触发 这个PHP文件

 step=1 #间隔的秒数，不能大于60 
 
 for (( i = 0; i < 60; i=(i+step) )); do 
 $(php '/home/wwwroot/default/wordpress/cronb.php') 
 echo i
 sleep $step 
 done 
 
 exit 0 

保存为crontab.sh

然后sh运行它就是了 测试下 是不是有了 每次redis有新数据 都会插入数据库后 然后移除