java读取redis数据（redis版本26）

本篇文章主要介绍了"java读取redis数据（redis版本26）"，主要涉及到方面的内容，对于Javajrs看球网直播吧_低调看直播体育app软件下载_低调看体育直播感兴趣的同学可以参考一下： import java.util.ArrayList;import java.util.List;import redis.clients.jedis.Jedi...

import java.util.ArrayList;
import java.util.List;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.ShardedJedis;
import redis.clients.jedis.ShardedJedisPool;
/**
 * @author liu
 *
 * @date 2015-8-25
 * @version 1.0
 */
public class InitialRedis {
   protected Jedis jedis;//非切片客户端连接
   private JedisPool jedisPool;//非切片连接池
   protected ShardedJedis shardedJedis;//切片(分布式)客户端连接
   private ShardedJedisPool shardedJedisPool;//切片连接池
   
   public InitialRedis() 
   { 
       initialPool(); 
       initialShardedPool(); 
       shardedJedis = shardedJedisPool.getResource(); 
       jedis = jedisPool.getResource(); 
       
       
   } 
 
   /**
    * 初始化非切片池
    */
   private void initialPool() 
   { 
       // 池基本配置 
       JedisPoolConfig config = new JedisPoolConfig(); 
       //config.setMaxActive(20); // 最大连接数
       config.setMaxIdle(5); // 最大空闲连接数
       config.setMaxWaitMillis(1000l); //获取连接时的最大等待毫秒数
       config.setTestOnBorrow(false); //在空闲时检查有效性, 默认false
       
       jedisPool = new JedisPool(config,"11.211.145.10",7001);
   }
   
   /** 
    * 初始化切片池 
    */ 
   private void initialShardedPool() 
   { 
       // 池基本配置 
       JedisPoolConfig config = new JedisPoolConfig(); 
       
       config.setMaxIdle(5); 
       config.setMaxWaitMillis(1000l); 
       config.setTestOnBorrow(false); 
       // slave 连接, 这里实现了集群的功能，配置多个redis服务实现请求的分配进行负载均衡
       List shards = new ArrayList(); 
       shards.add(new JedisShardInfo("11.211.145.10", 7001, "master")); 
       // 构造池 
       shardedJedisPool = new ShardedJedisPool(config, shards); 
   } 


}

import java.util.List;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import net.sf.json.JSONObject;
import org.junit.Test;
/**
 * @author liu
 *
 * @date 2015-8-26
 * @version 1.0
 */
public class ParseJson extends InitialRedis{
@Test
public void getjsondata() throws IOException{


         Set keys = jedis.keys("*"); 
         Iterator it=keys.iterator() ; 
         Map<>> map=new HashMap<>>();
        Map js HashMap();
         long starttime=System.currentTimeMillis();
         while(it.hasNext()){ 
         
           String key = it.next();
           
        
            //String type=jedis.type(key);
           String value=jedis.get(key);
           String keyvalue=key+":"+value;
           System.out.println("keyvalue::"+keyvalue);
          JSONObject js>           
          Iterator itor=jsonObject.keys();
           
          List js ArrayList();
           while(itor.hasNext()){
         
        String js>       
        String js>       
        //System.out.println(jsonkey+":"+jsonvalue);
        //jsonkeylist.add(jsonkey) ; 
        jsonmap.put(jsonkey, jsonvalue);
         
           }
              
                           
      
             
                      
             
         }





}

相关图片

相关文章