Jedis的简单使用

小灰灰 2022-07-15 13:19 180阅读 0赞

1、使用Jedis操作Redis中的String

public class TestString {
    	public static void main(String[] args) {
    		// 获取数据库的连接
    		Jedis jedis = new Jedis("192.168.2.116", 6379);
    
    		// 添加数据
    		jedis.set("age", "18");
    		jedis.set("name", "zhang");
    
    		// 一次获取一个数据
    		String age = jedis.get("age");
    		System.out.println(age);
    
    		// 一次获取多个数据
    		List<String> lists = jedis.mget("name", "age");
    		for (int i = 0; i < lists.size(); i++) {
    			String data = lists.get(i);
    			System.out.println(data);
    		}
    
    		// 对redis数据库的键值，进行加1的操作
    		jedis.incr("age");
    		String inc_age = jedis.get("age");
    		System.out.println(inc_age);
    
    		// 删除某个键
    		jedis.del("age");
    		// 因为键被删除，所以返回数值为null
    		String del_age = jedis.get("age");
    		System.out.println(del_age);
    
    		// 拼接
    		jedis.append("name", " bao bao ");
    		String app_name = jedis.get("name");
    		System.out.println(app_name);
    
    	}
    }

2、使用Jedis操作Redis中的Set

public class TestSet {
    	public static void main(String[] args) {
    		// 获取数据库的连接
    		Jedis jedis = new Jedis("192.168.2.116", 6379);
    
    		// 若存在，先删除这个key，方便测试
    		jedis.del("testset");
    
    		// 向Redis的Set里面添加数据
    		jedis.sadd("testset", "zhangsan");
    		jedis.sadd("testset", "lisi");
    		jedis.sadd("testset", "wangwu");
    		jedis.sadd("testset", "zhaoliu");
    
    		// 向Redis的Set里面移除数据
    		jedis.srem("testset", "zhangsan");
    
    		// 关于Redis的Set的相关操作
    		// 获取所有加入的Value
    		Set<String> set = jedis.smembers("testset");
    		for (String str : set) {
    			System.out.println(str);
    		}
    		// 判断who是不是testlist集合的元素
    		Boolean sismember = jedis.sismember("testset", "who");
    		System.out.println(sismember);
    		// 返回testlist集合的个数
    		Long scard = jedis.scard("testset");
    		System.out.println(scard);
    
    	}
    }

3、使用Jedis操作Redis中的List

public class TestList {
    	public static void main(String[] args) {
    		// 获取数据库的连接
    		Jedis jedis = new Jedis("192.168.2.116", 6379);
    		// 若存在，先删除这个key，方便测试
    		jedis.del("testlist");
    		// 向key为testlist的Redis的List类型,存放数据
    		// 注意lpush 和 rpush的区别
    		// 可以当队列使用
    		// lpush
    		jedis.lpush("testlist", "zhangsan");
    		jedis.lpush("testlist", "lisi");
    		jedis.lpush("testlist", "wangwu");
    		// rpush
    		jedis.rpush("testlist", "zhaoliu");
    
    		// 获取key为testlist的长度
    		System.out.println(jedis.llen("testlist"));
    		// 获取key为testlist的数据
    		List<String> lists = jedis.lrange("testlist", 0, -1);
    		for (int i = 0; i < lists.size(); i++) {
    			System.out.println(lists.get(i));
    		}
    	}
    }

4、使用Jedis操作Redis中的Hash

public class TestHash {
    	public static void main(String[] args) {
    
    		// 获取数据库的连接
    		Jedis jedis = new Jedis("192.168.2.116", 6379);
    
    		Map<String, String> map = new HashMap<String, String>();
    		map.put("name", "zhangsan");
    		map.put("age", "18");
    		map.put("qq", "123456");
    
    		// 添加数据到Redis的Hash
    		jedis.hmset("user", map);
    
    		// 获取map字段的某个属性的数据
    		String name = jedis.hget("user", "name");
    		System.out.println(name);
    
    		// 获取map的多个属性的数据
    		List<String> user = jedis.hmget("user", "name", "age");
    		System.out.println(user);
    
    		// 获取Hash的键值的所有的属性以及数据
    		Iterator<String> iterator = jedis.hkeys("user").iterator();
    		while (iterator.hasNext()) {
    			String key = iterator.next();
    			System.out.println(key + ":" + jedis.hget("user", key));
    		}
    
    		// 判断一个Hash是否包含一个 field 的属性
    		boolean contains = jedis.hkeys("user").contains("name");
    		System.out.println(contains);
    	}
    }

5、Jedis中的ShardedJedisPool的使用(**使用一致性哈希算法,实现Redis的集群**)

/**
     * 利用一致性哈希算法，实现Redis的集群
     */
    public class TestShardedJedisPool {
    	public static void main(String[] args) {
    
    		// 主从 哨兵 使用 share
    		// 利用一致性哈希算法，实现Redis的集群
    		// 集群的信息,一般包含多台信息
    		List<JedisShardInfo> shards = Arrays.asList(new JedisShardInfo(
    				"192.168.2.116", 6379));
    
                    // ShardedJedis
                    ShardedJedis shard = new ShardedJedis(shards);
                    shard.set("shard" , "n" )
    		// 连接池信息
    		GenericObjectPoolConfig goConfig = new GenericObjectPoolConfig();
    		goConfig.setMaxTotal(100);
    		goConfig.setMaxIdle(20);
    		goConfig.setMaxWaitMillis(-1);
    		goConfig.setTestOnBorrow(true);
    
    		// 构造ShardedJedisPool
    		ShardedJedisPool pool = new ShardedJedisPool(goConfig, shards);
    
    		// 使用ShardedJedisPool来存数据
    		pool.getResource().set("haha", "haha");
    
    		// 释放资源
    		pool.close();
    
    	}
    }

6、关于一致性哈希算法,可参考下面的博文

[一致性哈希算法][Link 1]

7、[测试代码下载][Link 2]

[Link 1]: http://blog.csdn.net/zbw18297786698/article/details/52893974
[Link 2]: http://pan.baidu.com/s/1cghOwY