秒杀系统源码

package com.imooc.miaosha.redis; import com.alibaba.fastjson.JSON; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Service; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; /** * Created by Administrator on 2018/3/27. */ @Service public class RedisService { @Autowired RedisConfig redisConfig; @Autowired JedisPool jedisPool; /** * 获取单个对象 * @param prefix * @param key * @param clazz * @param <T> * @return */ public <T> T get(KeyPrefix prefix,String key , Class<T> clazz){ Jedis jedis = null; try { jedis = jedisPool.getResource(); String realKey =prefix.getPrefix()+key; String str = jedis.get(realKey); T t = stringToBean(str,clazz); return t; }finally { returnToPool(jedis); } } /** * 设置对象 * @param prefix * @param key * @param value * @param <T> * @return */ public <T> boolean set(KeyPrefix prefix,String key , T value){ Jedis jedis = null; try { jedis = jedisPool.getResource(); String str = beanToString(value); if(str == null || str.length() <= 0){ return false; } String realKey =prefix.getPrefix()+key; int seconds = prefix.expireSeconds(); if(seconds <=0){ jedis.set(realKey,str); }else { jedis.setex(realKey,seconds,str); } return true; }finally { returnToPool(jedis); } } /** * 判断key是否存在 * @param prefix * @param key * @param <T> * @return */ public <T> boolean exists(KeyPrefix prefix,String key ){ Jedis jedis = null; try { jedis = jedisPool.getResource(); String realKey =prefix.getPrefix()+key; return jedis.exists(realKey); }finally { returnToPool(jedis); } } /** * 增加key * @param prefix * @param key * @param * @param <T> * @return */ public <T> Long incr(KeyPrefix prefix,String key ){ Jedis jedis = null; try { jedis = jedisPool.getResource(); String realKey =prefix.getPrefix()+key; return jedis.incr(realKey); }finally { returnToPool(jedis); } } /** * 减少key * @param prefix * @param key * @param * @param <T> * @return */ public <T> Long decr(KeyPrefix prefix,String key){ Jedis jedis = null; try { jedis = jedisPool.getResource(); String realKey =prefix.getPrefix()+key; return jedis.decr(realKey); }finally { returnToPool(jedis); } } /** * 删除 * */ public boolean delete(KeyPrefix prefix, String key) { Jedis jedis = null; try { jedis = jedisPool.getResource(); //生成真正的key String realKey = prefix.getPrefix() + key; long ret = jedis.del(realKey); return ret > 0; }finally { returnToPool(jedis); } } public static <T> String beanToString(T value) { if(value == null){ return null; } Class<?> clazz = value.getClass(); if(clazz == int.class||clazz == Integer.class){ return ""+value; }else if(clazz == String.class){ return (String)value; }else if(clazz == long.class||clazz==Long.class){ return ""+value; }else { return JSON.toJSONString(value); } } public static <T> T stringToBean(String str,Class<T> clazz) { if(str == null||str.length()<=0||clazz==null){ return null; } if(clazz == int.class||clazz == Integer.class){ return (T)Integer.valueOf(str); }else if(clazz == String.class){ return (T)str; }else if(clazz == long.class||clazz==Long.class){ return (T)Long.valueOf(str); }else { return JSON.toJavaObject(JSON.parseObject(str),clazz); } } private void returnToPool(Jedis jedis) { if(jedis != null){ jedis.close(); } } @Bean public JedisPool jedisPoolFactory(){ JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxIdle(redisConfig.getPoolMaxIdle()); poolConfig.setMaxTotal(redisConfig.getPoolMaxTotal()); poolConfig.setMaxWaitMillis(redisConfig.getPoolMaxWait()*1000); //GenericObjectPoolConfig poolConfig, String host, int port, int timeout, String password JedisPool jedisPool = new JedisPool(poolConfig,redisConfig.getHost(),redisConfig.getPort(),redisConfig.getTimeout()*1000); return jedisPool; } }