用redis的队列,数据lpush进入,而后另外开个进程,while(true){brpop/rpop队列}php
下面用php作示例:mysql
a.php 文件里的代码redis
$redis->Redis(); $redis->connect($host, $port, $db); $redis->lpush('list', $data);
b.php 文件里的代码,为减小链接次数,注意不要一条一条插入,能够达到几百条批量一次入库sql
$redis->Redis(); $redis->connect($host, $port, $db); while(true) { $data = $redis->brpop('list', 0); if ($data) { // 链接mysql操做 // 插入数据 } }
用php命令执行b.php文件segmentfault
php b.php
==========================================code
更好的方法:daemon的读redis rabbitmq
https://segmentfault.com/q/1010000003731015队列
另外:进程
1.redis自己支持mqit
2.rabbitmq