Redis的介绍及应用

本篇内容主要讲解“Redis的介绍及应用”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Redis的介绍及应用”吧!

官网下不了，这里找了这个地址，版本比较老

下载驱动,搜索jedis

参考

基本操作

public class RedisTest {	public static void main(String[] args) {	/**	 * 地址 端口 超时时间	 */	Jedis jedis = new Jedis("localhost", 6379, 100000);	/**	 * 测试是否通 	 */	System.out.println("服务正在运行: "+jedis.ping());	/** 	 * set：设置key值 	 * get：获取key值 	 * del：删除key 	 * append：追加key值 	 * incr：key值自增1 	 * incrBy：key值自增，指定步长 	 * decr：key值自减1 	 * decrBy：key值自减，指定步长 	 * expire：为key设置过期时间（秒数） 	 * setex：设置key值，可指定存活时间（秒数） 	 * setnx：设置key值。key不存在才会设置，如果key存在则回滚操作，结果返回0，表示没有设置成功 	 * ttl：time to live，获取key的存活时间（秒），-1表示永不过期 	 * persist：去掉key的expire设置，不再有失效时间 	 */  	jedis.set("first", "Hello World!");	System.out.println(jedis.get("first"));	/** 	 * LIST	 * 可以实现队列的功能 	 * lpush: 从列表头部插入多个元素 	 * rpush：从列表尾部插入多个元素 	 * llen：返回列表中的元素的数量 	 * lpop：从列表头部移除并返回list的第一个元素 	 * lrem：从头部开始找，删除n个值 	 * lrange：从列表中获取指定范围的子集 	 */	jedis.del("list");	jedis.lpush("list", "1","2","3");	jedis.lpush("list", "4");	Long count=jedis.llen("list");	List<String> list=jedis.lrange("list", 0, count);	System.out.println(list.toString());	/** 	 * sadd：往set对象中添加一个值 	 * smembers：取得set中所有的值 	 * sismember：判断一个值是否在set中存在 	 * srandmember：从set中随机取得一个值 	 * srem：从set中删除一个值 	 * scard：返回set的item个数 	 */	jedis.del("set");	jedis.sadd("set", "1","2","3");	jedis.sadd("set", "4");	jedis.sadd("set", "4");	Set<String> set=jedis.smembers("set");	System.out.println(set.toString());	/** 	 * hmset：设置key值，值类型为map对象 	 * type：返回key值的类型，可能值有none, string, hash, set, list, zset 	 * hkeys：获取所有key 	 * hvals：获取所有key对应的值 	 * hmget：一次性获取多个field的值 	 * hexists：判断field是否存在 	 * hset：设置field的值 	 * hgetAll：获取全部内容 	 * hget：获取field的值 	 * hdel：删除field 	 * hincrBy：field值自增1 	 * hlen：计算field的数目 	 * hsetnx：设置key值。field不存在才会设置，如果field存在则回滚操作，结果返回0，表示没有设置成功。可以用来实现分布式锁 	 */ 	 jedis.del("user");  	      	    Map<String, String> map = new HashMap<String, String>();  	    map.put("name", "cjm");  	    map.put("age", "33");  	    map.put("qq", "123456");  	      	    jedis.hmset("user", map);  	    System.out.println("type: " + jedis.type("user"));   	      	    System.out.println("hkeys: " + jedis.hkeys("user"));   	    System.out.println("hvals: " + jedis.hvals("user"));  	      	    System.out.println("hmget: " + jedis.hmget("user", "name", "age"));   	    System.out.println("hexists: " + jedis.hexists("user", "name"));  	      	    jedis.hset("user", "pwd", "123");   	    System.out.println("hgetAll: " + jedis.hgetAll("user"));   	    System.out.println("hget: " + jedis.hget("user", "pwd"));   	    jedis.hdel("user", "qq");   	    System.out.println("hincrBy: " + jedis.hincrBy("user", "count", 1));   	    System.out.println("hlen: " + jedis.hlen("user"));   	      	    Long r = jedis.hsetnx("user", "pwd2", "456");   	    System.out.println(r); 	} }

消息订阅、

订阅 public class Consumer {	public static void main(String[] args) {	/**	 * 地址 端口 超时时间	 */	Jedis jedis = new Jedis("localhost", 6379, 100000);	 /**	     * 消息订阅	     */	    JedisPubSub jps=new JedisPubSub() {	    	public void onPMessage(String pattern, String channel, String message) {	    	System.out.println("onPMessage()," + pattern + "=" + channel + "="	    	+ message);	    	}	     	    	public void onMessage(String channel, String message) {	    	System.out.println("onMessage()," + channel + "=" + message);	    	}	    };	    	    jedis.psubscribe(jps, "test*");	} } //发布  jedis.publish("test1", "message from test1");  jedis.publish("test2", "message from test2");

redis分布式锁

public class RedisTool {     private static final String LOCK_SUCCESS = "OK";     private static final Long RELEASE_SUCCESS = 1L;          /**      * 尝试获取分布式锁      * @param jedis Redis客户端      * @param lockKey 锁      * @param requestId 请求标识      * @param expireTime 超期时间      * @return 是否获取成功      */     public static boolean tryGetDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {                  String result = jedis.set(lockKey, requestId,new SetParams().nx().ex(expireTime));         if (LOCK_SUCCESS.equals(result)) {             return true;         }         return false;     }          /**      * 释放分布式锁      * @param jedis Redis客户端      * @param lockKey 锁      * @param requestId 请求标识      * @return 是否释放成功      */     public static boolean releaseDistributedLock(Jedis jedis, String lockKey, String requestId) {         String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";         Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));         if (RELEASE_SUCCESS.equals(result)) {             return true;         }         return false;     } } public class LockTest {	public static void main(String[] args) {	Runnable rn = new Runnable() {	@Override	public void run() {	Jedis jedis = new Jedis("localhost", 6379, 100000);	String uuid = UUID.randomUUID().toString().replaceAll("-", "");	int tryCount=5;	while (true) {	Boolean lock = RedisTool.tryGetDistributedLock(jedis, "lock", uuid, 10);	if (lock) {	System.out.println(Thread.currentThread().getName() + "获取锁");	try {	Thread.sleep(1000L);	} catch (InterruptedException e) {	e.printStackTrace();	}	Boolean unlock = RedisTool.releaseDistributedLock(jedis, "lock", uuid);	if (unlock) {	System.out.println(Thread.currentThread().getName() + "释放锁");	break;	}	}	if(tryCount<0) {	break;	}else {	try {	Thread.sleep(2000);	} catch (InterruptedException e) {	e.printStackTrace();	}	System.out.println(Thread.currentThread().getName() + "尝试次数:"+tryCount);	tryCount--;	}	}	}	};	for (int i = 0; i < 20; i++) {	Thread t = new Thread(rn);	t.start();	}	LockSupport.park();	} }

锁测试

package com.redis; import java.util.UUID; import java.util.concurrent.locks.LockSupport; import redis.clients.jedis.Jedis; public class ProductServer {	/**	 * 向服务端添加货	 * 	 * @return	 */	public boolean addProduct(Jedis jedis, String key, int i) {	System.out.println("货物:" + key + "添加库存:" + i);	if (i > 0) {	System.out.println("---添加货物:" + key + "数量:" + i + "---");	// 获取值	String count = jedis.get(key);	System.out.println("剩余库存:" + count);	if (null == count || Integer.valueOf(count) <= 0) {	System.out.println("---当前货物:" + key + "数量已销售完毕");	System.out.println("---当前货物:" + key + "添加开始");	jedis.set(key, i + "");	System.out.println("---当前货物:" + key + "添加结束");	return true;	}	}	return false;	}	/**	 * 消费数据	 */	public boolean decryProduct(Jedis jedis, String key, String requestID) {	try {	Boolean lock = RedisTool.tryGetDistributedLock(jedis, "lock", requestID, 100);	if (!lock) {	System.out.println("请稍后重试...");	return false;	}	System.out.println("货物:" + key + "线程:" + Thread.currentThread().getName() + "消费数据:" + requestID);	String count = jedis.get(key);	if (null != count && Integer.valueOf(count) > 0) {	jedis.decr(key);	count = jedis.get(key);	System.out.println("剩余库存:" + count);	return true;	}	} catch (Exception e) {	} finally {	RedisTool.releaseDistributedLock(jedis, "lock", requestID);	}	return false;	}	public static void main(String[] args) {	Jedis jedis = new Jedis("localhost", 6379, 10000);	ProductServer ps = new ProductServer();	ps.addProduct(jedis, "shouji", 10);	Runnable rn = new Runnable() {	@Override	public void run() {	String uuid = UUID.randomUUID().toString().replaceAll("-", "");	Jedis jedis = new Jedis("localhost", 6379, 10000);	ps.decryProduct(jedis, "shouji", uuid);	}	};	for (int i = 0; i < 15; i++) {	Thread td = new Thread(rn);	td.start();	}	LockSupport.park();	} }

到此，相信大家对“Redis的介绍及应用”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！