java操作redis使用例子

1：链接redis

           导入jar包  commons-pool-1.6.jar  jedis-2.1.0.jar
           编写测试类
        public class TestPing {

    public static void main(String [] args){
    //连接本地的 Redis 服务

        Jedis jedis=new Jedis("127.0.0.1",6379);
//查看服务是否运行，打出pong表示OK

        System.out.println(jedis.ping());

    }

 }   
      
2常用数据类测试
package com.czmec.redis.test;

import redis.clients.jedis.Jedis;

import java.util.*;

/**

 * Created by Administrator on 2016/12/6 0006.

 */

public class Test02 {

   public static  void main(String []args){

       Jedis jedis=new Jedis("112.74.34.11",6379);

       Set<String> keys=jedis.keys("*");//查询redis中所有的key

       for(Iterator iterator = keys.iterator(); iterator.hasNext();) {

           String key = (String) iterator.next();

           System.out.println(key);

       }

       /**

        * 判断key是不是存在

        */

       System.out.println("jedis.exists======>"+jedis.exists("k2"));

       /**

        * 查看key还有多少秒过期

        */

       System.out.println(jedis.ttl("k1"));

       /**

        * string类型

        */

       jedis.set("k1","myredis");//写入值

       System.out.println(jedis.get("k1"));

       jedis.set("k4","k4_redis");

       System.out.println("----------------------------------------");

       /**

        * 同时设置多个key-value值

        */

       jedis.mset("str1","v1","str2","v2","str3","v3");

       System.out.println(jedis.mget("str1","str2","str3"));

       /**

        * list类型

        */

       jedis.lpush("mylist","v1","v2","v3","v4","v5");

       //获取mylist  key

       List<String> list = jedis.lrange("mylist",0,-1);

       for(String element : list) {

           System.out.println(element);

           }

       /**

        * set类型

        */

       jedis.sadd("orders","jd001");

       jedis.sadd("orders","jd002");

       jedis.sadd("orders","jd003");

       Set<String> set1 = jedis.smembers("orders");

       for(Iterator iterator = set1.iterator(); iterator.hasNext();) {

           String string = (String) iterator.next();

           System.out.println(string);

           }

       jedis.srem("orders","jd002");

       System.out.println(jedis.smembers("orders").size());

       //hash

       jedis.hset("hash1","userName","lisi");

       System.out.println(jedis.hget("hash1","userName"));

       Map<String,String> map =new HashMap<String,String>();

       map.put("telphone","13811814763");

       map.put("address","atguigu");

       map.put("email","abc@163.com");

       jedis.hmset("hash2",map);

       List<String> result = jedis.hmget("hash2", "telphone","email");

       for(String element : result) {

           System.out.println(element);

           }

       /**

        * zset类型

        */

       //zset

       jedis.zadd("zset01",60d,"v1");

       jedis.zadd("zset01",70d,"v2");

       jedis.zadd("zset01",80d,"v3");

       jedis.zadd("zset01",90d,"v4");

       

       Set<String> s1 = jedis.zrange("zset01",0,-1);

       for(Iterator iterator = s1.iterator(); iterator.hasNext();) {

           String string = (String) iterator.next();

           System.out.println(string);

           }

   }

}

3：事务提交

     日常：
package com.czmec.redis.test;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.Response;

import redis.clients.jedis.Transaction;

/**

 * Created by Administrator on 2016/12/6 0006.

 */

public class affair {

    public static void main(String [] args){

        Jedis jedis=new Jedis("112.74.34.11",6379);

        /**

         * 监控Key 如果在对数据操作的时之前数据被改变 那么事务就会被放弃

         */

        //监控k

        jedis.watch("serialNum");

        jedis.set("serialNum","s#####################");

        jedis.unwatch();//放弃事务

        Transaction transaction = jedis.multi();//被当作一个命令进行执行

        Response<String> response=transaction.get("serialNum");

        transaction.set("serialNum","s002");

        response=transaction.get("serialNum");

        transaction.lpush("list3","a");

        transaction.lpush("list3","b");

        transaction.lpush("list3","c");

        transaction.exec();

        //2 transaction.discard();

        System.out.println("serialNum***********"+response.get());

    }

}