springboot2.0統合redisの構成

16486 ワード
Springboot集積redisは実は比較的に簡単ですが、ネット上の多くの集積は全面的ではありません.アクセス値変換パッケージは完璧ではありません.はい、くだらないことは言わないで、直接コードに行きます.
構成コードは次のとおりです.
package com.serverconfig.cache;

import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;


/**  
*
* @Title:  RedisConfig.java   
* @Package com.shop.cache   
* @Description:    TODO(redis   )   
* @author: jiazhenlong     
* @date:   2018 5 29    9:56:11   
* @version V1.0 
* @Copyright: 2018 wehere All rights reserved. 
*/
@Configuration
public class RedisConfig extends CachingConfigurerSupport {



  @Bean
  public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
    RedisTemplate redisTemplate = new RedisTemplate();
    redisTemplate.setConnectionFactory(factory);
    
    //       
    setSerializer(redisTemplate);
    redisTemplate.afterPropertiesSet();
    return redisTemplate;
  }

  private void setSerializer(RedisTemplate template) {
    @SuppressWarnings("rawtypes")
    RedisSerializer stringSerializer = new StringRedisSerializer();
    
    template.setValueSerializer(stringSerializer);
    template.setKeySerializer(stringSerializer);
    template.setHashKeySerializer(stringSerializer);
    template.setHashValueSerializer(stringSerializer);
  }
}

ツールコードは次のとおりです.
package com.serverconfig.cache;

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;


import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;

/**  
*
* @Title:  RedisTemplateHelp.java   
* @Package com.shop.cache   
* @Description:    TODO(redis   )   
* @author: jiazhenlong     
* @date:   2018 5 29    11:01:06   
* @version V1.0 
* @Copyright: 2018 wehere All rights reserved. 
*/
@Service
public class RedisTemplateHelp {

  private static final Logger LOG = LoggerFactory.getLogger(RedisTemplateHelp.class);

  
  
  @Autowired
  private RedisTemplate redisTemplate;

  public void setRedisTemplate(RedisTemplate redisTemplate) {
    this.redisTemplate = redisTemplate;
  }

  // =============================common============================
  /** 
   *          
   * @param key   
   * @param time   ( ) 
   * @return 
   */
  public boolean expire(String key,
                        long time) {
    try {
      if (time > 0) {
        redisTemplate.expire(key, time, TimeUnit.SECONDS);
      }
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *   key        
   * @param key      null 
   * @return   ( )   0        
   */
  public long getExpire(String key) {
    return redisTemplate.getExpire(key, TimeUnit.SECONDS);
  }

  /** 
   *   key     
   * @param key   
   * @return true    false    
   */
  public boolean hasKey(String key) {
    try {
      return redisTemplate.hasKey(key);
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *      
   * @param key            
   */
  @SuppressWarnings("unchecked")
  public void del(String... key) {
    if (key != null && key.length > 0) {
      if (key.length == 1) {
        redisTemplate.delete(key[0]);
      } else {
        redisTemplate.delete(CollectionUtils.arrayToList(key));
      }
    }
  }

  // ============================String=============================
  /** 
   *        
   * @param key   
   * @return   
   */
  @SuppressWarnings({"unchecked", "static-access"})
  public  T get(String key, Class clazz) {
    Object value = redisTemplate.opsForValue().get(key);
   
    if (value != null) {
      String temp;
      try {
          temp = new String();
          
          temp = temp.valueOf(value);
      } catch (Exception e) {
        LOG.error(e.getMessage(), e);
          return null;
      }
      
      if (clazz.isPrimitive()) {

        if (String.class.isAssignableFrom(clazz)) {
            return (T) temp;
        } else if (int.class.isAssignableFrom(clazz)) {
            return (T) new Integer(temp);
        } else if (long.class.isAssignableFrom(clazz)) {
            return (T) new Long(temp);
        } else if (boolean.class.isAssignableFrom(clazz)) {
            return (T) new Boolean(temp);
        } else if (double.class.isAssignableFrom(clazz)) {
            return (T) new Double(temp);
        } else if (float.class.isAssignableFrom(clazz)) {
            return (T) new Float(temp);
        } else if (byte.class.isAssignableFrom(clazz)) {
            return (T) new Byte(temp);
        } else if (short.class.isAssignableFrom(clazz)) {
            return (T) new Short(temp);
        } else {
            throw new RuntimeException("unsupport type:type=" + clazz.getName() + "value="
                    + temp);
        }
      } else {
          return JSON.parseObject(temp, clazz);
      }
  }
    
    return null;
  }

  /** 
   *        
   * @param key   
   * @param value   
   * @return true   false   
   */
  public boolean set(String key,
                     Object value) {
    try {
      redisTemplate.opsForValue().set(key,
              JSON.toJSONString(value, SerializerFeature.WriteClassName));
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }

  }

  /** 
   *             
   * @param key   
   * @param value   
   * @param time   ( ) time   0   time    0        
   * @return true   false    
   */
  public  boolean set(String key,
                         T value,
                         long time) {
    try {
      if (time > 0) {
        redisTemplate.opsForValue().set(key,
                JSON.toJSONString(value, SerializerFeature.WriteClassName), time, TimeUnit.SECONDS);
      } else {
        set(key, value);
      }
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *    
   * @param key   
   * @param by     (  0) 
   * @return 
   */
  public long incr(String key,
                   long delta) {
    if (delta < 0) {
      throw new RuntimeException("        0");
    }
    return redisTemplate.opsForValue().increment(key, delta);
  }

  /** 
   *    
   * @param key   
   * @param by     (  0) 
   * @return 
   */
  public long decr(String key,
                   long delta) {
    if (delta < 0) {
      throw new RuntimeException("        0");
    }
    return redisTemplate.opsForValue().increment(key, -delta);
  }

  // ================================Map=================================
  /** 
   * HashGet 
   * @param key      null 
   * @param item      null 
   * @return   
   */
  public Object hget(String key,
                     String item) {
    return redisTemplate.opsForHash().get(key, item);
  }

  /** 
   *   hashKey        
   * @param key   
   * @return         
   */
  public Map hmget(String key) {
    return redisTemplate.opsForHash().entries(key);
  }

  /** 
   * HashSet 
   * @param key   
   * @param map        
   * @return true    false    
   */
  public boolean hmset(String key,
                       Map map) {
    try {
      redisTemplate.opsForHash().putAll(key, map);
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   * HashSet       
   * @param key   
   * @param map        
   * @param time   ( ) 
   * @return true   false   
   */
  public boolean hmset(String key,
                       Map map,
                       long time) {
    try {
      redisTemplate.opsForHash().putAll(key, map);
      if (time > 0) {
        expire(key, time);
      }
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *    hash      ,         
   * @param key   
   * @param item   
   * @param value   
   * @return true    false   
   */
  public boolean hset(String key,
                      String item,
                      Object value) {
    try {
      redisTemplate.opsForHash().put(key, item, value);
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *    hash      ,         
   * @param key   
   * @param item   
   * @param value   
   * @param time   ( )    :      hash    ,            
   * @return true    false   
   */
  public boolean hset(String key,
                      String item,
                      Object value,
                      long time) {
    try {
      redisTemplate.opsForHash().put(key, item, value);
      if (time > 0) {
        expire(key, time);
      }
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *   hash     
   * @param key      null 
   * @param item            null 
   */
  public void hdel(String key,
                   Object... item) {
    redisTemplate.opsForHash().delete(key, item);
  }

  /** 
   *   hash          
   * @param key      null 
   * @param item      null 
   * @return true    false    
   */
  public boolean hHasKey(String key,
                         String item) {
    return redisTemplate.opsForHash().hasKey(key, item);
  }

  /** 
   * hash        ,                 
   * @param key   
   * @param item   
   * @param by     (  0) 
   * @return 
   */
  public double hincr(String key,
                      String item,
                      double by) {
    return redisTemplate.opsForHash().increment(key, item, by);
  }

  /** 
   * hash   
   * @param key   
   * @param item   
   * @param by     (  0) 
   * @return 
   */
  public double hdecr(String key,
                      String item,
                      double by) {
    return redisTemplate.opsForHash().increment(key, item, -by);
  }

  // ============================set=============================
  /** 
   *   key  Set      
   * @param key   
   * @return 
   */
  public Set sGet(String key) {
    try {
      return redisTemplate.opsForSet().members(key);
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return null;
    }
  }

  /** 
   *   value   set   ,     
   * @param key   
   * @param value   
   * @return true    false    
   */
  public boolean sHasKey(String key,
                         Object value) {
    try {
      return redisTemplate.opsForSet().isMember(key, value);
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *      set   
   * @param key   
   * @param values         
   * @return      
   */
  public long sSet(String key,
                   Object... values) {
    try {
      return redisTemplate.opsForSet().add(key, values);
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return 0;
    }
  }

  /** 
   *  set       
   * @param key   
   * @param time   ( ) 
   * @param values         
   * @return      
   */
  public long sSetAndTime(String key,
                          long time,
                          Object... values) {
    try {
      Long count = redisTemplate.opsForSet().add(key, values);
      if (time > 0) expire(key, time);
      return count;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return 0;
    }
  }

  /** 
   *   set      
   * @param key   
   * @return 
   */
  public long sGetSetSize(String key) {
    try {
      return redisTemplate.opsForSet().size(key);
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return 0;
    }
  }

  /** 
   *     value  
   * @param key   
   * @param values         
   * @return       
   */
  public long setRemove(String key,
                        Object... values) {
    try {
      Long count = redisTemplate.opsForSet().remove(key, values);
      return count;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return 0;
    }
  }
  // ===============================list=================================

  /** 
   *   list      
   * @param key   
   * @param start    
   * @param end     0   -1      
   * @return 
   */
  public List lGet(String key,
                           long start,
                           long end) {
    try {
      return redisTemplate.opsForList().range(key, start, end);
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return null;
    }
  }

  /** 
   *   list      
   * @param key   
   * @return 
   */
  public long lGetListSize(String key) {
    try {
      return redisTemplate.opsForList().size(key);
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return 0;
    }
  }

  /** 
   *        list    
   * @param key   
   * @param index     index>=0 ， 0   ，1      ，    ；index<0 ，-1，  ，-2       ，     
   * @return 
   */
  public Object lGetIndex(String key,
                          long index) {
    try {
      return redisTemplate.opsForList().index(key, index);
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return null;
    }
  }

  /** 
   *  list     
   * @param key   
   * @param value   
   * @param time   ( ) 
   * @return 
   */
  public boolean lSet(String key,
                      Object value) {
    try {
      redisTemplate.opsForList().rightPush(key, value);
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *  list     
   * @param key   
   * @param value   
   * @param time   ( ) 
   * @return 
   */
  public boolean lSet(String key,
                      Object value,
                      long time) {
    try {
      redisTemplate.opsForList().rightPush(key, value);
      if (time > 0) expire(key, time);
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *  list     
   * @param key   
   * @param value   
   * @param time   ( ) 
   * @return 
   */
  public boolean lSet(String key,
                      List value) {
    try {
      redisTemplate.opsForList().rightPushAll(key, value);
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *  list     
   * @param key   
   * @param value   
   * @param time   ( ) 
   * @return 
   */
  public boolean lSet(String key,
                      List value,
                      long time) {
    try {
      redisTemplate.opsForList().rightPushAll(key, value);
      if (time > 0) expire(key, time);
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *       list       
   * @param key   
   * @param index    
   * @param value   
   * @return 
   */
  public boolean lUpdateIndex(String key,
                              long index,
                              Object value) {
    try {
      redisTemplate.opsForList().set(key, index, value);
      return true;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return false;
    }
  }

  /** 
   *   N   value  
   * @param key   
   * @param count       
   * @param value   
   * @return       
   */
  public long lRemove(String key,
                      long count,
                      Object value) {
    try {
      Long remove = redisTemplate.opsForList().remove(key, count, value);
      return remove;
    } catch (Exception e) {
      LOG.error(e.getMessage(), e);
      return 0;
    }
  }

}
[BOJ]9251路LCS c++
React W+1