java连接Redis的工具类

女爷i 2022-06-03 09:28 160阅读 0赞

package com.yanshu.tools;  
  
  
import redis.clients.jedis.Jedis;  
import redis.clients.jedis.JedisPool;  
import redis.clients.jedis.JedisPoolConfig;  
  
  
/\*\*  
 \* Redis工具类  
 \* @author Administrator  
 \*  
 \*/  
public class JedisUtils \{  
  
  
//Redis服务器IP  
    private static String ADDR = "127.0.0.1";  
      
    //Redis的端口号  
    private static int PORT = 6379;  
      
    //访问密码  
    private static String AUTH = "123456";  
      
    //可用连接实例的最大数目，默认值为8；  
    //如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。  
    private static int MAX\_ACTIVE = 1024;  
      
    //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。  
    private static int MAX\_IDLE = 200;  
      
    //等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；  
    private static int MAX\_WAIT = 10000;  
      
    private static int TIMEOUT = 10000;  
      
    //在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；  
    private static boolean TEST\_ON\_BORROW = true;  
      
    private static JedisPool jedisPool = null;  
      
    /\*\*  
     \* 初始化Redis连接池  
     \*/  
    static \{  
        try \{  
            JedisPoolConfig config = new JedisPoolConfig();  
            config.setMaxIdle(MAX\_IDLE);  
            config.setMaxWaitMillis(MAX\_WAIT);  
            config.setTestOnBorrow(TEST\_ON\_BORROW);  
            jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);  
        \} catch (Exception e) \{  
            e.printStackTrace();  
        \}  
    \}  
      
    /\*\*  
     \* 获取Jedis实例  
     \* @return  
     \*/  
    public synchronized static Jedis getJedis() \{  
        try \{  
            if (jedisPool != null) \{  
                Jedis resource = jedisPool.getResource();  
                return resource;  
            \} else \{  
                return null;  
            \}  
        \} catch (Exception e) \{  
            e.printStackTrace();  
            return null;  
        \}  
    \}  
      
    /\*\*  
     \* 释放jedis资源  
     \* @param jedis  
     \*/  
    public static void returnResource(final Jedis jedis) \{  
        if (jedis != null) \{  
            jedisPool.returnResource(jedis);  
        \}  
    \}

\----------

package com.yanshu.tools;  
  
  
import redis.clients.jedis.Jedis;  
  
  
public class JedisUtilsTest \{  
public static void main(String\[\] args) \{  
  
/\*Jedis jedis = new Jedis("106.75.132.229 ",6379);//创建连接  
 jedis.auth("zxasqw123");//设置密码  
   jedis.select(13);//数据的索引  
\*/     
     
   String key = "rds:task-test";//数据表的名称  
  
  
  String val = "\{'succeedDate': 1513152466.972549, 'taskUrl': \['https://hws.m.taobao.com/cache/wdetail/5.0/?id=521458057351 '\], 'headers': \{\}, 'proxy': 'True', 'taskName': 'hbase', 'saveSite': 'testAuctionHbase'\}";  
  
  
   //store data in redis list  
   //  jedis.lpush(key, val);  
   //  jedis.lpush(key, val);  
  
  
   //  System.out.println("Server is running: "+jedis.get("abc"));  
  //getJedis  
  Jedis jedis=JedisUtils.getJedis();  
  System.out.println("00000"+jedis.ping());  
   jedis.select(13);//数据的索引  
   jedis.lpush(key, val);  
   jedis.lpush(key, val);  
  
  
     System.out.println("Server is running: "+jedis.get("abc"));  
\}  
  
  
\}