博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
使用redis和fastjson做应用和mysql之间的缓存
阅读量:6069 次
发布时间:2019-06-20

本文共 6489 字,大约阅读时间需要 21 分钟。

第一次做这种javaweb的项目,难免还是要犯很多错误。

大概也知道,redis常常被用来做应用和mysql之间的缓存。模型大概是这样子的。

99794-20160315142816521-761265823.png

为了让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);                Map
map = new HashMap
(); //如果是多组数据,那么保存的方式不同,多组的情况需要保存子实体类型 if(value.getClass().equals(ArrayList.class)) { @SuppressWarnings("unchecked") List
list = (List)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); } @Override public Object getObject(Object key) { try { String keyStr = getKey(key); Map
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; } } @Override public 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

你可能感兴趣的文章
Qt多线程
查看>>
我的友情链接
查看>>
Ubuntu12.04 编译android源代码及生成模拟器经历分享
查看>>
KVM网络桥接设置方法
查看>>
Puppet学习手册:Puppet Yum安装
查看>>
我的友情链接
查看>>
ansible学习记录
查看>>
网思科技校园网计费解决方案
查看>>
我的友情链接
查看>>
携程 Apollo分布式部署
查看>>
2017 Hackatari Codeathon B. 2Trees(深搜)(想法)
查看>>
单词统计
查看>>
输入一个数字计算圆的面积
查看>>
在Delphi中隐藏程序进程
查看>>
AngularJS PhoneCat代码分析
查看>>
MEF元数据应用说明
查看>>
maven错误解决:编码GBK的不可映射字符
查看>>
2016/4/19 反射
查看>>
SharePoint Wiki发布页面的“保存冲突”
查看>>
oracle 10g 数据库与客户端冲突导致实例创建无监听问题
查看>>