Java连接redis及基本操作示例

<project xmlns= "http://maven.apache.org/pom/4.0.0" xmlns:xsi= "http://HdhCmsTestw3.org/2001/xmlschema-instance" xsi:schemalocation= "http://maven.apache.org/pom/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >

  <modelversion> 4.0 . 0 </modelversion>

  <groupid>testredis</groupid>

  <artifactid>testredis</artifactid>

  <version> 0.0 . 1 -snapshot</version>

  <build/>

  <dependencies>

   <!-- redis nosql 操作依赖 -->

     <dependency>

       <groupid>redis.clients</groupid>

       <artifactid>jedis</artifactid>

       <version> 2.1 . 0 </version>

     </dependency>

  </dependencies>

</project>

package com.crisy.redis;

import java.util.arraylist;

import java.util.iterator;

import java.util.list;

import java.util.set;

import redis.clients.jedis.jedis;

import redis.clients.jedis.jedispool;

import redis.clients.jedis.jedispoolconfig;

import redis.clients.jedis.jedisshardinfo;

import redis.clients.jedis.shardedjedis;

import redis.clients.jedis.shardedjedispool;

public class redisclient {

  /**

  * 一般项目基本都使用非切片池；

  * 切片池主要用于分布式项目，可以设置主从redis库

  */

  private jedis jedis; //非切片客户端连接

  private jedispool jedispool; //非切片连接池

  private shardedjedis shardedjedis; //切片客户端连接

  private shardedjedispool shardedjedispool; //切片连接池

  public redisclient(){

     initialpool(); //初始化非切片连接池

     initialshardedpool(); //初始化切片连接池

     shardedjedis = shardedjedispool.getresource();

     jedis = jedispool.getresource();

   }

  private void initialpool() {

  jedispoolconfig config = new jedispoolconfig();

  config.setmaxactive( 20 );

  config.setmaxidle( 5 );

  config.setmaxwait( 100001 );

  config.settestonborrow( false );

  jedispool = new jedispool(config, "127.0.0.1" , 6379 );

  }

  private void initialshardedpool() {

  jedispoolconfig config = new jedispoolconfig();

  config.setmaxactive( 20 );

  config.setmaxidle( 5 );

  config.setmaxwait( 100001 );

  config.settestonborrow( false );

  //slave连接

  list<jedisshardinfo> shardinfos = new arraylist<jedisshardinfo>();

  shardinfos.add( new jedisshardinfo( "127.0.0.1" , 6379 , "master" ));

  //构造池

  shardedjedispool = new shardedjedispool(config, shardinfos);

  }

  public void show(){

  system.out.println( "----对value操作的命令----" );

  valueoperate();

  system.out.println( "----对string操作的命令----" );

  stringoperator();

  system.out.println( "----对list操作的命令----" );

  listoperator();

  system.out.println( "----对set操作的命令----" );

  setoperator();

  system.out.println( "----对hash操作的命令----" );

  hashoperate();

  }

  /**

  * 对value操作的命令

  * @throws interruptedexception

  */

  private void valueoperate(){

  system.out.println( "清空当前选择库中所有key：" +jedis.flushdb());

  system.out.println( "清空所有库中所有key：" +jedis.flushall());

  system.out.println( "判断mykey键是否存在：" +shardedjedis.exists( "mykey" ));

  system.out.println( "新增mykey：" +shardedjedis.set( "mykey" , "myvalue" ));

  system.out.println( "判断mykey键是否存在：" +shardedjedis.exists( "mykey" ));

  system.out.println( "查看mykey所储存的值的类型：" +jedis.type( "mykey" ));

  system.out.println( "重命名mykey-mykey_1：" +jedis.rename( "mykey" , "mykey_1" ));

  system.out.println( "判断mykey键是否存在：" +shardedjedis.exists( "mykey" ));

  system.out.println( "判断mykey_1键是否存在：" +shardedjedis.exists( "mykey_1" ));

  system.out.println( "新增mykey_2：" +shardedjedis.set( "mykey_2" , "myvalue_2" ));

  system.out.println( "查看索引为0的key：" +jedis.select( 0 ));

  system.out.println( "当前数据库中key的数目：" +jedis.dbsize());

  system.out.println( "系统中所有键如下：" );

  //返回满足给定pattern的所有key

     set<string> keys = jedis.keys( "*" );

     iterator<string> it=keys.iterator() ; 

     while (it.hasnext()){ 

       string key = it.next(); 

       system.out.println(key); 

     }

     //删除时，如果不存在忽略此命令

     system.out.println( "系统中删除mykey_3: " +jedis.del( "mykey_3" ));

     system.out.println( "系统中删除mykey_2: " +jedis.del( "mykey_2" ));

     system.out.println( "判断mykey_2是否存在：" +shardedjedis.exists( "mykey_2" ));

     system.out.println( "设置 mykey_1的过期时间为5秒:" +jedis.expire( "mykey_1" , 5 ));

     try {

   thread.sleep( 2000 );

  } catch (interruptedexception e) {

   // todo auto-generated catch block

   e.printstacktrace();

  }

     //没有设置过期时间或者不存在的都返回-1

     system.out.println( "获得mykey_1的剩余活动时间：" +jedis.ttl( "mykey_1" ));

     system.out.println( "取消设置mykey_1的活动时间：" +jedis.persist( "mykey_1" ));

     system.out.println( "查看mykey_1的剩余活动时间：" +jedis.ttl( "mykey_1" ));

  }

  /**

  * 对string操作的命令

  */

  private void stringoperator(){

  system.out.println( "清空当前选择库中所有key：" +jedis.flushdb());

  system.out.println( "给数据库中名称为key01的string赋予值value：" +jedis.set( "key01" , "value01" ));

  system.out.println( "给数据库中名称为key02的string赋予值value：" +jedis.set( "key02" , "value02" ));

  system.out.println( "给数据库中名称为key03的string赋予值value：" +jedis.set( "key03" , "value03" ));

  system.out.println( "返回数据库中名称为key01的string的value：" +jedis.get( "key01" ));

  system.out.println( "返回库中多个string的value：" +jedis.mget( "key01" , "key02" , "key03" ));

  system.out.println( "添加string，名称为key，值为value：" +jedis.setnx( "key04" , "value04" ));

  system.out.println( "向库中添加string，设定过期时间time：" +jedis.setex( "key05" , 5 , "value05" ));

  system.out.println( "批量设置多个string的值：" +jedis.mset( "key06_1" , "value06_1" , "key06_2" , "value06_2" ));

  system.out.println( "给数据库中名称为key07的string赋予值value：" +jedis.set( "key07" , "1" ));

  system.out.println( "名称为key07的string增1操作：" +jedis.incr( "key07" ));

  //err value is not an integer or out of range

  //system.out.println("名称为key01的string增1操作："+jedis.incr("key01"));

  system.out.println( "名称为key07的string增加integer：" +jedis.incrby( "key07" , 5 ));

  system.out.println( "名称为key07的string减1操作：" +jedis.decr( "key07" ));

  system.out.println( "名称为key07的string减少integer：" +jedis.decrby( "key07" , 3 ));

  system.out.println( "名称为key的string的值附加value：" +jedis.append( "key01" , "hello world" ));

  system.out.println( "返回名称为key的string的value的子串：" +jedis.substr( "key01" , 0 , 5 ));

  }

  /**

  * 对list操作的命令

  */

  private void listoperator(){

  system.out.println( "清空当前选择库中所有key：" +jedis.flushdb());

  //准备两个list

  shardedjedis.lpush( "mylist" , "java" );

     shardedjedis.lpush( "mylist" , "c" );

     shardedjedis.lpush( "mylist" , "c++" );

     shardedjedis.lpush( "mylist" , "java" );

  system.out.println( "在名称为mylist的list尾添加一个值为value的元素：" +jedis.rpush( "mylist" , "phython" ));

  system.out.println( "在名称为mylist的list头添加一个值为value的 元素：" +jedis.rpush( "mylist" , "php" ));

  system.out.println( "返回名称为mylist的list的长度：" +jedis.llen( "mylist" ));

  system.out.println( "返回名称为mylist中start至end之间的元素：" +jedis.lrange( "mylist" , 0 , 3 ));

  system.out.println( "截取名称为mylist的list：" +jedis.ltrim( "mylist" , 0 , 3 ));

  system.out.println( "返回名称为mylist的list中index位置的元素：" +jedis.lindex( "mylist" , 0 ));

  system.out.println( "给名称为mylist的list中index位置的元素赋值：" +jedis.lset( "mylist" , 0 , "hahahahah我改啦" ));

  system.out.println( "删除count个mylist的key中值为value的元素：" +jedis.lrem( "mylist" , 1 , "java" ));

  system.out.println( "返回并删除名称为mylist的list中的首元素：" +jedis.lpop( "mylist" ));

  system.out.println( "返回并删除名称为mylist的list中的尾元素：" +jedis.rpop( "mylist" ));

  }

  /**

  * 对set操作的命令

  */

  private void setoperator(){

  system.out.println( "清空当前选择库中所有key：" +jedis.flushdb());

  //准备两个set

  jedis.sadd( "myset" , "hahaha" );

  jedis.sadd( "myset" , "hahaha" );

  jedis.sadd( "myset" , "lalala" );

  jedis.sadd( "myset" , "kakaka" );

  jedis.sadd( "myset2" , "hahaha" );

  jedis.sadd( "myset2" , "lalala" );

  jedis.sadd( "myset2" , "kakaka" );

  system.out.println( "向名称为myset的set中添加元素member：" +jedis.sadd( "myset" , "wawawa" ));

  system.out.println( "返回名称为myset的set的所有元素：" +jedis.smembers( "myset" ));

  system.out.println( "删除名称为myset的set中的元素member：" +jedis.srem( "myset" , "wawawa" ));

  system.out.println( "返回名称为myset的set的所有元素：" +jedis.smembers( "myset" ));

  system.out.println( "随机返回并删除名称为myset的set中一个元素：" +jedis.spop( "myset" ));

  system.out.println( "移到集合元素：" +jedis.smove( "myset" , "myset2" , "hahaha" ));

  system.out.println( "返回名称为myset的set的所有元素：" +jedis.smembers( "myset" ));

  system.out.println( "返回名称为myset2的set的所有元素：" +jedis.smembers( "myset2" ));

  system.out.println( "返回名称为mykey的set的基数：" +jedis.scard( "myset" ));

  system.out.println( "member是否是名称为mykey的set的元素：" +jedis.sismember( "myset" , "hahaha" ));

  system.out.println( "求交集：" +jedis.sinter( "myset" , "myset2" ));

  system.out.println( "求交集并将交集保存到dstkey的集合：" +jedis.sinterstore( "dstkey" , "myset2" , "myset" ));

  system.out.println( "返回名称为dstkey的set的所有元素：" +jedis.smembers( "dstkey" ));

  system.out.println( "求并集：" +jedis.sunion( "myset" , "myset2" ));

  system.out.println( "求并集并将并集保存到dstkey的集合：" +jedis.sinterstore( "dstkey" , "myset2" , "myset" ));

  system.out.println( "返回名称为dstkey的set的所有元素：" +jedis.smembers( "dstkey" ));

  system.out.println( "求差集：" +jedis.sdiff( "myset2" , "myset" ));

  system.out.println( "求差集并将差集保存到dstkey的集合：" +jedis.sdiffstore( "dstkey" , "myset2" , "myset" ));

  system.out.println( "返回名称为dstkey的set的所有元素：" +jedis.smembers( "dstkey" ));

  system.out.println( "随机返回名称为dstkey的set的一个元素：" +jedis.srandmember( "dstkey" ));

  }

  /**

  * hash

  */

  private void hashoperate(){

  system.out.println(jedis.flushdb());

  system.out.println( "向名称为key的hash中添加元素field1：" +shardedjedis.hset( "key" , "field1" , "value1" ));

     system.out.println( "向名称为key的hash中添加元素field2：" +shardedjedis.hset( "key" , "field2" , "value2" ));

     system.out.println( "向名称为key的hash中添加元素field3：" +shardedjedis.hset( "key" , "field3" , "value3" ));

     system.out.println( "返回名称为key的hash中field1对应的value：" +shardedjedis.hget( "key" , "field1" ));

     system.out.println( "返回名称为key的hash中field1对应的value：" +shardedjedis.hmget( "key" , "field1" , "field2" , "field3" ));

     system.out.println( "删除名称为key的hash中键为field1的域：" +shardedjedis.hdel( "key" , "field1" ));

     system.out.println( "返回名称为key的hash中所有键对应的value：" +shardedjedis.hvals( "key" ));

     system.out.println( "返回名称为key的hash中元素个数：" +shardedjedis.hlen( "key" ));

     system.out.println( "返回名称为key的hash中所有键：" +shardedjedis.hkeys( "key" ));

     system.out.println( "返回名称为key的hash中所有的键（field）及其对应的value：" +shardedjedis.hgetall( "key" ));

     system.out.println( "名称为key的hash中是否存在键为field1的域：" +shardedjedis.hexists( "key" , "field1" ));

  }

}