redis存储和查询的java实现

问题导读：
1、Redis是什么？
2、Redis的性能如何？
3、redis.conf的主要配置参数的意义？



1.Redis简介Redis是一个key-value存储系统。和Memcached类似，但是解决了断电后数据完全丢失的情况，而且她支持更多无化的value类型，除了和string外，还支持lists（链表）、sets（集合）和zsets（有序集合）几种数据类型。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。

2.Redis的性能
官方数据：每秒可存110000条 , 每秒可取 81000 条.

3.安装RedisRedis的代码遵循ANSI-C编写，系统（如Linux,等）上安装运行。而且Redis并不依赖任何非标准库，也没有编译参数必需添加。
先去官网下载源码：

wget http://redis.googlecode.com/files/redis-2.4.6.tar.gz
复制代码

解压：

tar –zxvf redis-2.4.6.tar.gz
复制代码

编译需要说明的事，redis的安装非常简单，已经有现成的Makefile文件，直接运行make命令即可。

make

make install
复制代码

Redis 由四个可执行文件：redis-benchmark、redis-cli、redis-server、redis-stat这四个文件，加上一个redis.conf就构成了整个redis的最终可用包。它们的作用如下：

• redis-server：Redis服务器的daemon启动程序
• redis-cli：Redis命令行操作工具。当然，你也可以用telnet根据其纯文本协议来操作
• redis-benchmark：Redis性能测试工具，测试Redis在你的系统及你的配置下的读写性能
• redis-stat：Redis状态检测工具，可以检测Redis当前状态参数及延迟状况
  

现在就可以启动redis了，redis只有一个启动参数，就是他的配置文件路径。

redis-server /etc/redis.conf
复制代码

注意，默认复制过去的redis.conf文件的daemonize参数为no，所以redis不会在后台运行，这时要测试，我们需要重新开一个终端。修改为yes则为后台运行redis。另外配置文件中规定了pid文件，log文件和数据文件的地址，如果有需要先修改，默认log信息定向到stdout.
下面是redis.conf的主要配置参数的意义：

• daemonize：是否以后台daemon方式运行
• pidfile：pid文件位置
• port：监听的端口号
• timeout：请求超时时间
• loglevel：log信息级别
• logfile：log文件位置
• databases：开启数据库的数量
• save * *：保存快照的频率，第一个*表示多长时间，第三个*表示执行多少次写操作。在一定时间内执行一定数量的写操作时，自动保存快照。可设置多个条件。
• rdbcompression：是否使用压缩
• dbfilename：数据快照文件名（只是文件名，不包括目录）
• dir：数据快照的保存目录（这个是目录）
• appendonly：是否开启appendonlylog，开启的话每次写操作会记一条log，这会提高数据抗风险能力，但影响效率。
• appendfsync：appendonlylog如何同步到磁盘（三个选项，分别是每次写都强制调用fsync、每秒启用一次fsync、不调用fsync等待系统自己同步）
  

这时你可以打开一个终端进行测试了，配置文件中默认的监听端口是6379
我们可以开启一个Redis客户端进行测试

[root@test01 ~]# redis-cli
Could not connect to Redis at 127.0.0.1:6379: Connection refused
not connected> exit
[root@test01 ~]# redis-server /etc/redis.conf
[root@test01 ~]# redis-cli
redis 127.0.0.1:6379> quit
复制代码

4.常用操作
通过java 调用redis API，实现存储和查询：

    import com.agd.utils.PropertiesUtils;  
      
    import redis.clients.jedis.JedisPool;  
    import redis.clients.jedis.JedisPoolConfig;  
      
    /** 
     *  取redis 连接池 
     * <一句话功能简述> 
     * <功能详细描述> 
     *  
     * @author  khj 
     * @see  [相关类/方法] 
     * @since  [产品/模块版本] 
     */  
    public class RedisClientPool  
    {  
     public static RedisClientPool redisClientPool = getInstance();  
          
        public static JedisPool jedisPool;  
          
        public static synchronized RedisClientPool getInstance()  
        {  
            if (null == redisClientPool)  
            {  
                redisClientPool = new RedisClientPool();  
            }  
            return redisClientPool;  
        }  
          
        public RedisClientPool()  
        {  
            if (null == jedisPool)  
            {  
                init();  
            }  
        }  
          
        /** 
         *   初始化Jedis 
         * <一句话功能简述> 
         * <功能详细描述> 
         * @return 
         * @see [类、类#方法、类#成员] 
         */  
        private static JedisPoolConfig initPoolConfig()  
        {  
            JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();  
            // 控制一个pool最多有多少个状态为idle的jedis实例  
            jedisPoolConfig.setMaxIdle(1000);  
            // 最大能够保持空闲状态的对象数  
            jedisPoolConfig.setMaxIdle(300);  
            // 超时时间  
            jedisPoolConfig.setMaxWaitMillis(1000);  
            // 在borrow一个jedis实例时，是否提前进行alidate操作；如果为true，则得到的jedis实例均是可用的；  
            jedisPoolConfig.setTestOnBorrow(true);  
            // 在还会给pool时，是否提前进行validate操作  
            jedisPoolConfig.setTestOnReturn(true);  
              
            return jedisPoolConfig;  
        }  
          
        /** 
         * 初始化jedis连接池 
         */  
        public static void init()  
        {  
            JedisPoolConfig jedisPoolConfig = initPoolConfig();  
            String host = PropertiesUtils.getValue("redis.host");//"localhost";  
            int port = Integer.parseInt(PropertiesUtils.getValue("redis.port"));//6379;  
            int timeout = Integer.parseInt(PropertiesUtils.getValue("redis.timeout"));//60000;  
            // 构造连接池  
            jedisPool = new JedisPool(jedisPoolConfig, host, port, timeout);  
        }  
复制代码

    import java.util.List;  
    import java.util.Map;  
    import java.util.concurrent.ConcurrentHashMap;  
      
    import redis.clients.jedis.Jedis;  
      
    /** 
     *  redis 操作api 
     * <一句话功能简述> 
     * <功能详细描述> 
     *  
     * @author  khj 
     * @see  [相关类/方法] 
     * @since  [产品/模块版本] 
     */  
    public class RedisClient   
    {  
        /** 
         *  保存数据   类型为 Map 
         * <一句话功能简述> 
         * <功能详细描述> 
         * @param flag 
         * @param mapData 
         * @see [类、类#方法、类#成员] 
         */  
        public static void setMapDataToRedis(String flag,Map<String,String> mapData)  
        {         
            Jedis redisClient = null;  
            try  
            {  
                redisClient = RedisClientPool.jedisPool.getResource();  
                redisClient.hmset(flag,mapData);  
            }   
            catch (Exception e)  
            {  
                // 销毁对象  
                RedisClientPool.jedisPool.returnBrokenResource(redisClient);  
            }  
            finally  
            {  
                // 还原到连接池  
                RedisClientPool.jedisPool.returnResource(redisClient);  
            }  
        }  
          
        /** 
         *  保存数据   类型为 key-value 
         * <一句话功能简述> 
         * <功能详细描述> 
         * @param flag 
         * @param field 
         * @param value 
         * @see [类、类#方法、类#成员] 
         */  
        public static void setDataToRedis(String flag,String field,String value)  
        {  
            Jedis redisClient = null;  
            try  
            {  
                redisClient = RedisClientPool.jedisPool.getResource();  
                redisClient.hset(flag, field, value);  
            }   
            catch (Exception e)  
            {  
                // 销毁对象  
                RedisClientPool.jedisPool.returnBrokenResource(redisClient);  
            }  
            finally  
            {  
                // 还原到连接池  
                RedisClientPool.jedisPool.returnResource(redisClient);  
            }  
        }  
          
        /** 
         *  获取Map数据 
         * <一句话功能简述> 
         * <功能详细描述> 
         * @param flag 
         * @return 
         * @see [类、类#方法、类#成员] 
         */  
        public static Map<String,String> getMapData(String flag)  
        {  
            Map<String,String> dataMap = null;  
              
            Jedis redisClient = null;  
            try  
            {  
                redisClient = RedisClientPool.jedisPool.getResource();  
                dataMap = redisClient.hgetAll(flag);  
            }   
            catch (Exception e)  
            {  
                // 销毁对象  
                RedisClientPool.jedisPool.returnBrokenResource(redisClient);  
            }  
            finally  
            {  
                // 还原到连接池  
                RedisClientPool.jedisPool.returnResource(redisClient);  
            }  
            return dataMap;  
        }  
          
        public static long deleteData(String flag)  
        {  
            long result = 0;  
            Jedis redisClient = null;  
            try  
            {  
                redisClient = RedisClientPool.jedisPool.getResource();  
                result = redisClient.del(flag);  
            }   
            catch (Exception e)  
            {  
                // 销毁对象  
                RedisClientPool.jedisPool.returnBrokenResource(redisClient);  
            }  
            finally  
            {  
                // 还原到连接池  
                RedisClientPool.jedisPool.returnResource(redisClient);  
            }  
              
            return result;  
        }  
          
        /** 
         * 根据key和字段获取数据  
         * <一句话功能简述> 
         * <功能详细描述> 
         * @param flag 
         * @param field 
         * @return 
         * @see [类、类#方法、类#成员] 
         */  
        public static String getData(String flag,String field)  
        {  
            String data = null;  
            Jedis redisClient = null;  
            try  
            {  
                redisClient = RedisClientPool.jedisPool.getResource();  
                data = redisClient.hget(flag, field);  
            }   
            catch (Exception e)  
            {  
                // 销毁对象  
                RedisClientPool.jedisPool.returnBrokenResource(redisClient);  
            }  
            finally  
            {  
                // 还原到连接池  
                RedisClientPool.jedisPool.returnResource(redisClient);  
            }  
              
            return data;  
        }  
      
          
        public static void main(String[] args)  throws Exception  
        {           
            RedisClient.testMap();    
        }    
          
          
        public void testList()  
        {    
           Jedis redis = RedisClientPool.jedisPool.getResource();  
            //hset key field value将哈希表key中的域field的值设为value。   
            redis.hset("table", "field1", "value1");   
            redis.hset("table", "field2", "value2");   
            redis.hset("table", "field3", "value3");   
            //返回哈希表key中，一个或多个给定域的值。   
            List<String> list = redis.hmget("table","field1","field2","field3");   
            for(String tmp : list)  
            {   
                System.out.println(tmp);   
            }   
        }  
          
        public static void testMap()  
        {  
            //同时将多个field - value(域-值)对设置到哈希表key中。   
            Map<String,String> map = new ConcurrentHashMap<String,String>();  
            for (int i = 0;i < 10000;i++)  
            {  
                map.put("field"+i, "value"+i);   
            }  
            if (null != getData("table", "field1"))  
            {  
                deleteData("table");  
            }  
            //得到map下面的username的值   
            Map<String,String> maps = getMapData("table");  
            System.out.println(maps.size());  
              
            setMapDataToRedis("table",map);  
      
            //HGETALL key返回哈希表key中，所有的域和值。   
            maps = getMapData("table");   
             
            System.out.println(maps.size());  
        }  
      
    }  
复制代码

资料来源：http://blog.csdn.net/kuanghongjiang/article/details/45061863