V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
weixiaoyao
V2EX  ›  Redis

hiredis 库如何实现事务

  •  
  •   weixiaoyao · 2018-11-22 14:40:31 +08:00 · 4353 次点击
    这是一个创建于 1953 天前的主题,其中的信息可能已经有所发展或是发生改变。

    近期使用 hiredis 库,用到了 pipeline 的方式,但是 pipiline 无法解决多客户端时可能操作同样 key 的竞争问题,想使用事务方式,但是不知道该怎么实现,有用过的朋友可以指点下么,谢谢了。 下面是用 redisAppendCommand 和 redisGetReply 实现的 pipeline 方式

    //输入命令写入缓冲区
    int nCmdCount = vecPipelineCmd.size();
    for (int i = 0; i < nCmdCount; i++)
    {
    	redisAppendCommand(m_pContext, vecPipelineCmd[i].c_str());
    }
    
    //批量发送命令并获取批量回复结果,redisGetReply 的调用次数必须和 redisAppendCommand 一致
    nSuccessCnt = 0;
    for (int i = 0; i < nCmdCount; i++)
    {
    	bool bStatus = false;
    	string strRsp("");
    	redisReply* reply = NULL;
    
    	if(redisGetReply(m_pContext, (void**)&reply) == REDIS_OK && reply != NULL && reply->type == REDIS_REPLY_STRING)
    	{
    		bStatus = true;
    		strRsp = reply->str;
    		nSuccessCnt++;
    	}
    
    	//释放 reply 的内存空间
    	freeReplyObject(reply);
    
    	vecPipelineStatus.push_back(bStatus);
    	vecPipelineRsp.push_back(strRsp);
    }
    
    目前尚无回复
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   4911 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 26ms · UTC 09:53 · PVG 17:53 · LAX 02:53 · JFK 05:53
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.