Redisパイピングストレージ--簡単な例

まずredis接続を取得

   //  IP,  ,    
   Jedis j = new Jedis("127.0.0.1",6379,1000);
   //    DB
   j.select(1);
   //    
   Pipeline pipeline = j.pipelined();

/*List    ，lpush key value value ... */
public void addRuleConditionToRedis(Pipeline pipeline) {
        for(Map< String, Object> map : oldObjects){
            pipeline.lpush("orule:" + "condi:" + map.get("ObjectRuleID").toString(),
                    map.get("ObjectRuleConditionID").toString());
        }
        //  
        pipeline.sync();
}

 /*Hash    ，hmset ket Map< String,String>*/
   public void storeRuleCondition(List< Map< String, Object>> mapList) {
        Pipeline pipeline = client.pipelined();
        for(Map< String, Object> map : mapList){
            Map< String,String> map2 = new HashMap<>();
            map2.put("RuleDataType",map.get("RuleDataType").toString());
            map2.put("LogicType",map.get("LogicType").toString());
            pipeline.hmset("orule:condi-type:" + map.get("ObjectRuleConditionID").toString(),map2);
        }
        //  
        pipeline.sync();
    }

    /*Set    ，sadd key value value ...*/
    for(Map< String, Object> map : mapList){
        pipeline.sadd("orule:condi_cont_dict:" + 
            map.get("ObjectRuleConditionID").toString(), dictId);
    }
    //  
    pipeline.sync();