1. 介绍
Scala语言拥有很强的表达能力，语法简洁，很接近人类的思考方式。利用map、flatMap方法做数据转换时，层层递进的演算方式，很像是在画流程图，中间没有停顿，思绪很流畅，不会被无关的变量声明、初始化等琐事打断。Scala中的Future可以让你非常灵活的使用线程，而不需要关注底层的线程管理问题，Scala已经为你处理好一切。下面我们以一个示例来说明，将Future、map和flatMap组合起来会产生多大的威力！
2. 需求描述
假设我们是一个VPS服务器提供商，现在考虑用户购买了VPS之后，要在控制台上执行创建磁盘快照的操作。系统需要执行的步骤如下：
1）根据用户id和VPS id，到数据库中分别取出相应记录
2）检查用户和VPS的状态，如果状态异常，返回报错信息
3）向消息队列发送一条创建磁盘快照的消息，如果消息发送失败，返回报错信息
4）执行过程中，如果有异常抛出，直接返回错误页面
如果只有上面这四条需求，你是不是觉得也太简单了！好吧，下面重头戏来了，为了保证系统的高并发，我们还有第五条要求，
5）所有的操作都要异步执行，不能阻塞当前处理请求的线程
小伙伴们，如何实现，你想好了吗？
3. Scala实现
既要异步执行，又要优雅地处理跨线程异常，看看Scala是如何处理的吧！
1def doDiskSnapshot(uid: String, vpsId: String) = Action.async { implicit request => { 2 for { 3 Some(user) <- getCollection("user").find(Json.obj("_id" -> uid)).one[User] 4 Some(vps) <- getCollection("vps").find(Json.obj("_id" -> vpsId)).one[Vps] 5 } yield { 6 if(!user.disabled && !vps.disabled){ true } else { false } 7 } 8 }.flatMap{ isValid => 9 if(isValid){ 10 getCollection("snapshot-task").insert(SnapshotTask(...)).map{ wr => 11 if(wr.ok && wr.n == 1){ 12 Ok("操作成功！") 13 } else { 14 Ok("操作失败！") 15 } 16 } 17 } else { 18 Future(Ok("很抱歉，您的操作已被系统拒绝！")) 19 } 20 }.recover{ 21 case t => 22 Ok("很抱歉，发生系统错误，请稍候重试！") 23 } 24}
第3-4行：从数据库中取出用户和VPS记录
第6行： 返回状态检查结果
第8行： 数据传递
第9行： 检查状态信息
第10行： 发送消息
第20行： 错误处理
整个执行过程一气呵成，去掉方法声明一共22行代码，没有任何拖沓冗余的地方，让人不得不感叹Scala设计之精妙！
好了，文章到此结束。感兴趣的同学可以猜猜看：假设线程池足够大，上面的代码一共用到了几个线程？答案会在后面公布。