游戏服务器之内存数据库redis客户端应用（上）

struct CBagItem  
{  
int m_nID;  //物品ID 
int m_nCount; //物品个数 默认一 
//物品的可变属性 
int m_nUsedHole;  //能用孔的个数 
int m_GremId[MAXGREMNUM];  //孔里面放置的宝石id 目前武器最多有5个孔 
int m_nDeadTime;  //使用的结束时间 
bool m_IsDead;    //是否到期 
bool m_IsBand;//是否帮定 
int m_augmentLevel; //强化等级 
int m_score; //装备评分 
public:  
strengthen m_nStreng;//装备属性 
int m_nCurNum;//当前已有进度 
int m_nUpNum; //下一等级升级所需数量 
};  

void CRWRedisClientOperator::add_equip_to_redis(CGamePlayer* player,int pos,CBagItem* bagItem)  
{  
if(NULL == player||NULL == bagItem))  
{  
return;  
}  
int playerId = player->get_player_base()->m_player_id;  
//实际是以玩家id和装备关键字来作为key。例如  ：  EQUIPMENTBAG%d 
char tmpBuf[256];  
memset(tmpBuf,0,sizeof(tmpBuf));  
sprintf(tmpBuf,"EQUIPMENTBAG%d",playerId);  
string key(tmpBuf);  
 
memset(tmpBuf,0,sizeof(tmpBuf));  
sprintf(tmpBuf,"%d",pos);  
string frield(tmpBuf);  
memset(tmpBuf,0,sizeof(tmpBuf));  
//这里可以直接用道具bagItem的地址是因为CBagItem类型里面的成员都是原子类型的，如果有容器（stl或其他的容器），则需要自己提供一个序列化的函数。 
memcpy(tmpBuf,(void*)bagItem,sizeof(CBagItem));  
string value;  
value.assign(tmpBuf,sizeof(CBagItem));//这里是把一个道具的内存存到一个字符串类型（string）的内存里，最大的长度是256字节，不可以超过这个长度。 
 
CRWRedisClient redisClient;  
redis::client* tmpRedisClient = redisClient.get_redis_client();//这里是redis客户端的一个实例池，做了个简单的封装 
if(NULL == tmpRedisClient)  
{  
return;  
}  
try 
{  
tmpRedisClient->hset(key,frield,value);//key : EQUIPMENTBAGplayerId  frield: pos value:CBagItem 
//设置过期时间 30天，需要设置redis内存数据的期限，鉴于内存受限 
tmpRedisClient->expire(key,3600*24*30);  
}  
catch (redis::redis_error & e)  
{  
cerr << "got exception: " << e.what() << endl << "FAIL" << endl;  
return;  
}  
}  

void CRWRedisClientOperator::player_equipbag_insert_db_redis(CGamePlayer* player)  
{  
 if(NULL == player)  
    {  
 return;  
    }  
    CPlayerBag* bag = player->get_player_bag();  
 if(NULL == bag)  
    {  
 return;  
    }  
 //玩家装备道具的map存储到strPairVec，然后调用接口void hmset( const string_type & key, const string_pair_vector & field_value_pairs )发送到redis 服务器 
    map<int,CBagItem*>* tmpMap = bag->get_equip_map();  
    map<int,CBagItem*>::iterator iter = tmpMap->begin();  
 
 //以hash格式插入redis的元素 
    vector<pair<string,string> > strPairVec;  
 for(;iter != tmpMap->end();iter++)  
    {  
        CBagItem* equipItem = iter->second;  
 if(NULL == equipItem)  
        {  
 return;  
        }  
 //设置frield值，道具id 
 char frieldBuf[64];  
        memset(frieldBuf, 0, sizeof(frieldBuf));  
        sprintf(frieldBuf,"%d",iter->first);  
        string frield(frieldBuf);  
 
 //设置value，道具二进制信息 
 char valueBuf[256];  
        memset(valueBuf, 0, sizeof(valueBuf));  
        memcpy(valueBuf,equipItem,sizeof(CBagItem));  
        string value;  
        value.assign(valueBuf,sizeof(CBagItem));  
        strPairVec.push_back(pair<string,string>(frield,value));  
    }  
 //通过playerId得到key值 EQUIPMENTBAGplayerId 
 int playerId = player->get_player_base()->m_player_id;  
 if(0 == playerId)  
    {  
 return;  
    }  
 char tmpBuf[64];  
    memset(tmpBuf,0,64);  
    sprintf(tmpBuf,"EQUIPMENTBAG%d",playerId);  
    string key(tmpBuf);  
 
    CRWRedisClient redisClient;  
    redis::client* tmpRedisClient = redisClient.get_redis_client();  
 if(NULL == tmpRedisClient)  
    {  
 return ;  
    }  
 try 
    {  
 //使用命令hmset 设置 key : EQUIPMENTBAGplayerId  frield: pos value:CBagItem 
        tmpRedisClient->hmset(key,strPairVec);  
 //设置过期时间 30天 
        tmpRedisClient->expire(key,60*60*24*30);  
    }  
 catch (redis::redis_error & e)  
    {  
        cerr << "got exception: " << e.what() << endl << "FAIL" << endl;  
 return ;  
    }  
}