使用redis和fastjson做应用和mysql之间的缓存

第一次做这种javaweb的项目，难免还是要犯很多错误。
大概也知道，redis常常被用来做应用和mysql之间的缓存。模型大概是这样子的。

为了让redis能够缓存mysql数据库中的数据，我写了很多这样类似的代码：

原来的查询商品

public Product selectProductById(int id) {Product product = productMapper.selectByPrimaryKey(id);if (product != null) {String detail = product.getDetail();if (detail != null) {product.setDetail(HtmlUtils.string2Html(detail));// 进行html转义，替换html转义符}}return product; }

用redis缓存之后的查询商品

public Product selectProductById(int id) {Product product = JSONObject.parseObject(redisCli.get(PRODUCT_KEY + id), Product.class);if (product != null) {product = productMapper.selectByPrimaryKey(id);String detail = product.getDetail();if (detail != null) {product.setDetail(HtmlUtils.string2Html(detail));// 进行html转义，替换html转义符}redisCli.set(PRODUCT_KEY + product.getId(), JSONObject.toJSON(product).toString(),30);}return product; }

老板说，不行啊，网站首页太慢了！于是我们又开始在ModelAndView上做文章。
原来首页的代码

@RequestMapping("/wxIndex/{id}") public ModelAndView goWxIndex(HttpServletRequest request, HttpServletResponse response,@PathVariable(value = "id") Integer id) {ModelAndView mv = new ModelAndView(); mv.setViewName(ViewNameConstant.WXINDEX); //一些逻辑代码return mv; }

于是我们又加了这样的代码：

@RequestMapping("/wxIndex/{id}") public ModelAndView goWxIndex(HttpServletRequest request, HttpServletResponse response,@PathVariable(value = "id") Integer id) {ModelAndView mv = JSONObject.parseObject(redisCli.get("index"),ModelAndView.class);if(mv != null){return mv;}mv = new ModelAndView();mv.setViewName(ViewNameConstant.WXINDEX); //一些逻辑代码redisCli.put("index",JSONObject.toString(mv),30);return mv; }

于是代码越来越乱。

慢慢学习和适应spring的思想中，明白，我们可以使用拦截的方式去做mysql的缓存。我们拦截到一个sql语句，于是把这条sql语句作为key，把返回的结果作为value保存到redis里面去，失效时间为30秒钟；
期间如果发现一个有insert或者update就把对应表的所有的缓存给清理掉。
有了思想就下手去做好了。不曾想发现mybatis已经提供了对应好的缓存的接口Cache，思想和上述完全一致。
那么我们也就是用他的接口好了。

mybatis默认缓存是PerpetualCache，可以查看一下它的源码，发现其是Cache接口的实现；那么我们的缓存只要实现该接口即可。

该接口有以下方法需要实现：

public abstract interface CacheString getId();int getSize();void putObject(Object key, Object value); Object getObject(Object key); Object removeObject(Object key);void clear();ReadWriteLock getReadWriteLock(); }

最重要的两个接口是putObject和getObject；任何select语句都会首先请求getObject函数，如果返回为null，那么再去请求mysql数据库；我们在mysql中取到数据之后，调用putObject函数，进行缓存数据的保存。
序列图为：

网上提供的案例，大部分是这样子:

public class MybatisRedisCache implements Cache {private RedisCli redisCli;@Override  public void putObject(Object key, Object value) {  logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>putObject:"+key+"="+value);  redisCli.set(SerializeUtil.serialize(key.toString()), SerializeUtil.serialize(value));  }  @Override  public Object getObject(Object key) {  Object value = SerializeUtil.unserialize(redisCli.get(SerializeUtil.serialize(key.toString())));  logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>getObject:"+key+"="+value);  return value;  }   }public class SerializeUtil {  public static byte[] serialize(Object object) {  ObjectOutputStream oos = null;  ByteArrayOutputStream baos = null;  try {  //序列化  baos = new ByteArrayOutputStream();  oos = new ObjectOutputStream(baos);  oos.writeObject(object);  byte[] bytes = baos.toByteArray();  return bytes;  } catch (Exception e) {  e.printStackTrace();  }  return null;  }  public static Object unserialize(byte[] bytes) {  ByteArrayInputStream bais = null;  try {  //反序列化  bais = new ByteArrayInputStream(bytes);  ObjectInputStream ois = new ObjectInputStream(bais);  return ois.readObject();  } catch (Exception e) {  }  return null;  }  } 

如果是通过java提供的序列化进行实体类和String的转换，那么我们要修改所有已经存在的实体Bean类，工作量太大；而且java的序列化效率又低；我们还是考虑使用工程已经引入的fastjson好；使用fastjson，就必须在缓存数据的时候，同时缓存数据的类型；我们使用redis的hash结构，就能解决这个问题

于是接口就成了下面这个样子：

public class MybatisRedisCache implements Cache {private RedisCli redisCli;@Overridepublic void putObject(Object key, Object value) {String keyStr = getKey(key);Map<String,String> map = new HashMap<String,String>();//如果是多组数据，那么保存的方式不同，多组的情况需要保存子实体类型if(value.getClass().equals(ArrayList.class)){@SuppressWarnings("unchecked")List<Object> list = (List<Object>)value;map.put("type", "java.util.ArrayList");if(list.size() > 0){map.put("subType", list.get(0).getClass().getCanonicalName());}else{map.put("subType",Object.class.getCanonicalName());}map.put("value", JSONObject.toJSONString(value));}else{map.put("type", value.getClass().getCanonicalName());map.put("value", JSONObject.toJSONString(value));}this.redisCli.hAllSet(keyStr, map,30);this.cacheKeys.add(keyStr);}@Overridepublic Object getObject(Object key) {try{String keyStr = getKey(key);Map<Object,Object> map = this.redisCli.hAllGet(keyStr);String type = (String)map.get("type");String value = (String)map.get("value");if(type == null || value == null){return null;}if("java.util.ArrayList".equals(type)){String subType = (String)map.get("subType");return JSONObject.parseArray(value, Class.forName(subType));}else{return JSONObject.parseObject(value, Class.forName(type));}}catch (Exception e){e.printStackTrace();return null;}}@Overridepublic void clear() {if(this.cacheKeys.isEmpty()){return ;} for(String key : this.cacheKeys){this.redisCli.del(key);}this.cacheKeys.clear();} }

ps： 我们这里还是把key直接保存在了内存里面，这样存在的问题就是，如果服务器重启，那么需要清理所有的缓存；不然一定会造成脏数据。
或者，我们在保存缓存数据的时候，设置缓存数据的生命时间是30秒即可，希望对大家有所帮助。

转载于:https://www.cnblogs.com/archy_yu/p/5276153.html

总结

以上是生活随笔为你收集整理的使用redis和fastjson做应用和mysql之间的缓存的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。