Redis连接配置模块类

野性酷女 2022-05-19 12:07 69阅读 0赞

package com.\*\*\*

import redis.clients.jedis.Jedis;  
import redis.clients.jedis.JedisPool;  
import redis.clients.jedis.JedisPoolConfig;

public class JedisConnectUtil \{  
    private final static String IP\_ADDR = "192.168.1.000";//RedisIP地址  
    private final static int PORT = 6379;//端口  
    private static final int TIMEOUT = 300;//超时  
//    private final static String AUTH = "";  
      
    //连接池config配置信息  
    private final static int MAX\_IDLE = 5000;  
    private final static int MAX\_WAIT = 1000000;  
    private final static int MAX\_TOTAL = 10240;  
    private final static boolean TEST\_ON\_BORROW = true;  
    private final static boolean TEST\_ON\_RETURE = true;  
    private final static int MAX\_INDEX = 16;  
    private static JedisPool\[\] jedisPool = null;  
      
    static\{  
        // 构建连接池配置信息  
        JedisPoolConfig config = new JedisPoolConfig();  
        config.setMaxIdle(MAX\_IDLE);  
        config.setMaxWaitMillis(MAX\_WAIT);  
        // 设置最大连接数  
        config.setMaxTotal(MAX\_TOTAL);  
        config.setTestOnBorrow(TEST\_ON\_BORROW);  
        config.setTestOnReturn(TEST\_ON\_RETURE);  
        // 根据配置实例化jedis池  
        jedisPool = new JedisPool\[MAX\_INDEX\];  
        for (int i = 0; i < jedisPool.length; i++) \{  
            jedisPool\[i\] = new JedisPool(config, IP\_ADDR, PORT, TIMEOUT, null, i);  
        \}  
    \}  
      
    /\*\*  
     \* 【\*\*系统】链接redis数据库【内网db\*】  
     \* @return  
     \*/  
    public static Jedis getJedisDB()\{  
        return getJedisDB(\*);  
    \}  
    /\*\*  
     \* 使用jedis 链接【\*\*项目】redis数据库【内网db0】  
     \* @return  
     \*/  
    public static Jedis getJedisDB0()\{  
        return getJedisDB(0);  
    \}  
      
    /\*\*  
     \* 选择连接Redis的一个库\[共16个：db0~db15\]  
     \* @param index 库的索引  
     \* @return  
     \*/  
    public synchronized static Jedis getJedisDB(int index)\{  
        if (jedisPool != null)\{  
            return jedisPool\[index\].getResource();  
        \}  
        return null;  
    \}  
      
    /\*\*  
     \* 关闭jedis连接(jedis操作完之后需要关闭)  
     \* @param jedis  
     \*/  
    public static void close(final Jedis jedis)\{  
        if (jedis != null) \{  
            jedis.close();  
        \}  
    \}  
\}