Redis和MySQL双写一致性

Redis和MySQL的双写一致性指的是在同时使用缓存和数据库存储数据的时候，保证Redis和MySQL中数据的一致性。

用户发起请求，先从Redis中查取数据，有数据就直接返回，没有数据就从MySQL中查询数据，并且存储到Redis中，然后返回。从MySQL中查询到数据再存入Redis中这个步骤称为回写。

上述这种有回写的缓存称为读写缓存，仅仅用于查询的缓存称为只读缓存，只读缓存中的数据是通过命令或者批量脚本从MySQL中写到Redis的。

对于读写缓存，如果需要尽可能保证数据库和缓存数据一致，使用同步直写策略，写数据库后也同步写Redis缓存；如果数据库和缓存的数据同步容许有一定的时间间隔，比如仓库系统，就可以使用异步缓写策略，写数据库的一段时间后再同步缓存，当出现异常情况需要对数据进行修补的时候，也可能需要使用异步换写策略，比如用Kafka或RabbitMQ之类的消息中间件重写数据。

源码地址，文中只展示关键代码。

双检加锁策略

从缓存中查询两次，并且加上互斥锁。

func (dao *UserDAO) FindByID(c context.Context, userID int64) (u domain.User, err error) {
	db := dao.db
	rdb := dao.rdb
	key := fmt.Sprintf("user:%v", userID)

	// 1. 从缓存中查询数据，如果有数据就返回
	var user domain.User
	val, err := rdb.Get(c, key).Result()
	if val != "" && err == nil {
		err := json.Unmarshal([]byte(val), &user)
		if err == nil {
			return user, nil
		}
	}
	// 2. 没有查到数据就加锁再查一次
	mu.Lock()
	defer mu.Unlock()
	val, err = rdb.Get(c, key).Result()
	// 2.1 从缓存中查到数据就直接返回
	if val != "" && err == nil {
		err := json.Unmarshal([]byte(val), &user)
		if err == nil {
			return user, nil
		}
	}
	// 2.2 没有从缓存中查到数据就从数据库中查询
	err = db.Where("id=?", userID).First(&user).Error
	if err != nil {
		return user, err
	}
	// 3. 将从数据库中拿到的数据写到缓存中
	userStr, err := json.Marshal(user)
	if err == nil {
		rdb.Set(c, key, userStr, 1000*time.Second)
	}
	return user, nil
}

数据库和缓存一致性的几种更新策略

上面说的是查询策略，接下来说一下数据库和缓存一致性的更新策略。

可以停机的情况：

​ 比如先往MySQL中灌入1万条数据，再同步到Redis中，可以在凌晨升级，给出升级提示。

不可以停机的情况：

异常情况2：

并发情况下执行顺序的不确定性导致的问题。

func (dao *UserDAO) UpdateUserData(c context.Context, userID int64, name string) (user User, err error) {
   db := dao.db
   rdb := dao.rdb
   key := fmt.Sprintf("user:%v", userID)
   user.ID = userID

   // 先更新数据库中的数据
   u := User{
   	Name: name,
   }
   err = db.Model(&user).
   	Select("Name").
   	Where("id=?", userID).Updates(u).Error
   if err != nil {
   	return user, err
   }

   // 再删除缓存中的数据
   err = rdb.Del(c, key).Err()
   if err != nil {
   	return user, err
   }
   return user, nil
}

学习地址

缓存双写一致性：www.bilibili.com/video/BV13R…