进行原子操作

目前数据存储服务使用 MongoDB 3.4，不具备处理事务的能力，但这不代表开发者无法进行并发操作。阅读本文，了解 MongoDB 提供的原子操作符以及使用方法。

原子插入

要保证同一条信息不可插入两次，在集合上新增一个字段并且设置 unique index，如下所示：

  1. // 创建唯一索引
  2. basement.db.collection('order').createIndex(
  3.   { 'orderId': 1 },
  4.   { 'unique': true }
  5. );
  7. // 插入时验证
  8. function placeOrder(items) {
  9.   const orderId = uuid();
  10.   basement.db.collection('order').insertOne({
  11.     orderId,
  12.     items,
  13.   }).then(res => {
  14.     console.log('order placed successful');
  15.   }).catch(err => {
  16.     console.error('insert failed');
  17.   });
  18. }

原子更新

原子更新可以通过判断当前的最后更新时间来匹配是否可以更新。例如，在发送一个礼物时，A 和 B 同时领取，在不支持原子更新的情况下，可能导致两个用户都抢到的情况。

  1. basement.db.collection('gifts').createIndex('inventory.itemId');
  3. function giveOutGift(owner, item) {
  4.   // 发礼物
  5.   return basement.db.collection('inventory').updateOne({
  6.     user: owner,
  7.   }, {
  8.     $addToSet: { // 保证唯一性，subdocument 不能建立唯一索引
  9.       inventory: {
  10.         item,
  11.         itemId: item.id,
  12.         status: 'unclaimed',
  13.       },
  14.     },
  15.   }, { upsert: true });
  16. }
  18. function freezeGift(item) {
  19.   return basement.db.collection('gifts').updateOne({
  20.     inventory: {
  21.       $elemMatch: { // 找到数组里对应的礼物
  22.         itemId: item.id,
  23.         status: 'unclaimed',
  24.       },
  25.     },
  26.   }, {
  27.     $set: {
  28.       'inventory.$.status': { status: 'transferring' }, // 设置成转移中
  29.     },
  30.   }).then(res => {
  31.     if (res.affectedDocs !== 1) {
  32.       return Promise.reject();
  33.     }
  34.   });
  35. }
  37. function claimGift(to, item) {
  38.   return basement.db.collection('gifts').updateOne({
  39.     user: to,
  40.   }, {
  41.     $addToSet: {
  42.       inventory: { 
  43.         item,
  44.         itemId: item.id,
  45.         status: 'owned'
  46.       },
  47.     },
  48.   }, {
  49.     upsert: true,
  50.   }).then(res => {
  51.     if (res.affectedDocs !== 1) {
  52.       return Promise.reject();
  53.     }
  54.   });
  55. }
  57. function claimUserGift(from, to, item) {
  58.   return freezeGift().then(claimGift).then(() => basement.db.collection('gifts').updateOne({
  59.     user: from,
  60.     inventory: {
  61.       $elemMatch: {
  62.         itemId: item.id,
  63.         status: 'transferring',
  64.       },
  65.     },
  66.   }, {
  67.     $set: {
  68.       'inventory.$.status': 'claimed',
  69.     },
  70.   });
  71. }
  73. giveOutGift('alice', {
  74.   name: 'umbrella',
  75.   id: '5b9642e109d54b4c12d68c7e',
  76. }).then(res => claimUserGift('alice', 'bob', {
  77.   name: 'umbrella',
  78.   id: '5b9642e109d54b4c12d68c7e',
  79. });

原文: https://docs.alipay.com/mini/cloud-service/shr0ud