精品蜜臀久久久久99网站,久久99国内精品自在现线,国产亚洲精品久久久久秋霞

hiredis異步接口封裝并導(dǎo)出到Lua

hiredis異步接口封裝并導(dǎo)出到Lua

(金慶的專(zhuān)欄 2017.1)

hiredis 不支持 Windows, Windows 下使用 wasppdotorg / hiredis-for-windows 。
Linux 下仍是 redis/hiredis。
hiredis-for-windows 是以 hiredis 0.13.3 為基礎(chǔ)移植的。

hiredis-for-windows 需要稍加修正：
   * 去除 inline 宏
   * TCP_NODELAY 改在連接之前設(shè)置。
詳見(jiàn)其Issue.

Cluster 支持采用 shinberg/cpp-hiredis-cluster。這是個(gè)CPP庫(kù)，支持異步，
要求 hiredis >= 0.12.0。
jinq0123/cpp-hiredis-cluster 在 develop 分支上更改了接口，讓它更好用。

因?yàn)榫W(wǎng)絡(luò)庫(kù)是boost asio, 所以需要asio適配器，采用 jinq0123/hiredis-boostasio-adapter。

cpp-hiredis-cluster 提供的是統(tǒng)一的Command接口，接收字符串命令，返回 redisReply.
對(duì)于常用命令，需要更簡(jiǎn)單的接口。
在Lua手游服務(wù)器代碼中新建CRedis類(lèi)，封裝 cpp-hiredis-cluster，
為常用redis命令封裝更好用的接口。
CRedis類(lèi)封裝了asio, 接口是根據(jù)應(yīng)用需要定義的，所以是專(zhuān)用接口，
不在 cpp-hiredis-cluster 中實(shí)現(xiàn)。

bool CRedis::Init(io_service& rIos, const std::string& sHost, uint16_t uPort)
創(chuàng)建 RedisCluster 對(duì)象。
io_service 用于創(chuàng)建一個(gè) redis 事件適配器，
RedisCluster創(chuàng)建需要一個(gè)適配器。
sHost, uPort 用于初始化連接redis cluster, 獲取集群信息。

using Cmd = RedisCluster::AsyncHiredisCommand;

bool CRedis::Init(io_service& rIos, const std::string& sHost, uint16_t uPort)
{
   m_pAdapter.reset(new Adapter(rIos));
   try
   {
       m_pCluster.reset(Cmd::createCluster("127.0.0.1", 7000, *m_pAdapter));
   }
   catch (const RedisCluster::ClusterException &e)
   {
       LOG_ERROR("Cluster exception: " << e.what());
       return false;
   }

   return true;
}

static Cmd::Action handleException(const RedisCluster::ClusterException &exception,
   RedisCluster::HiredisProcess::processState state)
{
   // Check the exception type.
   // Retry in case of non-critical exceptions.
   if (!dynamic_cast<const RedisCluster::CriticalException*>(&exception))
   {
       LOG_WARN("Exception in processing async redis callback: "
           << exception.what() << " Retry...");
       // retry to send a command to redis node
       return Cmd::RETRY;
   }
   LOG_ERROR("Critical exception in processing async redis callback: "
       << exception.what());
   return Cmd::FINISH;
}

static void handleSetReply(const redisReply &reply, const CRedis::SetCb& setCb)
{
   if (!setCb) return;
   if (reply.type == REDIS_REPLY_STATUS)
   {
       const std::string OK("OK");
       if (OK == reply.str)
       {
           setCb(true);
           return;
       }
   }

   LOG_WARN("Set reply: " << reply.str);
   setCb(false);
}

void CRedis::Set(const string& sKey, const string& sValue, const SetCb& setCb)
{
   assert(m_pCluster);
   Cmd::commandf2(*m_pCluster, sKey,
       [setCb](const redisReply& reply) {
           handleSetReply(reply, setCb);
       },
       handleException,
       "set %s %s", sKey.c_str(), sValue.c_str());
}

static void handleGetReply(const redisReply& reply,
   const CRedis::ReplyStringCb& hdlStrReply)
{
   if (!hdlStrReply) return;
   using Rt = CRedis::ReplyType;
   if (reply.type == REDIS_REPLY_NIL)
   {
       hdlStrReply(Rt::NIL, "");
       return;
   }
   std::string sReply(reply.str, reply.len);
   if (reply.type == REDIS_REPLY_STRING)
       hdlStrReply(Rt::OK, sReply);
   else
       hdlStrReply(Rt::ERR, sReply);
}

void CRedis::Get(const std::string& sKey, const ReplyStringCb& hdlStrRepl)
{
   assert(m_pCluster);
   Cmd::commandf2(*m_pCluster, sKey,
       [hdlStrRepl](const redisReply& reply) {
           handleGetReply(reply, hdlStrRepl);
       },
       handleException,
       "get %s", sKey.c_str());
}

handleException 是Cmd::command() 接口中需要的異常處理，這里是盡量重試。

Cmd::command() 中的第3個(gè)參數(shù)是 redis 應(yīng)答的回調(diào)，讀取 redisReply, 然后觸發(fā)命令的回調(diào)。

CRedis::Get() 執(zhí)行 redis GET 命令，固定1個(gè)參數(shù)，返回是字符串，nil, 或錯(cuò)誤。

   enum class ReplyType
   {
       OK = 0, // redis replys string/integer/array
       NIL = 1, // redis replys nil
       ERR = 2, // redis replys error status
   };

   // 簡(jiǎn)單的常用命令會(huì)自動(dòng)解析reply, 使用更易用的回調(diào)。
   using ReplyStringCb = function<void (ReplyType, const string& sReply)>;

CRedis::Get() 的回調(diào)就是 ReplyStringCb。

void CRedis::Set() 的回調(diào)只需知道成功或失敗，SetCb 定義為：
   using SetCb = function<void (bool ok)>;

失敗時(shí)會(huì)有錯(cuò)誤信息，已統(tǒng)一打印日志，不再暴露出來(lái)。

SET 命令完整的參數(shù)列表還有其他參數(shù)：
set key value [EX seconds] [PX milliseconds] [NX|XX]

因?yàn)槌Ｓ玫木?"set key value", 其他擴(kuò)展的命令需要使用通用的 command() 接口，
并需要讀取 redisReply.

使用 LuaIntf 導(dǎo)出 CRedis 到 Lua.
因?yàn)橹挥幸粋€(gè) CRedis, 所以導(dǎo)出為模塊 c_redis:

#include <LuaIntf/LuaIntf.h>

namespace {

void Set(const string& sKey, const string& sValue, const LuaRef& luaSetCb)
{
   // Default is empty callback.
   auto setCb = ToFunction<CRedis::SetCb>(luaSetCb);
   GetRedis().Set(sKey, sValue, setCb);
}

void Get(const string& sKey, const LuaRef& luaReplyStringCb)
{
   auto replyStringCb = ToFunction<CRedis::ReplyStringCb>(
       luaReplyStringCb);
   GetRedis().Get(sKey, replyStringCb);
}

} // namespace

void Bind(lua_State* L)
{
   LuaBinding(L).beginModule("c_redis")
       .addFunction("set", &Set)
       .addFunction("get", &Get)
   .endModule();
}

需要將 lua 的回調(diào)函數(shù)轉(zhuǎn)成 cpp 的回調(diào)：

template <class Function>
Function ToFunction(const LuaIntf::LuaRef& luaFunction)
{
   // Default is empty.
   if (!luaFunction)
       return Function(); // skip nil
   if (luaFunction.isFunction())
       return luaFunction.toValue<Function>(); // Todo: catch
   LOG_WARN_TO("ToFunction", "Lua function expected, but got "
       << luaFunction.typeName());
   return Function();
}

Lua 這樣調(diào)用：
c_redis.set("FOO", "1234")
c_redis.set("FOO", "1234", function(ok) print(ok) end)
c_redis.get("FOO", function(reply_type, reply)
   assert("string" == type(reply))
   if 0 == reply_type or 1 == reply_type then
       print("FOO="..reply)
   else
       print("Error: "..reply)
   end
end)

posted on 2017-01-05 18:42 金慶閱讀(1003) 評(píng)論(0) 編輯收藏引用所屬分類(lèi): 1. C/C++ 、2. 網(wǎng)游開(kāi)發(fā)

只有注冊(cè)用戶(hù)登錄后才能發(fā)表評(píng)論。
【推薦】100%開(kāi)源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: How are dtLinks created in NavMesh C++ parameter passing rules Naming Conventions for Accessors Visual Studio 2019 Compiler Hangs Fbx File Format Identifier 查找內(nèi)存錯(cuò)誤 std::thread 中的異常會(huì)丟失調(diào)用棧用賦值代替 protobuf CopyFrom() vs2017 linux 編譯輸出改成 vs 格式為 LiteIDE 添加選中標(biāo)記

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問(wèn) Chat2DB 管理

金慶的專(zhuān)欄

公告

留言簿(12)

隨筆分類(lèi)(502)

隨筆檔案(423)

相冊(cè)

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜