Redis助手工具类，如何高效应对长尾词查询挑战？

本文共计1807个文字，预计阅读时间需要8分钟。

javapackage com.isoftstone.pcis.util;

import java.io.IOException;import java.io.InputStream;import java.util.Iterator;import java.util.List;import java.util.Map;import java.util.Properties;import org.apache.log4j.Logger;

public class RedisHelper { private static final Logger LOGGER=Logger.getLogger(RedisHelper.class); private Properties properties;

public RedisHelper() { loadProperties(); }

private void loadProperties() { InputStream inputStream=this.getClass().getClassLoader().getResourceAsStream(redis.properties); properties=new Properties(); try { properties.load(inputStream); } catch (IOException e) { LOGGER.error(Failed to load properties, e); } }

public String getProperty(String key) { return properties.getProperty(key); }

public List getPropertyList(String key) { return properties.getProperty(key).split(,); }

public Map getPropertyMap(String key) { String[] keyValue=properties.getProperty(key).split(,); Map map=new HashMap(); for (String entry : keyValue) { String[] pair=entry.split(:); map.put(pair[0].trim(), pair[1].trim()); } return map; }}

RedisHelper.java

package com.isoftstone.pcis.util; import java.io.IOException; import java.io.InputStream; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Properties; import org.apache.log4j.Logger; import redis.clients.jedis.Jedis; import redis.clients.jedis.Pipeline; /** * * @author qingzhu@isoftstone.com Redis Helper 类处理Redis基本操作 * */ public class RedisHelper { static Logger logger = Logger.getLogger(RedisHelper.class); public static String getStringByKey(final String key) { return (String) getObjectByKey(key); } public static Object getObjectByKey(final String key) { Jedis jedis = null; try { jedis = RedisPool.getJedis(); final String s = DBPREFIX + key; byte[] ret = jedis.get(s.getBytes()); if (ret != null) { return SerializeUtils.deserialize(ret); } else { return null; } } catch (Exception e) { RedisPool.brokenResource(jedis); logger.error(e.getMessage()); } finally { RedisPool.retResource(jedis); } return null; } public static boolean setObject2Redis(final String key, final String value) { return setObject2Redis(key, (Object) value); } public static boolean setObject2Redis(final String key, final Object value) { boolean flag = true; Jedis jedis = null; try { jedis = RedisPool.getJedis(); byte[] val = SerializeUtils.serialize(value); final String s = DBPREFIX + key; String ret = jedis.set(s.getBytes(), val); flag = ret.equals(OP_REDIS_SUCCESS) ? true : false; } catch (Exception e) { flag = false; RedisPool.brokenResource(jedis); logger.error(e.getMessage()); } finally { RedisPool.retResource(jedis); } return flag; } /** * * @param key * @param value * @param nxxx not use
* NX|XX
* NX-- Only set the key if it does not already exist.
* XX-- Only set the key if it already exist.
* @param expx not use
* EX|PX
* EX = seconds; PX = milliseconds
* @param time * @return * @throws BusinessServiceException */ public static boolean setObject2Redis(final String key, final Object value, final String nxxx, final String expx, final long time) { boolean flag = true; Jedis jedis = null; try { jedis = RedisPool.getJedis(); byte[] val = SerializeUtils.serialize(value); final String s = DBPREFIX + key; /** String ret = jedis.set(s.getBytes(), val, nxxx.getBytes(), expx .getBytes(), time); **/ String ret = jedis.set(s.getBytes(),val); jedis.expire(s.getBytes(), (int) time); flag = ret.equals(OP_REDIS_SUCCESS) ? true : false; } catch (Exception e) { e.printStackTrace(); flag = false; RedisPool.brokenResource(jedis); logger.error(e.getMessage()); } finally { RedisPool.retResource(jedis); } return flag; } /** * 异步管道方式 * @param hashMap * @return */ public static boolean setObject4Pipelined(final Map hashMap){ if(hashMap==null) return false; boolean flag = true; Jedis jedis = null; try { jedis = RedisPool.getJedis(); Pipeline pipeline=jedis.pipelined(); for(Iterator iter = hashMap.keySet().iterator();iter.hasNext();){ String key = iter.next(); final String s = DBPREFIX + key; pipeline.set(s.getBytes(), SerializeUtils.serialize(hashMap.get(key))); } List