dqysi86208 2015-11-16 12:08
浏览 102
已采纳

在php循环中将数据写入redis时发生了有趣的事情

i wrote a php script to pull data from one server (lets call it Server A) to the other (Server B). data in server A is a redis list stores all the operating commands need to be written in server B, such as :

["setex",["session:xxxx",604800,"xxxx"]]
["set",["uid:xxx","xxxxx"]]
["pipeline",[]]
["set",["uid:xxx","xxxxx"]]
["hIncrBy",["Signin:xxxx","totalTimes",1]]
["pipeline",[]]
....

my php codes are :

while($i < 1000){
    $line = $redis['server_a']->rpop('sync:op');
    list($op,$params) = json_decode($line,1);
    $r = call_user_func_array(array($redis['server_b'], $op), $params);

    $i++;
}

The wired thing is, when the call_user_func_array method executes the redis command uncorrectly, all the rest commands in the queue cannot be written correctly into server B.

i stuck in this problem almost one week for seeking answers. after thousands of tests i found if i remove the "bad commands" that cannot be executed correctly, such as the ["pipeline",[]] row. all the other commands can be inserted properly. so it reminds me of some redis transaction issue. maybe there are some machanisms that when a command executed unproperly in redis , all the other commands afterwards will be treated as a transaction. so i add a exec() command into the while loop :

 while($i < 1000){
    $line = $redis['server_a']->rpop('sync:op');
    list($op,$params) = json_decode($line,1);
    $r = call_user_func_array(array($redis['server_b'], $op), $params);
    $redis['server_b']->exec(); //this is the significant update
    $i++;
}

then, my problem solved !!!

My question is , can anybody help me explain the redis machanism? is my assumption correct ?

  • 写回答

1条回答 默认 最新

  • duanguan3863 2015-11-16 12:51
    关注

    Your library is probably using transactions for pipelining for whatever reason. pipeline is no actual Redis command, see http://redis.io/commands

    Just strip all pipeline commands with empty arguments or just use ->exec when you issued a pipeline before.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 BP神经网络控制倒立摆
  • ¥20 要这个数学建模编程的代码 并且能完整允许出来结果 完整的过程和数据的结果
  • ¥15 html5+css和javascript有人可以帮吗?图片要怎么插入代码里面啊
  • ¥30 Unity接入微信SDK 无法开启摄像头
  • ¥20 有偿 写代码 要用特定的软件anaconda 里的jvpyter 用python3写
  • ¥20 cad图纸,chx-3六轴码垛机器人
  • ¥15 移动摄像头专网需要解vlan
  • ¥20 access多表提取相同字段数据并合并
  • ¥20 基于MSP430f5529的MPU6050驱动,求出欧拉角
  • ¥20 Java-Oj-桌布的计算