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