引言

本地缓存是一种常用的缓存手段,在客户端会经常使用这种手段来提升效率,但服务端在分布式环境下它出现的频率并不高,原因是本地缓存无法做到多台服务器数据共享,因此我们会采用redis这种分布式缓存,然而在某些情况下我们还是要使用的话怎么办呢?网上基本查不到有人去做这种分布式环境使用本地缓存,又要实时更新的方法,我这边项目中就需要这样。

项目背景

我这边有个评论检测的项目,其中有个敏感词检测的功能,这个功能需要一次性拿出所有敏感词,对输入的评论进行检测,敏感词有几万个,因此如果把敏感词放到redis,每次都取出所有的敏感词显然不太合适,因为我考虑放到本地缓存,但同时我们敏感词是需要实时更新的,后台设置以后要立马生效,所以我就弄了一套分布式环境更新本地缓存的方法。

功能实现

一. 第一个考虑的问题,我们要怎么让本地缓存知道敏感词更新了呢,肯定是通知,如何通知?

  • 我第一反应是消息推送,通过MQ这些消息队列来推送,RabbitMq有一种工作模式叫做topic主题模式,它可以把消息分发给不同的路由Key,但是我们这个路由Key是相同的,是属于多台服务器同一套代码,所以我排除了这种做法。
  • 后来我想到可以通过调用接口来通知消息(首先说明一下,我这个更新敏感词的操作是在后台管理,代码和评论检测的代码不是在一起的,是两套系统),通过接口当然可以让本地缓存更新,问题就在于,调用接口是一次性的,nginx只会转发到一个节点上,所以现在要做的就是怎么调用所有节点的通知接口。我这边想到了微服务的注册机制,springcloud中每一个微服务都是由注册中心管理,我也可以做一个注册中心,把所有节点的IP注册进去,然后通过IP+端口来调用接口

所以最后的做法就是弄一个注册中心,我选择了redis作为注册中心,简单粗暴,效率又高。具体做法就是:

  • 应用启动时把IP注册到redis
    @PostConstruct
    public void addIpToRedis() {
        String key = XHStringUtil.generateRedisKey(XHConstant.IP);
        String ip = IPUtil.getLocalIpByNetcard();
        redisTemplate.opsForSet().add(key, ip);
    }

  • 应用关闭时把IP从redis剔除
    @PreDestroy
    public void delIpFromRedis() {
        String key = XHStringUtil.generateRedisKey(XHConstant.IP);
        String ip = IPUtil.getLocalIpByNetcard();
        redisTemplate.opsForSet().remove(key, ip);
    }

当然只是这样还是不够,因为万一机房断电,进程被人误杀,这种都可能导致这个注册中心的数据不正确,不及时,所以还需要给注册中心加一个心跳检测:

  • 可以做个简单的维护注册中心的功能,就是每隔5分钟把本地的IP加入注册中心,而在调用方,只要调用节点接口失败,就把节点的IP从注册中心剔除
  • 也可以做个复杂点的心跳检测,就是专门写一个用于心跳的接口,每隔几秒调用一次,只要失败达到累计次数就剔除IP

至此,分布式环境更新本地缓存就已经实现了,简单又实用.其实还有一种比较麻烦的更新本地缓存方法,就是监控binlog,但是由于比较复杂,而且只能局限于mysql,就不展开了