平武建站

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 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 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 map = new HashMap();  
		    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的介绍及应用”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！


网页标题：Redis的介绍及应用
文章网址：http://pwwzsj.com/article/pigcci.html

其他资讯