Java操作redis-阿里云开发者社区

Java操作redis

2016-05-26 4246

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

云数据库 Tair（兼容Redis），内存型 2GB

Redis 开源版，标准版 2GB

简介：

Java操作redis很简单。创建一个普通的Java工程。然后导入redis依赖的jar包。jar包我已经上传了。

1.入门级的demo

    入门级demo代码  
    
  
package com.bjsxt.test;  
  
import redis.clients.jedis.Jedis;  
  
public class RedisDemo {  
      
    public static Jedis getJedis(){  
        Jedis jedis = null;  
        jedis = new Jedis(FinalCollention.IP, 6379);  //redis服务器的ip和端口  
        jedis.auth(FinalCollention.PASSWORD);  //连接redis的密码  
        return jedis;  
    }  
    public void test(){  
        Jedis jedis = null;  
        try{  
            jedis = getJedis();  
            jedis.incr("test");  
            long dbsize = jedis.dbSize();  
            System.out.println("数据库大小："+dbsize);  
            System.out.println("测试test的值："+jedis.get("test"));  
              
        }catch(Exception e){  
            e.printStackTrace();  
        }finally{  
            if(jedis != null){  
                jedis.disconnect();  
            }  
        }  
    }  
    public static void main(String[] args) {  
        RedisDemo demo = new RedisDemo();  
        demo.test();  
    }  
}  

如果出现Java无法连接redis的异常，主要有三个方面的问题：

1.Java运行的主机ping一下redis服务器所在主机，看能否ping通

2.关闭redis服务器所在主机的防火墙

3.打开redis安装目录下的redis.conf文件。注释掉：bind 127.0.0.1这句话

    注释掉bind代码  
    
  
# Accept connections on the specified port, default is 6379.  
# If port 0 is specified Redis will not listen on a TCP socket.  
port 6379  
  
# If you want you can bind a single interface, if the bind option is not  
# specified all the interfaces will listen for incoming connections.  
#  
# bind 127.0.0.1  
"redis.conf" 597L, 25667C written  

特别说明：后面的实例，我就不使用try--catch了，但是自己写时一定要记着关闭连接

2.Java操作redis的各种数据结构

    Redis的各种数据类型测试代码  
    
  
package com.bjsxt.test;  
  
import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  
  
import redis.clients.jedis.Jedis;  
  
public class RedisDataTypeDemo {  
      
    public static Jedis getJedis(){  
        Jedis jedis = null;  
        jedis = new Jedis(FinalCollention.IP, 6379);  //redis服务器的ip和端口  
        jedis.auth(FinalCollention.PASSWORD);  //连接redis的密码  
        return jedis;  
    }  
    /**  
     *   
     * @title demoKey  
     * @description 测试Key  
     * @author hadoop  
     */  
    public void demoKey(){  
        Jedis jedis = RedisDataTypeDemo.getJedis();  
        System.out.println("查看键为aa的是否存在："+jedis.exists("aa"));  
        System.out.println("查看键为aa的类型："+jedis.type("aa"));  
        System.out.println("随机获得一个key："+jedis.randomKey());  
        System.out.println("将aa重命名为bb："+jedis.rename("aa", "bb"));  
        System.out.println("删除bb："+jedis.del("bb"));  
        //从上面的方法可以看出，redis提供的接口方法名和redis-cli客户端提供的方法名是一样的，所以，只要对redis客户端的命令熟悉，那么Java操作redis就不是问题  
    }  
    /**  
     *   
     * @title demoString  
     * @description 测试String  
     * @author hadoop  
     */  
    public void demoString(){  
        Jedis jedis = RedisDataTypeDemo.getJedis();  
        System.out.println("设置name："+jedis.set("name", "小花"));  
        System.out.println("设置name1："+jedis.set("name1", "小花1"));  
        System.out.println("设置那么2："+jedis.set("name2", "小花2"));  
        System.out.println("设置name，如果存在返回0："+jedis.setnx("name", "小花哈哈"));  
        System.out.println("获取key为name和name1的value值："+jedis.mget("name","name1"));  
        System.out.println("自增1："+jedis.incr("index"));  
        System.out.println("自增1："+jedis.incr("index"));  
        System.out.println("自增2："+jedis.incrBy("count", 2));  
        System.out.println("自增2："+jedis.incrBy("count", 2));  
        System.out.println("递减1："+jedis.decr("count"));  
        System.out.println("递减2："+jedis.decrBy("index",2));  
        System.out.println("在name后面添加String："+jedis.append("name", ",我爱你"));  
        System.out.println("获取key为name的值："+jedis.get("name"));  
          
    }  
    /**  
     *   
     * @title demoList  
     * @description 测试list数据类型  
     * @author hadoop  
     */  
    public void demoList(){  
        Jedis jedis = RedisDataTypeDemo.getJedis();  
        //在头添加  
        jedis.lpush("list", "hadoop","hbase","hive","pig","zookeeper");  
        //在末尾添加  
        jedis.rpush("list", "java","struts");  
        //返回长度  
        jedis.llen("list");  
        //取值  
        List<String> list = jedis.lrange("list", 0, -1);  
        for (String string : list) {  
            System.out.println(string);  
        }  
    }  
    /**  
     *   
     * @title demoSet  
     * @description 测试set数据类型  
     * @author hadoop  
     */  
    public void demoSet(){  
        Jedis jedis = RedisDataTypeDemo.getJedis();  
        jedis.sadd("city", "北京","上海","重启","武汉");  
        System.out.println("取出最上面的："+jedis.spop("city"));  
        System.out.println("随机取出一个值"+jedis.srandmember("city"));  
        jedis.sadd("city2", "北京","武汉","河北","张家界","辽林");  
        System.out.println("交集："+jedis.sinter("city","city1"));  
        System.out.println("并集："+jedis.sunion("city","city1"));  
        System.out.println("差集："+jedis.sdiff("city","city1"));  
          
    }  
    /**  
     *   
     * @title demoMap  
     * @description 测试map数据类型  
     * @author hadoop  
     */  
    public void demoMap(){  
        Jedis jedis = RedisDataTypeDemo.getJedis();  
        jedis.hset("Mcity", "c1", "北京");  
        System.out.println("取值："+jedis.hget("city", "c1"));  
        Map<String,String> mcity = new HashMap<String, String>();  
        mcity.put("c1", "桂林");  
        mcity.put("c2", "天津");  
        mcity.put("c3", "合肥");  
        jedis.hmset("Mcity2", mcity);  
        List<String> list =  jedis.hmget("Mcity2", "c1","c2","c3");  
        for (String string : list) {  
            System.out.println(string);  
        }  
        System.out.println(jedis.hlen("Mcity2"));  
    }  
    //测试  
    public static void main(String[] args) {  
        RedisDataTypeDemo rdr = new RedisDataTypeDemo();  
        rdr.demoKey();  
        rdr.demoList();  
        rdr.demoMap();  
        rdr.demoSet();  
        rdr.demoString();  
    }  
}  

3.Java操作redis的管道

    管道代码  
    
  
package com.bjsxt.test;  
  
import redis.clients.jedis.Jedis;  
import redis.clients.jedis.Pipeline;  
  
public class RedisPipelineDemo {  
    public static Jedis getJedis(){  
        Jedis jedis = null;  
        jedis = new Jedis(FinalCollention.IP, 6379);  //redis服务器的ip和端口  
        jedis.auth(FinalCollention.PASSWORD);  //连接redis的密码  
        return jedis;  
    }  
      
    public void hasPipeline(){  
        Jedis jedis = RedisPipelineDemo.getJedis();  
        System.out.println("开始："+System.currentTimeMillis());  
        Pipeline pl = jedis.pipelined();  
        for(int i = 0 ; i < 1000 ; i++){  
            pl.incr("testPL");  
        }  
        pl.sync();  
        System.out.println("开始："+System.currentTimeMillis());  
    }  
      
    public void noPipeline(){  
        Jedis jedis = RedisPipelineDemo.getJedis();  
        System.out.println("开始："+System.currentTimeMillis());  
        for(int i = 0 ; i < 1000 ; i++){  
            jedis.incr("testPL");  
        }  
        System.out.println("开始："+System.currentTimeMillis());  
    }  
}  

4.redis事务

    Redis事务代码  
    
  
package com.bjsxt.test;  
  
import java.util.List;  
  
import redis.clients.jedis.Jedis;  
import redis.clients.jedis.Transaction;  
  
public class RedisTXDemo {  
    public static Jedis getJedis(){  
        Jedis jedis = null;  
        jedis = new Jedis(FinalCollention.IP, 6379);  //redis服务器的ip和端口  
        jedis.auth(FinalCollention.PASSWORD);  //连接redis的密码  
        return jedis;  
    }  
    /**  
     *   
     * @title txDemo  
     * @description 没有异常的事务  
     * @author hadoop  
     */  
    public void txDemo(){  
        Jedis jedis = getJedis();  
        //开启事务  
        Transaction tx = jedis.multi();  
          
        tx.set("txcity", "beijin");  
        tx.sadd("hi", "abc");  
        tx.get("txcity");  
        List<Object> objs = tx.exec();  
          
        for (Object object : objs) {  
            System.out.println(object.toString());  
        }  
    }  
      
    /**  
     *   
     * @title txHasExDemo  
     * @description 含有异常的事务  
     * @author hadoop  
     */  
    public void txHasExDemo(){  
        Jedis jedis = getJedis();  
        //开启事务  
        Transaction tx = jedis.multi();  
          
        tx.set("txcity1", "beijin");  
        tx.sadd("hi1", "abc");  
        int i = 1/0;  
        tx.get("txcity1");  
        List<Object> objs = tx.exec();  
          
        for (Object object : objs) {  
            System.out.println(object.toString());  
        }  
    }  
      
    public static void main(String[] args) {  
        RedisTXDemo redisTXDemo = new RedisTXDemo();  
        redisTXDemo.txDemo();  
        redisTXDemo.txHasExDemo();  
    }  
}  

Java操作redis

Java操作redis很简单。创建一个普通的Java工程。然后导入redis依赖的jar包。jar包我已经上传了。

1.入门级的demo

2.Java操作redis的各种数据结构

3.Java操作redis的管道

4.redis事务

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

Java操作redis

Java操作redis很简单。创建一个普通的Java工程。然后导入redis依赖的jar包。jar包我已经上传了。

1.入门级的demo

2.Java操作redis的各种数据结构

3.Java操作redis的管道

4.redis事务

热门文章

最新文章

相关课程

相关电子书

相关实验场景