热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

数据先写进redis用队列,然后定时任务来写mysql,如何实现?

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

回复内容:

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

用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);

后台运行:

chmod a+x /png/php_daemon #给脚本加上执行权限
nohup /png/php_daemon >/png/php_daemon.log 2>&1 &

或者添加到/etc/rc.local,让其开机自启动运行:

/png/php_daemon >/png/php_daemon.log

php_daemon内容:

#!/png/php/7.0.0/bin/php

补充:
PHP提供有2个预定义变量用于PHP脚本接收命令行参数:
http://php.net/manual/zh/reserved.variables.php
$argc 传递给脚本的参数个数
$argv[] 传递给脚本的参数数组

getopt可以用于获取命令行参数选项,返回一个参数名和值的关联数组.
http://php.net/manual/zh/function.getopt.php
单独的字符(不接受值)
后面跟随冒号的字符(此选项需要值)
后面跟随两个冒号的字符(此选项的值可选)

#!/png/php/5.4.39NTS/bin/php
chmod +x cli.php
./cli.php -a1024 -b2048 或者 php cli.php -a1024 -b2048

输出:

Array
(
    [a] => 1024
    [b] => 2048
)

注释掉 $argv = getopt("a:b:") 输出:

Array
(
    [0] => ./cli.php
    [1] => -a1024
    [2] => -b2048
)

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

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

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

用这个:https://github.com/Footstones/Plumber

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

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

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

推荐阅读
  • 本文介绍了在开发Android新闻App时,搭建本地服务器的步骤。通过使用XAMPP软件,可以一键式搭建起开发环境,包括Apache、MySQL、PHP、PERL。在本地服务器上新建数据库和表,并设置相应的属性。最后,给出了创建new表的SQL语句。这个教程适合初学者参考。 ... [详细]
  • 分享css中提升优先级属性!important的用法总结
    web前端|css教程css!importantweb前端-css教程本文分享css中提升优先级属性!important的用法总结微信门店展示源码,vscode如何管理站点,ubu ... [详细]
  • 篇首语:本文由编程笔记#小编为大家整理,主要介绍了软件测试知识点之数据库压力测试方法小结相关的知识,希望对你有一定的参考价值。 ... [详细]
  • 搭建Windows Server 2012 R2 IIS8.5+PHP(FastCGI)+MySQL环境的详细步骤
    本文详细介绍了搭建Windows Server 2012 R2 IIS8.5+PHP(FastCGI)+MySQL环境的步骤,包括环境说明、相关软件下载的地址以及所需的插件下载地址。 ... [详细]
  • 本文介绍了如何使用php限制数据库插入的条数并显示每次插入数据库之间的数据数目,以及避免重复提交的方法。同时还介绍了如何限制某一个数据库用户的并发连接数,以及设置数据库的连接数和连接超时时间的方法。最后提供了一些关于浏览器在线用户数和数据库连接数量比例的参考值。 ... [详细]
  • 本文介绍了Redis的基础数据结构string的应用场景,并以面试的形式进行问答讲解,帮助读者更好地理解和应用Redis。同时,描述了一位面试者的心理状态和面试官的行为。 ... [详细]
  • 在说Hibernate映射前,我们先来了解下对象关系映射ORM。ORM的实现思想就是将关系数据库中表的数据映射成对象,以对象的形式展现。这样开发人员就可以把对数据库的操作转化为对 ... [详细]
  • 本文由编程笔记小编整理,介绍了PHP中的MySQL函数库及其常用函数,包括mysql_connect、mysql_error、mysql_select_db、mysql_query、mysql_affected_row、mysql_close等。希望对读者有一定的参考价值。 ... [详细]
  • yum安装_Redis —yum安装全过程
    篇首语:本文由编程笔记#小编为大家整理,主要介绍了Redis—yum安装全过程相关的知识,希望对你有一定的参考价值。访问https://redi ... [详细]
  • 解决VS写C#项目导入MySQL数据源报错“You have a usable connection already”问题的正确方法
    本文介绍了在VS写C#项目导入MySQL数据源时出现报错“You have a usable connection already”的问题,并给出了正确的解决方法。详细描述了问题的出现情况和报错信息,并提供了解决该问题的步骤和注意事项。 ... [详细]
  • Java验证码——kaptcha的使用配置及样式
    本文介绍了如何使用kaptcha库来实现Java验证码的配置和样式设置,包括pom.xml的依赖配置和web.xml中servlet的配置。 ... [详细]
  • 众筹商城与传统商城的区别及php众筹网站的程序源码
    本文介绍了众筹商城与传统商城的区别,包括所售产品和玩法不同以及运营方式不同。同时还提到了php众筹网站的程序源码和方维众筹的安装和环境问题。 ... [详细]
  • 如何在php中将mysql查询结果赋值给变量
    本文介绍了在php中将mysql查询结果赋值给变量的方法,包括从mysql表中查询count(学号)并赋值给一个变量,以及如何将sql中查询单条结果赋值给php页面的一个变量。同时还讨论了php调用mysql查询结果到变量的方法,并提供了示例代码。 ... [详细]
  • 一次上线事故,30岁+的程序员踩坑经验之谈
    本文主要介绍了一位30岁+的程序员在一次上线事故中踩坑的经验之谈。文章提到了在双十一活动期间,作为一个在线医疗项目,他们进行了优惠折扣活动的升级改造。然而,在上线前的最后一天,由于大量数据请求,导致部分接口出现问题。作者通过部署两台opentsdb来解决问题,但读数据的opentsdb仍然经常假死。作者只能查询最近24小时的数据。这次事故给他带来了很多教训和经验。 ... [详细]
  • 本文介绍了关系型数据库和NoSQL数据库的概念和特点,列举了主流的关系型数据库和NoSQL数据库,同时描述了它们在新闻、电商抢购信息和微博热点信息等场景中的应用。此外,还提供了MySQL配置文件的相关内容。 ... [详细]
author-avatar
欢乐文艺女青年
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有