第一次做这种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 Cache String 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; @Override public void putObject(Object key, Object value) { String keyStr = getKey(key); Mapmap = new HashMap (); //如果是多组数据,那么保存的方式不同,多组的情况需要保存子实体类型 if(value.getClass().equals(ArrayList.class)) { @SuppressWarnings("unchecked") List
ps: 我们这里还是把key直接保存在了内存里面,这样存在的问题就是,如果服务器重启,那么需要清理所有的缓存;不然一定会造成脏数据。
或者,我们在保存缓存数据的时候,设置缓存数据的生命时间是30秒即可,希望对大家有所帮助。