我有一个简单的比赛条件。我有一个网站,人们可以对照片进行投票,但最多允许 10 票。
当用户提交投票时,我会为该特定照片更新照片表中的 num_votes 列。我这样做是为了方便查找票数。
如何确保 vote.save 和 num_votes 更新发生在同一个事务中?
谢谢!
我有一个简单的比赛条件。我有一个网站,人们可以对照片进行投票,但最多允许 10 票。
当用户提交投票时,我会为该特定照片更新照片表中的 num_votes 列。我这样做是为了方便查找票数。
如何确保 vote.save 和 num_votes 更新发生在同一个事务中?
谢谢!
为了实现这一点,您必须使用某种锁定。基本上你有 3 个选项:乐观/悲观的导轨锁定和一些外部锁定后端(如 Redis::Lock)。
如果这里不是真正的高性能,我个人会选择悲观锁定
photo = Photo.find(photo_id)
photo.with_lock do
photo.num_votes += 1
photo.save!
end
我还应该指出,坚持只包装递增的 num_votes 并保存到一个事务中并不能解决竞争条件。大多数 RDBMS 默认工作在读提交模式。这并不能阻止这种竞争条件。
如果它是一个简单的竞争条件,那么您应该将它作为一个竞争条件来解决。尝试使用一些锁定机制。Redis 很好用: redis 为 ruby 加锁
RedisLocker.new('vote_#{@photo.id}').run! { @photo.vote }
# ... photo model
def vote
if num_votes <= 10
self.num_votes += 1
save
end
end
好吧,Rails/Postgres 支持事务。您可以在任何 ActiveRecord 模型上简单地声明一个:
Photo.transaction do
Vote.create(:whatever)
Photo.votes = thing
Photo.save!
end
如果在事务块期间引发异常(例如,通过调用.save!
无效模型),事务将回滚,并且不会提交任何可能发生的数据库更改(在这种情况下,投票记录不会插入)。当然,您仍然需要救援和处理异常。
顺便说一句,在记录中存储关联对象的数量以便于查找是一种非常常见的模式,称为计数器缓存,Rails 也支持这些模式 - 您可能希望研究正式制作num_votes
计数器缓存(默认名称为photos.votes_count
,但这不是必需的)。不过,您可能仍希望交易检查它是否超出限制。
你不需要明确的锁
Photo.where(:id => photo_id).where('num_votes < 10').update_all('num_votes = num_votes+ 1')
将更新该照片的投票数,但前提是投票数少于 10。您可以检查 的返回值update_all
以查看是否实际更新了任何内容:返回值是更新的行数。如果更新失败,则不要创建投票(或者如果您已经创建了投票,则回滚事务)。
乐观锁定使用类似的技术来检测并发更新的尝试:它对更新设置一个条件,以确保如果有人在您之前潜入其中,则不会发生任何事情,然后检查更新的行数。