php - 数据先写进redis用队列,然后定时任务来写 mysql,如何实现?
PHP中文网
PHP中文网 2017-04-10 16:02:17
[PHP讨论组]

之前没接触过redis,能否详细给我解释下如何使用?百度了没找到典型例子啊

PHP中文网
PHP中文网

认证0级讲师

全部回复(5)
ringa_lee

用php-worker模式啊。大致应该如此

$cache_data = $redis->get_all();
$redis->flush_all();

$sqlArr = [];

for($item in $cache_data){
    array_push($sqlArr,sql_gen($item));
}

execute_sqls($sqlArr);

sleep($sleep_time);
黄舟

写个daemon不停的读redis就行了。

1.程序启动
2.读取新数据(按照timestamp排序获取最旧的)
3.没有数据,sleep 1秒
3.有数据,操作mysql,更新最后一次检查的时间戳timestamp

怪我咯

你不知道redis有消息队列功能么,让其它线程用blpop这种阻塞读取的模式从队列里读消息就可以了

大家讲道理

可以考虑两种方式:
(1)list作为缓存,借用producer/consumer模式
(2)Pub/Sub,订阅消息,写MySQL

伊谢尔伦

以前我在stackoverflow上也问过这个问题,好多答案都是说redis用list存,然后设置一个每分钟跑的cron任务去读这个list,为什么不用while (true)是因为长时间执行的php进程可能会造成内存泄漏。

不过现在我已经在尝试使用rabbitmq来实现队列了,效果也很不错哟。

热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号