今日头条开放api接口seo上首页排名
Redlock实现原理
超过半数redis节点加锁成功才算成功加锁。
Redlock存在问题
如果主节点挂掉,还没有同步到从节点,重新选举出主节点,那加锁就没有加到这个新的主节点上。
如果增加redis主节点数,那么加锁的性能更差,要给半数节点加锁,如果没有加成功,还要回滚。
Redis的刷盘频率,1s刷盘一次,否则写一条刷盘一条性能就非常差了。如果redis挂了或者重启,可能导致这1s内的数据没有持久化,因此也会造成锁丢失,别的线程也可以加锁成功。
RedLock 依赖 Redis 实例的系统时钟计算锁的剩余有效期。若不同实例的时钟不同步(如时钟跳跃或漂移),可能导致锁被提前释放或无法释放。
Redisson 官方已弃用 RedLock。
高并发扣减库存
分段锁。
ConcurrentHashMap1.7分段锁的原理
分段结构:分为多个segment,继承reentrantLock。
锁粒度:写操作仅锁定当前操作的segment。读操作不用加锁。
哈希定位:第一次hash计算segment位置,第二次hash计算数组下标。
热点缓存重建
Product product = null;
String productCacheKey = RedisKeyPrefixConst.PRODUCT_CACHE + productId;
// 获取缓存
product = getProductFromCache(productCacheKey);
if(product != null) return product;
//加分布式锁解决热点缓存并发重建问题
RLock hotCreatecacheLock = redisson.getLock( LOCK_PRODUCT_HOT_CACHE_CREATE_PREFIX + productId);
hotCreateCacheLock.tryLock();
try {// 在锁内再次确认缓存状态,防止在第一次检查缓存为空后// 但是在加锁前,其他线程已经重新构建好缓存// 并且若多个线程同时通过第一次检查,加锁后保证只有一个线程来执行// 剩下的线程拿到锁再进来检查到缓存有值就直接返回了product = getProductFromCache(productCacheKey);if(product != null) return product;// 读锁共享,写锁互斥RReadWriteLock productupdateLock = redisson.getReadWriteLock( name: LOCK_PRODUCT_UPDATE_PREFIX + productId);// 读锁RLock rLock =productUpdateLock.readLock();rLock.lock();// 构建缓存,同时也构建本地缓存。reBuildCache();// 热点key,比如微博,百万用户查同一个key,redis扛不住。// 本地缓存,并发百万级别没问题。// 多级缓存无法保证绝对一致性。不用过度设计。MQ异步或者redis发布订阅。// redis的发布订阅机制,如果更新数据,发送消息到queue,然后监听更新。// 热点中的热点商品才会存放到本地缓存,因为本地缓存是非常宝贵的。// 并且热点商品的变动是非常快的。// 因此,有专门的一个热点缓存计算系统,所有的应用会对热点缓存计算系统做一个监听,维护缓存。
}// 发布消息
redisTemplate.convertAndSend("cache:update", JSON.toJSONString(new CacheMessage("user:" + user.getId(), "DELETE")));
// 订阅频道
redisTemplate.execute((RedisConnection connection) -> {connection.subscribe(new RedisMessageListener() {@Overridepublic void onMessage(String channel, String message) {// 解析消息CacheMessage cacheMsg = JSON.parseObject(message, CacheMessage.class);// 更新本地缓存
// 重建热点缓存串行转并行
// tryLock允许线程立即尝试获取锁,若锁不可用则立即返回失败,而非阻塞等待。这种机制打破了严格的串行逻辑。
if (cacheLock.tryLock()) {try {// 重建缓存(串行)} finally {cacheLock.unlock();}
} else {// 返回旧缓存或默认值(并行)
}
缓存穿透
查询一个不存在的key,设置为空值给缓存。
private final static String EMPTY_CACHE = "{}";
缓存雪崩
过期时间加一个随机值。