redis 队列同步到mysql 方案

用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

相关文章
相关标签/搜索