Redis队列缓存应用示例

消息队列的一个典型应用就是通过异步处理方式，来解决某些场景下的高并发问题 例如日志的收集，特点是数据量大，并发压力大，不宜直接插入数据库，但实时性要求不高，所以适合使用消息队列缓存日志信息，然后批量进行处理 基本思路 （1）日志信息插入队列缓存 （2）定时读取缓存 批量入库 实现 下面是简单的伪代码示例 （1）日志入队 并发量很高，处理过程应尽量简洁 可以做成接口，供日志记录程序调用 //取得日志信息 var info = getinfo(); //添加时间戳 info += "|" + time(); //放入队列 redis.lpush("log", info); （2）入库处理 每分钟从队列中获取N条信息，批量插入数据库 插入过程如果出现错误，需要把失败的信息再次入队，以便下次重新入库 //目标读取信息数量 var count = N; //回滚信息数组 var arr_rollback = array(); //获取消息队列的内容，拼接sql /** 批量insert的格式为： INSERT INTO users(name, age) VALUES ('姚明', 25), ('盖茨', 50), ('火星人', 600); */ var sql = "insert into log (`content`, `createtime`) values "; //循环读取日志信息，拼接sql for(var i=0; i<count; i++){ //从消息队列获取信息 var info = redis.rpop("log"); //如果没有取到信息，停止循环 if(empty(info)){ break; } //添加到回滚数组 arr_rollback.push(info); //分割信息，取得日志内容和时间戳 var arr = split(info, "|"); var loginfo = arr[0]; var time = arr[1]; //拼接sql sql += " ('" + loginfo + "','" + time + "'),"; } //执行插入数据库操作 sql = rtrim(sql,",")+";"; var result = mysql_query(sql); //插入失败回滚 if(!result){ foreach(arr_rollback as rec){ redis.lpush("log", rec); } } （3）设置定时 可以使用定时器，也可以用最简单的系统定时任务