Minutes() - 30);
var t = db.transactions.findOne( { state: "pending", lastModified: { $lt: dateThreshold } } );
然后回到“3.在两个账户中应用该事务”这一步
Applied状态的事务 例：
获取三十分钟内未成功的事务记录
var dateThreshold = new Date();
dateThreshold.setMinutes(dateThreshold.getMinutes() - 30);
var t = db.transactions.findOne( { state: "applied", lastModified: { $lt: dateThreshold } } );
然后回到“5.更新账户pendingTransactions数组”这一步
回滚操作 有些情况下，可能需要回滚，或者撤销操作，比如，应用程序需要取消事务，或者其中一个账户不存在或者被冻结。
Applied状态的事务 在“4.更新事务状态为applied”这一步之后，不应该再回滚事务，而是应该完成当前事务，然后创建一个新的事务来把数据修改回来。
Pending状态的事务 在“2.更新事务状态为pending”这一步之后，“4.更新事务状态为applied”这一步之前，可以通过以下步骤回滚事务：
1.更新事务状态为取消中
db.transactions.update(
{ _id: t._id, state: "pending" },
{
$set: { state: "canceling" },
$currentDate: { lastModified: true }
}
)
2.在两个账户中取消操作
如果事务已经应用，需要回退这个事务以取消在两个账户上的操作。在更新的条件中，包含pendingTransactions:t._id,以便在pending transaction已经被应用的时候更新账户。
更新目标账户，减去事务中给其增加的值，cong pendingTransactions数组中移除事务_id
db.accounts.update(
{ _id: t.destination, pendingTransactions: t._id },
{
$inc: { balance: -t.value },
$pull: { pendingTransactions: t._id }
}
)
如果pending transaction还没有被应用到这个账户中，将不会有记录匹配查询条件。
3.更新事务状态为已取消
db.transactions.update(
{ _id: t._id, state: "canceling" },
{
$set: { state: "cancelled" },
$currentDate: { lastModified: true }
}
)
更新事务状态为cancelled来标志事务已取消。
多应用情景 由于事务的存在，多个应用可以同时创建和执行操作，而不会产生数据不一致或者冲突。在之前的例子中，更新或者回滚记录，包含state字段的更新条件防止不同应用重复提交事务
例如，app1和app2同时获取了一个在initial状态的事务。app1在app2开始前提交了整个事务。当app2试图更新事务状态为pending的时候，包含state:'initial'的更新条件将不会匹配任何记录，
同时nMatched和nModified将为0.这就表明app2需要回到第一步，重启一个不同的事务过程。
当多个应用运行的时候，关键在有只有一个应用可以及时处理指定的事务。这样的话，即使在有符合更新条件的记录，也可以在事务记录中创建一个标记来标志应用正在处理这个事务。使用findAndModify()方法来修改事务，并且回退。
t = db.transactions.findAndModify(
{
query: { state: "initial", application: { $exists: false } },
update:
{
$set: { state: "pending", application: "App1" },
$currentDate: { lastModified: true }
},
new: true
}
)
修正后的事务操作确保只有标识符匹配的应用可以提交该事务。
如果app1在事务执行中失败，可以使用之前讲的恢复操作，但是应用程序需要在应用事务之前确保“拥有”该事务。
例如，查找并恢复pending状态的job
var dateThreshold = new Date();
dateThreshold.setMinutes(dateThreshold.getMinutes() - 30);
db.transactions.find(
{
application: "App1",
state: "pending",
lastModified: { $lt: dateThreshold }
}
)
在生产环境中使用两步提交 以上的例子是有意写的很简单。例如，它假设一个账户的回滚操作总是可能的，并且账户可以保存负值。
生产环境可能会更加负值，通常来说，账户需要当前账户值，信用，欠款等多种信息。
对于所有事务，要确保使用的是write concern权限等级。
|