| | |
| | | */ |
| | | public class MappingCache extends BaseCache { |
| | | |
| | | //后缀 用来刷缓存时删除 所有以这个为后缀的数据 |
| | | public final static String _SUFFIX_MAPPING = "_SUFFIX_MAPPING"; |
| | | |
| | | /** |
| | | * 获取值 |
| | |
| | | Jedis redis = null; |
| | | try { |
| | | redis = getJedis(); |
| | | Object object = SerializeUtil.unserialize(redis.get((domain + key).getBytes())); |
| | | Object object = SerializeUtil.unserialize(redis.get((domain + key+_SUFFIX_MAPPING).getBytes())); |
| | | if (object == null) { |
| | | return null; |
| | | } |
| | |
| | | Jedis redis = null; |
| | | try { |
| | | redis = getJedis(); |
| | | Object obj = SerializeUtil.unserialize(redis.get((DomainContant.COMMON_DOMAIN+key).getBytes())); |
| | | Object obj = SerializeUtil.unserialize(redis.get((DomainContant.COMMON_DOMAIN+key+_SUFFIX_MAPPING).getBytes())); |
| | | if(obj instanceof Mapping){ |
| | | return (Mapping) obj; |
| | | } |
| | |
| | | Jedis redis = null; |
| | | try { |
| | | redis = getJedis(); |
| | | return SerializeUtil.unserializeList(redis.get(domain.getBytes()),Mapping.class); |
| | | return SerializeUtil.unserializeList(redis.get((domain+_SUFFIX_MAPPING).getBytes()),Mapping.class); |
| | | }finally { |
| | | if(redis != null){ |
| | | redis.close(); |
| | |
| | | Jedis redis = null; |
| | | try { |
| | | redis = getJedis(); |
| | | redis.set((mapping.getDomain()+mapping.getKey()).getBytes(),SerializeUtil.serialize(mapping)); |
| | | redis.set((mapping.getDomain()+mapping.getKey()+_SUFFIX_MAPPING).getBytes(),SerializeUtil.serialize(mapping)); |
| | | }finally { |
| | | if(redis != null){ |
| | | redis.close(); |
| | |
| | | Jedis redis = null; |
| | | try { |
| | | redis = getJedis(); |
| | | redis.set((mappings.get(0).getDomain()).getBytes(),SerializeUtil.serializeList(mappings)); |
| | | redis.set((mappings.get(0).getDomain()+_SUFFIX_MAPPING).getBytes(),SerializeUtil.serializeList(mappings)); |
| | | }finally { |
| | | if(redis != null){ |
| | | redis.close(); |