`
wbj0110
  • 浏览: 1604637 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

scala akka 修炼之路6(scala函数式柯里化风格应用场景分析)

    博客分类:
  • Akka
阅读更多

胜败兵家事不期,包羞忍耻是男儿——斗牛士fighting,fighting,fighting...

 

    小象学习和使用scala也一段时间了,最初小象学习scala主要为了学习spark生态,但是深入学习scala的一些特性后,深深被scala函数式和面向对象的风格所折服,不得不赞美设计这门语言的设计者。小象大学阶段在使用MATLAB做数据分析和自动化设计时,就非常喜欢使用MATLAB的命令行和面向矩阵运算的风格编写分析代码;喜欢使用java编写层次化和清晰的模块接口,而这些Scala语言设计中都有很好的设计。不得不说scala的函数式和面向对象风格,可以让想想随时发生;如果你是画家,使用scala写出来的代码更像一幅充满诗意的风景画。如果你是作家,写出的将是一个扣人心弦的跌宕起伏的大篇。scala给不同类型的程序员不同的体验和感受。而使用scala函数式柯里化风格,可以编写出更加抽象,功能化和高效的函数式代码。

    小象在定义主函数功能的时候常常出现这种情况,函数体中的代码越写越长,本来可以拆分的功能,由于写代码的时候逻辑思绪根本停不下来,不愿意中途打断去定义那些繁琐的辅助函数,往往一个函数就一路走到头,最后使主函数代码段很长,不便理解,功能复杂,需要后期慢慢拆分功能。小象在学习使用scala函数式柯里化风格后,在思绪停不下来又需要拆分功能的时候,就将定义好需要拆分的辅助功能函数的声明按照柯里化风格定义在函数声明中,继续完成主函数功能,等主函数功能完成后,在慢慢按照顺序去实现这些辅助功能。为了减少或隐藏辅助功能的传入简化接口中不必要的辅助方法参数传入,可以创建主函数的重载。使用scala柯里化风格可以简化主函数的复杂度,提高主函数的自闭性,提高功能上的可扩张性(事实证明:流水化生产式最高效和安全的,代码编写也一样,一个函数实现维护一个功能的完成处理(逻辑处理,相关异常处理等),也是极简设计,优秀代码体检的追求)。

    例如 设计一个获取本地文本文件的所有行数据的功能,主函数功能主要是创建文件流读取文件的所有行,在读取过程中,需要做很多的辅助操作如判断本地文件是否存在和可读和关闭文件流。使用scala的函数式柯里化代码看上去将变得非常优雅

    
[java] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. def getLines(filename:String):List[String]={  
  2.     getLines(filename)(isReadable)(closeStream)  
  3. }  
  4. def getLines(filename: String)(isFileReadable: (File) => Boolean)(closableStream: (Closeable) => Unit):List[String] = {  
  5.     val file = new File(filename)  
  6.     if (isFileReadable(file)) {  
  7.       val readerStream = new FileReader(file)  
  8.       val buffer = new BufferedReader(readerStream)  
  9.       try {  
  10.         var list: List[String] = List()  
  11.         var str = ""  
  12.         var isReadOver = false  
  13.         while (!isReadOver) {  
  14.           str = buffer.readLine()  
  15.           if (str == null) isReadOver = true  
  16.           else list = str :: list  
  17.         }  
  18.         list.reverse  
  19.       } finally {  
  20.         closableStream(buffer)  
  21.         closableStream(readerStream)  
  22.       }  
  23.     } else {  
  24.       List()  
  25.     }  
  26.   }  
  27.   
  28.   def isReadable(file: File) = {  
  29.     if (null != file && file.exists() && file.canRead()) true  
  30.     else false  
  31.   }  
  32.   def closeStream(stream: Closeable) {  
  33.     if (null != stream) {  
  34.       try {  
  35.         stream.close  
  36.       } catch {  
  37.         case ex => Log.error(“[”+this.getClass.getName+”.closeStream]”,ex.getMessage)  
  38.       }  
  39.     }  
  40.   }  

    小象认为使用柯里化特性可以将复杂逻辑简单化,并能将很多常漏掉的主函数业务逻辑之外的处理暴露在函数的定义阶段,提高代码的健壮性,使函数功能更加细腻化和流程化。

    例如 使用REST风格的HTTP资源请求的基于三层架构的MVC模式的WEB开发中前端的请求服务器段处理过程主要包含:第一步服务器端接受用户资源请求,第二步前端调度器代理接受用户资源请求,第三步检查当前请求的合法性,第四步创建相应的申请过滤处理链处理请求,第五步创建渲染视图,第六步响应用户请求。

    如果使用scala编写流程控制函数将非常简单和易于理解

 

[java] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. /** 
  2.    * 用户资源请求=>调度器代理用户资源请求=>检查请求的合法性=>创建相应的资源申请责任链返回Model数据和视图URI=>创建视图=>响应用户请求 
  3.    */  
  4.   def serviceUserRequest[IN,M,V,OUT](requstInputData: IN)(dipatcherDelegeteOp: IN => M)(checkRequestValid: M => Boolean)(filterChains: M => M)(createResponseRestURLView: M => V)(createResponseStream:V=>OUT): OUT = {  
  5.     val request = dipatcherDelegeteOp(requstInputData)  
  6.     if (checkRequestValid(request)) {  
  7.       val model = filterChains(request)  
  8.       val view=createResponseRestURLView(model)  
  9.      createResponseStream(view)  
  10.     } else {  
  11.       //error business handler  
  12.       “return error view URI Stream"  
  13.     }  
  14.   }  

http://blog.csdn.net/yangguo_2011/article/details/30730185

分享到:
评论

相关推荐

    响应式架构 消息模式Actor实现与Scala.Akka应用集成

    8. 实战案例:分析实际项目中的示例,如何将Akka应用于Web服务、大数据处理或其他并发场景。 通过以上知识点的学习,开发者能够熟练掌握使用Scala和Akka构建响应式架构的方法,进而构建出能够适应现代分布式计算...

    scala akka

    - **Scala**: 是一种多范式编程语言,结合了面向对象和函数式的特性,广泛应用于大数据处理领域。Akka正是用Scala编写的,并且充分展示了Scala在并发编程方面的优势。 #### 2. Akka的核心概念:Actor模型 - **...

    Scala函数式编程

    《Scala函数式编程》是针对希望学习FP并将它应用于日常编码中的程序员而写的,内容包括:函数式编程的概念;函数式编程相关的各种“为什么”和“怎么做”;如何编写多核程序;练习和检测。 从OOP到FP,思路的转化 ...

    Scala函数式编程.pdf

    函数式编程(FP)是一种...《Scala函数式编程》是针对希望学习FP并将它应用于日常编码中的程序员而写的,内容包括:函数式编程的概念;函数式编程相关的各种“为什么”和“怎么做”;如何编写多核程序;练习和检测。

    Scala和Spark大数据分析函数式编程、数据流和机器学习

    Scala是一种静态类型的函数式编程语言,而Spark是一个分布式计算框架,尤其适合于大数据处理和分析。本教程将深入探讨这两者如何结合,实现高效的大数据分析、数据流处理以及机器学习任务。 首先,让我们来理解...

    响应式架构++消息模式Actor实现与Scala.Akka应用集成+,沃恩·弗农+

    8. **案例研究**:可能包含实际项目案例,展示如何在真实世界的应用场景中应用Akka和响应式架构。 9. **最佳实践**:提供了一些关于如何设计和实现高性能、可维护的Akka系统的指导原则和建议。 通过阅读这本书,...

    用Scala写的akka actor简单demo

    Scala是多范式编程语言,支持函数式和面向对象编程,与Akka的集成非常紧密。 Akka Actor是Akka的核心组件,它是一种并发原语,通过消息传递来实现异步通信。每个Actor都有自己的邮箱,用于存储接收到的消息,并且在...

    akka框架,应用于scala

    Akka之所以使用Scala语言编写,是因为Scala的强大特性和其与JVM的无缝集成,使得Akka能够充分利用JVM的优势并发挥出Scala的函数式编程和面向对象编程的双重优势。同时,Akka也提供了对Java的全面支持,开发者可以...

    Scala Akka项目源码

    Scala Akka是一个强大的工具包,用于构建高度并发、分布式和反应式的应用程序。它基于actor模型,使得在Java虚拟机(JVM)上编写这类程序变得简单高效。Akka的使用通常涉及以下几个核心概念: 1. **Actor系统**:...

    响应式架构 消息模式Actor实现与Scala.Akka应用集成 ,沃恩·弗农

    集成Scala与Akka意味着利用Scala强大的函数式编程特性,编写出简洁、可读性强的Actor代码。Scala的类型系统和表达式语法使得定义Actor和消息变得非常直观。例如,你可以使用case类来定义消息类型,然后在Actor中使用...

    响应式架构 消息模式Actor实现与Scala.Akka应用集成 高清扫描版

    响应式架构 消息模式Actor实现与Scala.Akka应用集成 高清扫描版

    Akka Scala 学习高清原版pdf

    Akka是一个用Scala和Java编写的库,用于构建并发、分布式以及容错的事件驱动应用。Akka框架借鉴了Erlang的并发模型,但它是建立在JVM之上,并且提供了丰富的抽象和工具,能够简化开发工作。 标题“Akka Scala 学习...

    Reactive Programming with Scala and Akka(Pdf格式)

    《Reactive Programming with Scala and Akka》是一本关于使用Scala语言和Akka框架开发响应式程序的专业书籍。该书系统地介绍了响应式编程的概念、原理和实践,尤其强调了响应式编程在构建可伸缩、高效能、高可靠性...

    基于Akka的加密消息通信.rar_scala akka_基于Akka通信框架的加密通信项目_消息通信

    Scala是一种函数式和面向对象编程语言,它与Java无缝集成,是开发Akka应用的首选语言。尽管描述中提到不支持Scala,但Akka的典型实现是使用Scala编写的,因此我们将以Scala为背景来探讨这个项目。 **Akka Actor系统...

    Scala 函数柯里化(Currying)

    柯里化(Currying)指的是将原来接受两个参数的函数变成新的接受一个参数的函数的过程。新的函数返回一个以原有第二个参数为参数的函数。 实例 首先我们定义一个函数: def add(x:Int,y:Int)=x+y 那么我们应用的时候,...

Global site tag (gtag.js) - Google Analytics