[关闭]
@boothsun 2019-12-08T12:30:12.000000Z 字数 23380 阅读 966

SCALA基础知识学习

大数据


注:本文只说和Java不同的地方。
总结自:
1. Scala详细教程
2. Scala教程

scala基础语法

  1. Scala 与 Java 的最大区别是:Scala 语句末尾的分号 “;” 是可选的。
  2. def main(args: Array[String])Scala程序从main()方法开始处理,这是每一个Scala程序的强制程序入口部分。
  3. 换行符:Scala是面向行的语言,语句可以用分号(;)结束或换行符。Scala程序里,语句末尾的分号通常是可选的。如果你愿意可以输入一个,但若一行里仅有一个语句也可不写。另一方面,如果一行里写多个语句那么分号是需要的。val s = "菜鸟教程"; println(s)
  4. Scala 也是使用import关键字引用包。

    • 使用方式

      1. // 1. 第一种方式 和Java一致
      2. import java.awt.Color
      3. // 2. 引入包内所有成员
      4. import java.awt._
      5. // 3. 如果想要引入包中的几个成员,可以使用selector(选取器)
      6. import java.awt.{Color, Font}
      7. // 4. 重命名成员
      8. import java.util.{HashMap => JavaHashMap}
      9. // 5. 引入了util包的所有成员,但是HashMap被隐藏了
      10. import java.util.{HashMap => _, _}
    • import语句可以出现在任何地方,而不是只能在文件顶部。import的效果从开始延伸到语句块的结束

    • 默认情况下,Scala 总会引入java.lang._scala._Predef._,这里也能解释,为什么以scala开头的包,在使用时都是省去scala.的。

Scala数据类型:

https://www.runoob.com/scala/scala-data-types.html

  1. Unit 表示无值,和其他语言中void等同。用作不返回任何结果的方法的结果类型。Unit 只有一个实例值,写成()
  2. 上表中列出的数据类型都是对象,也就是说scala没有java中的原生类型。在scala是可以对数字等基础类型调用方法的。

变量定义

在Scala中,使用关键字“var”声明变量,使用关键字“val”声明常量。

声明变量和常量不一定要指明数据类型,在没有指明数据类型的情况下,其数据类型是通过变量或常量的初始值推断出来的。但在没有指明数据类型的情况下声明变量或常量必须要给出其初始值,否则将会报错。

  1. object 变量定义 extends App {
  2. /**
  3. * 定义变量使用var或者val关 键 字
  4. *
  5. * 语法:
  6. * var | val 变量名称(: 数据类型) =变量值
  7. */
  8. // 使用val修饰的变量, 值不能为修改,相当于java中final修饰的变量
  9. val name = "tom"
  10. // 使用var修饰的变量,值可以修改
  11. var age = 18
  12. // 定义变量时,可以指定数据类型,也可以不指定,不指定时编译器会自动推测变量的数据类型
  13. val name2 : String = "jack"
  14. }

Scala 访问修饰符

  1. class Outer{
  2. class Inner{
  3. private def f(){println("f")}
  4. class InnerMost{
  5. f() // 正确
  6. }
  7. }
  8. (new Inner).f() //错误
  9. }

条件表达式

  1. object Test {
  2. def main(args: Array[String]) {
  3. var x = 30;
  4. if( x == 10 ){
  5. println("X 的值为 10");
  6. }else if( x == 20 ){
  7. println("X 的值为 20");
  8. }else if( x == 30 ){
  9. println("X 的值为 30");
  10. }else{
  11. println("无法判断 X 的值");
  12. }
  13. }
  14. }
  1. /*
  2. * Scala if条件表达式
  3. */
  4. object ScalaIf extends App {
  5. def main(args: Array[String]): Unit = {
  6. //if语句的使用
  7. var faceValue = 98
  8. var res1 = if (faceValue>90) "帅的一批" else "有点恼火"
  9. print(res1)
  10. //3>5 不成立,且代码没有else分支,那么res2应该输出什么呢?
  11. var i=3
  12. var res2=if (i>5) i // 默认 if后面一定有else 如果没写 默认是 else ()
  13. print(res2)// output ()代表空
  14. // 支持嵌套,if...else if ...else代码过多时可以使用{}
  15. val score=85
  16. if(score<60)"不及格"
  17. else if(score>=60&&score<70)"及格"
  18. else if (score>=80&&score<90)"优秀"
  19. else "优秀"
  20. }
  21. }

循环

while循环 和 do while循环 语法与Java一致

  1. object ForTest {
  2. def main ( args : Array[String]) {
  3. for( ele <- 1 to 9 ) { // 1.to(9)
  4. print (ele + " ") ;
  5. }
  6. val arry = Array(1,2,3,4,5,6)
  7. for( ele <- arry ) {
  8. print(ele + " ")
  9. }
  10. // for循环中可以增加过滤条件,下面这段语句是打印arr数组中的偶数
  11. for(i <- arry if i%2==0){
  12. print(i)
  13. }
  14. printf("\n")
  15. //双层for循环
  16. for (i <- 1 to 3;j <- 1 to 3 if i!=j; if i != 2){
  17. print( i*10 + j + " ")
  18. }/*output:12,13,21,23,31,32*/
  19. // for中使用yield 可以将 for 循环的返回值作为一个变量存储
  20. var retVal = for { a <- arry if a != 3; if a < 8 } yield a
  21. for( a <- retVal){
  22. println( "Value of a: " + a );
  23. }
  24. }
  25. }
  26. <div class="md-section-divider"></div>
  1. var retVal = for { var x <- List
  2. if condition1; if condition2...
  3. } yield x
  4. <div class="md-section-divider"></div>

注意大括号中用于保存变量和条件,retVal是变量,循环中的yield会把当前的元素记下来,保存在集合中,循环结束后将返回该集合。

运算符和运算符重载

Scala 中的+-*/%等操作符的作用与 Java 一样,位操作符 &|^>><<也一样。

只是有一点特别的:这些操作符实际上是方法。例如:

  1. // 下面是等同的
  2. a + b
  3. a.+(b) // a 方法 b 可以写成 a.方法(b)
  4. <div class="md-section-divider"></div>

Int.class的源码

Scala 方法与函数

Scala有方法与函数,二者在语义上的区别很小。Scala方法是类的一部分,而函数是一个对象可以赋值给一个变量。换句话来说在类中定义的函数即是方法。

Scala 中的方法跟 Java 的类似,方法是组成类的一部分。

Scala 中的函数则是一个完整的对象,Scala 中的函数其实就是继承了 Trait 的类的对象。

Scala 中使用 val 语句可以定义函数,def 语句定义方法。

  1. def m(x: Int) = x + 3
  2. val f = (x: Int) => x + 3
  3. def main(args: Array[String]): Unit = {
  4. printf("方法" + m(2) + "\n")
  5. printf("函数" + f(2) + "\n")
  6. }
  7. <div class="md-section-divider"></div>

方法声明:
Scala 方法声明格式如下:

  1. def functionName ([参数列表]) : [return type] = {
  2. // function body
  3. // return [expr]
  4. }
  5. <div class="md-section-divider"></div>

如果你不写等于号和方法主体,那么方法会被隐式声明为抽象(abstract),包含它的类型也将是一个抽象类型。

return type可以是任意合法的Scala数据类型。如果方法没有返回值,可以返回“Unit”,这个类似于Java的“Void”。另外,方法的返回值类型也可以不写,编译器可以自动推断出来,但是对于递归函数,必须指定返回类型。

  1. object add {
  2. def addInt( a:Int, b:Int ) : Int = {
  3. var sum:Int = 0
  4. sum = a + b
  5. return sum
  6. }
  7. }
  8. <div class="md-section-divider"></div>

方法的定义与调用:

  1. object TestMethod {
  2. def m(x: Int) = x + 3
  3. val f = (x: Int) => x + 3
  4. def main(args: Array[String]): Unit = {
  5. printf("方法" + m(2) + "\n") // 方法调用
  6. printf("函数" + f(2) + "\n") // 函数调用
  7. val fm = m _ // 方法变函数 方法名 + 空格 + “_”
  8. printf("方法变函数:" + fm(2))
  9. }
  10. }
  11. <div class="md-section-divider"></div>

函数的定义与调用:
函数的定义方式一:

调用方式:f1(2),其中f1为函数的引用,也可以叫做函数名。function1表示一个参数的函数。

函数定义方式二:

下面为没有任何参数的函数,函数的返回值为Int类型。

  1. object TestFunction {
  2. // val 函数名=参数列表 =>{ 函数体 }
  3. val function2=(x:Int)=> {
  4. val s = x * 10
  5. s +1
  6. } ;
  7. val function3 = (x:Int , y:Int) => {
  8. x + y
  9. }
  10. // val 函数名:(参数类型列表) => 返回值类型 = (参数名列表) => {函数体}
  11. val function4:(Int,Int) => Int =(x,y) => x + y
  12. val function5 =() => {
  13. printf("8")
  14. }
  15. def main(args:Array[String]):Unit = {
  16. println("function2:" + function2(2))
  17. println("function3:" + function3(2,3))
  18. println("function4:" + function4(4,5))
  19. println("function4:" + function5())
  20. }
  21. }
  22. <div class="md-section-divider"></div>

传值调用和传名调用

通常,函数的参数是传值参数;也就是说,参数的值在传递给函数之前就已经确定。

但是,在Scala中,我们方法或者函数的参数还可以是一个表达式,也就是将一个代码逻辑传递给了某个方法或者函数。

在进入函数内部前,传值调用方式就已经将参数表达式的值计算完毕,而传名调用是在函数内部进行参数表达式的值计算的。

这就造成了一种现象,每次使用传名调用时,解释器都会计算一次表达式的值。

我的理解:
+ 传值调用:先计算表达式的值,然后表达式的值作为变量 在函数内部使用;和Java类似。
+ 传名调用:直接将函数或者代码片段传入函数内部。在使用时,在执行函数或者代码片段获取具体值,使用继续值做后续流程。

语法格式:

  1. def 函数名 (参数名 : => 参数类型) : Unit = {
  2. // 方法体
  3. }
  4. <div class="md-section-divider"></div>

使用示例:

  1. object TestCallByName {
  2. def main(args:Array[String]) {
  3. // 传名调用
  4. println("========== 传名调用 =========")
  5. delayed(getTime())
  6. println("========== 传值调用 =========")
  7. // 传值调用
  8. printTime(getTime())
  9. }
  10. def getTime () :Long = {
  11. println("获取时间")
  12. System.nanoTime()
  13. }
  14. def delayed (t : => Long ): Unit = {
  15. println("delayed method")
  16. println("参数值:" + t)
  17. }
  18. def printTime (t:Long) : Unit = {
  19. println("printTime method")
  20. println("当前时间是:" + t)
  21. }
  22. }
  23. 下面是运行输出:
  24. ========== 传名调用 =========
  25. delayed method
  26. 获取时间
  27. 参数值:14121545574709
  28. ========== 传值调用 =========
  29. 获取时间
  30. printTime method
  31. 当前时间是:14121545692211
  32. <div class="md-section-divider"></div>

可变参数函数:

Scala 允许你指明函数的最后一个参数可以是重复的,即我们不需要指定函数参数的个数,可以向函数传入可变长度参数列表。

Scala 通过在参数的类型之后放一个星号来设置可变参数(可重复的参数)。例如:

  1. object ScalaVarParams {
  2. def main (args:Array[String]) : Unit = {
  3. printParams("1","2","3","4")
  4. }
  5. def printParams (params : String*) : Unit = {
  6. for (s <- params) {
  7. println(s)
  8. }
  9. }
  10. }
  11. <div class="md-section-divider"></div>

Scala 函数 - 默认参数值

  1. object DefaultParam {
  2. def main(args:Array[String]) : Unit = {
  3. println(add())
  4. println(add(7,8))
  5. }
  6. def add ( a:Int = 5 , b:Int = 6 ): Int = {
  7. a + b
  8. }
  9. }
  10. <div class="md-section-divider"></div>

Scala函数 - 函数嵌套函数

  1. object Factorial {
  2. def main (args : Array[String]) : Unit = {
  3. println(calculate(9))
  4. }
  5. def calculate( i: Int ) :Int = {
  6. def add ( a:Int ) : Int = {
  7. a + 3
  8. }
  9. def subtract (s:Int) : Int = {
  10. s - 1
  11. }
  12. val tmp = add(i)
  13. subtract(tmp)
  14. }
  15. }
  16. <div class="md-section-divider"></div>

部分参数应用函数

如果函数传递所有预期的参数,则表示已完全应用它。如果只传递几个参数并不是全部参数,那么将返回部分应用的函数。这样就可以方便地绑定一些参数,其余的参数可稍后填写补上。

  1. object PartsParam {
  2. def main(args:Array[String]) : Unit = {
  3. val partAdd = add(1 , _ : Int) ;
  4. println( partAdd ( 2 ) )
  5. println( partAdd ( 3 ) )
  6. }
  7. def add (a : Int , b : Int) : Int = {
  8. a + b
  9. }
  10. }
  11. <div class="md-section-divider"></div>

Scala 指定函数参数名

一般情况下函数调用的参数列表,就按照函数定义时的参数顺序一个个传递。但是我们也可以通过指定函数参数名,并且不需要按照顺序向函数传递参数,实例如下:

  1. object Test {
  2. def main(args: Array[String]) {
  3. printInt(b=5, a=7);
  4. }
  5. def printInt( a:Int, b:Int ) = {
  6. println("Value of a : " + a );
  7. println("Value of b : " + b );
  8. }
  9. }
  10. <div class="md-section-divider"></div>

高阶函数

高阶函数(Higher-Order Function)就是操作其他函数的函数。
Scala 中允许使用高阶函数,高阶函数可以使用其他函数作为参数,或者使用函数作为输出结果。

  1. def main(args:Array[String]) : Unit = {
  2. sayHello(getName,100)/*output:100*/
  3. sayHello(getName,101)/*output:100*/
  4. }
  5. // 高阶函数将其他函数作为参数
  6. def sayHello(f:Int => String,p:Int): Unit ={
  7. println("hello " + f(p))
  8. }
  9. def getName(id:Int): String ={
  10. if ( id == 100 ) {
  11. "张三"
  12. } else {
  13. "无名氏"
  14. }
  15. }
  16. <div class="md-section-divider"></div>

匿名函数

Scala中定义匿名函数的语法很简单,箭头左边是参数列表,右边是函数体。

  1. object AnonymousFunction {
  2. var add = (x:Int) => x+1
  3. def main(args:Array[String]) : Unit = {
  4. println(add(1))
  5. }
  6. }
  7. <div class="md-section-divider"></div>

函数柯里化(Currying)

柯里化(Currying)指的是将原来接受两个参数的函数变成新的接受一个参数的函数的过程。新的函数返回一个以原有第二个参数为参数的函数。

  1. /*
  2. *scala的柯里化
  3. */
  4. object ScalaCurrying extends App{
  5. //定义了一个求和函数
  6. def add(a:Int,b:Int)=a+b
  7. // 那么我们在调用的时候,应该是add(1,2)
  8. // 现在我们将这个函数变形
  9. def add(a:Int)(b:Int)=a+b
  10. // 那么我们在调用的是后应该是add(1)(2),其结果还是等于3,这种方式(或过程)就叫做柯里化,
  11. // 经过柯里化之后函数通用性降低,但是适用性有所提高
  12. //分析下其演变过程
  13. def add(a:Int): Int => Int={
  14. (b:Int)=>a+b
  15. }
  16. //(b:Int)=>a+b 为一个匿名函数,也就意味着add方法的返回值为一个匿名函数,
  17. // 那么现在的调用过程为
  18. var result=add(1)
  19. var sum1=result(2)
  20. }
  21. <div class="md-section-divider"></div>

“闭包”函数

闭包是一个函数,返回值依赖于声明在函数外部的一个或多个变量。
闭包函数通常来说可以简单的认为是可以函数外部局部变量的一个函数。

  1. def main(args: Array[String]) {
  2. println( "multiplier(1) value = " + multiplier(1) )
  3. println( "multiplier(2) value = " + multiplier(2) )
  4. }
  5. var factor = 3
  6. val multiplier = (i:Int) => i * factor //闭包函数
  7. <div class="md-section-divider"></div>

Scala数组

数组的定义

  1. 一维数组语法格式如下:

    1. var 数组变量名:Array[元素类型] = new Array[元素类型](数组大小)
    2. var 数组变量名 = new Array[元素类型](数组大小)
    3. var 数组变量名 = Array (数组元素列表)

    这里的数组大小是可以省略的,如果不写就表示不定长数组。

  2. 多维数组语法格式如下:
    多维数组 一个数组中的值可以是另一个数组,另一个数组的值也可以是一个数组。

    1. var 数组变量名 = ofDim[元素类型](数组大小,数组大小,...)

数组的使用:

  1. def main (args:Array[String]) : Unit = {
  2. val array1 = new Array[String](5) ;
  3. val array2 = Array("1","2","3") ;
  4. // 输出数组元素
  5. println(array1.toBuffer) ;
  6. println(array2.toBuffer) ;
  7. // 访问指定下标位置的元素
  8. println(array2(0))
  9. println(array2(1))
  10. println(array2(2))
  11. // 元素赋值
  12. array1(0) = "0"
  13. array1(1) = "1"
  14. array1(2) = "2"
  15. array1(3) = "3"
  16. array1(4) = "4"
  17. println(array1.toBuffer)
  18. // 创建变长数组
  19. val array3 = ArrayBuffer[Int]()
  20. array3 += 1 // 数组元素末尾追加元素1
  21. array3 += (2,3,4,5)
  22. array3 ++= Array(6,7)
  23. array3.foreach(println)
  24. println("+++++++++++++")
  25. // 指定位置插入元素
  26. array3.insert(0,250)
  27. array3.foreach(println)
  28. println("-------------")
  29. // 指定位置移除元素
  30. array3.remove(0)
  31. array3.foreach(println)
  32. println("-------数组遍历------")
  33. // 数组遍历
  34. array2.foreach(println)
  35. for( a <- array2) {
  36. println(a)
  37. }
  38. var total = 0 ;
  39. for ( i <- array3.indices) {
  40. total += array3(i)
  41. }
  42. println( "total:" + total) ;
  43. var max = 0 ;
  44. for ( i <- 1 to (array3.length - 1) ) {
  45. if (array3(i) > max) max = array3(i)
  46. }
  47. println("max:" + max)
  48. println("+++++++ 数组合并 ++++++")
  49. // 数组合并
  50. var array4 = concat(array1 , array2)
  51. array4.foreach(print)
  52. }
  53. <div class="md-section-divider"></div>

集合

Scala的集合有三大类:序列 Seq、集 Set、映射 Map,所有的集合都扩展自 Iterable特质。在 Scala中集合有可变(mutable)和不可变(immutable)两种类型,immutable类型的集合初始化后就不能改变了。不过,我们仍然可以模拟添加,移除或更新操作。但是这些操作将在每一种情况下都返回一个新的集合,同时使原来的集合不发生改变。

List集合

集合的定义:

  1. // 字符串列表
  2. val site: List[String] = List("Runoob", "Google", "Baidu")
  3. // 整型列表
  4. val nums: List[Int] = List(1, 2, 3, 4)
  5. // 空列表
  6. val empty: List[Nothing] = List()
  7. val list2 = Nil
  8. // 二维列表
  9. val dim: List[List[Int]] =
  10. List(
  11. List(1, 0, 0),
  12. List(0, 1, 0),
  13. List(0, 0, 1)
  14. )
  15. <div class="md-section-divider"></div>

集合的操作:

  1. // LIST的定义
  2. val list1 = List (1,2,3) ;
  3. // Head返回列表第一个元素
  4. println("list1.head:" + list1.head)
  5. // tail返回集合中除了第一个元素之外的其他全部元素。
  6. println("list1.tail:" + list1.tail)
  7. // 判断集合是否为空
  8. println("list1.isEmpty:" + list1.isEmpty)
  9. // 集合连接 可以使用 ::: 运算符或 List.:::() 方法或 List.concat() 方法来连接两个或多个列表
  10. val list2 = List(5,6,7)
  11. val list3 = list1 ::: list2 ;
  12. println("list1 ::: list2 :" + list3)
  13. val list4 = list2.:::(list1)
  14. println("list2.:::(list1) :" + list4)
  15. val list5 = List.concat(list1 , list2)
  16. println(" List.contract(list1 , list2) :" + list5)
  17. // :: 操作符是将给定的头和尾创建一个新的列表
  18. val list6 = list1.:+(9)
  19. val list7 = 10+:list1
  20. <div class="md-section-divider"></div>

Set集合

Scala Set(集合)是没有重复的对象集合,所有的元素都是唯一的。

Scala集合分为可变的和不可变的集合。

默认情况下,Scala使用的是不可变集合,如果你想使用可变集合,需要引用scala.collection.mutable.Set包。默认引用的是scala.collection.immutable.Set

Set的操作:

  1. // ****** 可变SET ******//
  2. val set: mutable.HashSet[Int] = new mutable.HashSet[Int]()
  3. println(set.getClass.getName)
  4. set+=4
  5. set.add(5) // 追加元素
  6. set++= Set (6,7,8) // 添加另一个set中元素
  7. set-=4
  8. set.remove(6)
  9. set.foreach(print)
  10. println()
  11. // ****** 不可变SET *****//
  12. val set2 = Set(1,2,3)
  13. // 不可变SET 也有添加或删除操元素操作。但是,每次会产生一个新的SET,原来的SET 并没有改变。
  14. val set3 = set2.drop(1)
  15. set2.foreach(print)
  16. println()
  17. set3.foreach(print)
  18. <div class="md-section-divider"></div>

Map集合

默认情况下 Scala 使用不可变 Map。如果你需要使用可变Map,你需要显式的引入import scala.collection.mutable.Map类;不可变的直接使用 Map,可变的使用mutable.Map

  1. object TestMap {
  2. def main(args: Array[String]): Unit = {
  3. // ********** Map定义 ********* //
  4. val map1:Map[String,Int] = Map()
  5. val map2 = Map("A" -> 1 , "B" -> 2 , "C" -> 3)
  6. println(map1)
  7. println(map2)
  8. // *********** Map操作 ******** //
  9. println( "map1 中的键为 : " + map2.keys )
  10. println( "map1 中的值为 : " + map2.values )
  11. println( "检测 map1 是否为空 : " + map2.isEmpty )
  12. // ******** Map合并 *********** //
  13. val map3 = Map( "C" -> 3 , "D" -> 4)
  14. val map4 = map2 ++ map3
  15. val map5 = map2.++(map3)
  16. println("map4 = map2 ++ map3:" + map4)
  17. println("map5 = map2.++(map3):" + map5)
  18. // ******** 删除元素 ******* //
  19. val map6 = map5 - ("C")
  20. val map7 = map5.-("A","B")
  21. println("map5 - (\"C\"):" + map6)
  22. println("map5.-(\"A\",\"B\"):" + map7)
  23. }
  24. }
  25. <div class="md-section-divider"></div>

元组

与列表一样,元组也是不可变的,但与列表不同的是元组可以包含不同类型的元素。

元组定义:

  1. val t = (1, 3.14, "Fred");
  2. // 或
  3. val t = new Tuple3(1, 3.14, "Fred");
  4. <div class="md-section-divider"></div>

元组的实际类型取决于它的元素的类型,比如 (99, "runoob") 是 Tuple2[Int, String]。 ('u', 'r', "the", 1, 4, "me") 为 Tuple6[Char, Char, String, Int, Int, String]。

目前 Scala 支持的元组最大长度为22。对于更大长度你可以使用集合,或者扩展元组。

  1. object TestTuple {
  2. def main(args: Array[String]): Unit ={
  3. val tuple3 = (1, 3.14, "Fred") ;
  4. val tuple2 = new Tuple2(1, "Fred")
  5. val tuple4 = new Tuple4(1, 6.66, "Fred",'C')
  6. println(tuple3)
  7. println(tuple2)
  8. println(tuple4)
  9. val t = (4,3,2,1)
  10. val sum = t._1 + t._2 + t._3 + t._4 //使用._n 访问元组中的第N个元素
  11. println( "元素之和为: " + sum )
  12. t.productIterator.foreach{ i =>println("Value = " + i )} // 元组遍历
  13. println("连接后的字符串为: " + t.toString())
  14. println("t.swap" + tuple2.swap) // 二元组中 元素交换
  15. }
  16. }
  17. <div class="md-section-divider"></div>

集合操作

map, flatten, flatMap, filter, sorted, sortBy, sortWith, grouped, fold(折叠), foldLeft, foldRight, reduce, reduceLeft, aggregate, union, intersect(交集), diff(差集), head, tail, zip, mkString, foreach, length, slice, sum

  1. object TestCollectionOperation {
  2. def main(args:Array[String]) : Unit = {
  3. // ******** Map操作 *******//
  4. val arr = Array(1,5,2,3,4)
  5. val arrMap1 = arr map((x:Int) => x * 2)
  6. val arrMap2 = arr.map(x => x * 2)
  7. val arrMap3 = arr.map(_ * 2)
  8. arrMap1.foreach(print)
  9. println()
  10. arrMap2.foreach(print)
  11. println()
  12. arrMap3.foreach(print)
  13. // ******* flatten操作 *****//
  14. val words=Array("tom jack oliver jack","hello tom oliver tom ")
  15. // 将words中元素按照“,”切分
  16. val splitWords: Array[Array[String]] = words.map(x=>x.split(" "))
  17. //此时数组中的每个元素进行split操作之后变成了Array,
  18. // flatten是对splitWords里面的元素进行扁平化操作
  19. val flatten: Array[String] = splitWords.flatten
  20. flatten.foreach(print)
  21. println()
  22. // ******* flatMap操作 ******* //
  23. // 上诉两步操作可以等价于flatmap,意味着先map操作之后进行flatten操作
  24. val result=words.flatMap(_ .split(" "))
  25. result.foreach(print)
  26. println()
  27. // **** filter操作 ****//
  28. val filterArr = arr.filter( x => x == 2)
  29. filterArr.foreach(print)
  30. // **** sorted操作 ****//
  31. arr.sorted.foreach(print) //升序排序
  32. println()
  33. // ***** sortBy操作 ****//
  34. arr.sortBy( x => -x).foreach(print)
  35. val wordTuple=List(("a",3),("b",5),("c",2))
  36. wordTuple.sortBy( t => t._2).foreach(print)
  37. }
  38. }
  39. <div class="md-section-divider"></div>

Scala 类和对象

类定义

Scala中的类不声明为public,一个Scala源文件中可以有多个类。
Scala中的类定义可以有参数,称为类参数。类参数在整个类中都可以访问。
Scala中也可以使用new关键字来创建类的对象。

实例:

  1. import java.io._
  2. class Point(xc: Int, yc: Int) {
  3. var x: Int = xc
  4. var y: Int = yc
  5. def move(dx: Int, dy: Int) {
  6. x = x + dx
  7. y = y + dy
  8. println ("x 的坐标点: " + x);
  9. println ("y 的坐标点: " + y);
  10. }
  11. }
  12. object Test {
  13. def main(args: Array[String]) {
  14. val pt = new Point(10, 20);
  15. // 移到一个新的位置
  16. pt.move(10, 10);
  17. }
  18. }
  19. <div class="md-section-divider"></div>

类成员变量 | 构造器

  1. 如果你没有定义构造器,类会有一个默认的空参构造器。
  2. scala中 var类型的类成员变量默认对外提供setter、getter方法。val类型的类成员变量默认对外提供getter方法,不提供setter方法。

    1. class Student {
    2. // _表示一个占位符,编译器会根据你变量的类型赋予相应的初始值
    3. var name:String=_
    4. // 错误代码,val修饰的变量不能使用占位符
    5. // val age:Int=_
    6. val age:Int=10
    7. }
    8. object test{
    9. def main(args: Array[String]): Unit = {
    10. // 空参构造器可以加()也可以不加
    11. val student = new Student()
    12. student.name="JackMa"
    13. // 错误代码,类中使用val修饰的变量不能更改
    14. // student.age=20
    15. println(s"name=${student.name},age=${student.age}")
    16. }
    17. }
  3. scala中构造器分为主构造器和辅助构造器。在类定义后面跟着的参数列表为类主构造器,在类里定义的构造器为辅助构造器,一个类可以有多个辅助构造器。

    1. /*
    2. * 定义在类名称后面的构造器为主构造器
    3. * 类的主构造器中的属性会定义成类的成员变量
    4. * 类的主构造器中属性没有被var|val修饰的话,该属性不能访问,相当于对外没有提供get方法
    5. * 如果属性使用var修饰,相当于对外提供set和get方法
    6. */
    7. class Student1(var name:String,val age:Int){ // 主构造器
    8. var gender:String=_
    9. def this(name:String,age:Int,gender:String){ // 辅助构造器
    10. this(name,age)
    11. this.gender=gender
    12. }
    13. }
    14. object test{
    15. def main(args: Array[String]): Unit = {
    16. val s1 = new Student1("Tom",18)
    17. println(s"name=${s1.age},age=${s1.age},gender=${s1.gender}")
    18. val s2 = new Student1("JackMa",20,"man")
    19. println(s2.gender)
    20. // output:
    21. // name=18,age=18,gender=null
    22. // man
    23. }
    24. }

访问权限

  1. 构造器的访问权限

    1. /*
    2. * private 加在构造器之前,这说明该类的构造器是私有的,外部对象或者外部类不能访问。伴生类可以访问
    3. */
    4. class Student2 private(var name:String,val age:Int){
    5. var gender:String=_
    6. private def this(name:String,age:Int,gender:String){
    7. this(name,age)
    8. this.gender=gender
    9. }
    10. }
  2. 成员变量的访问权限

    1. /*
    2. * age加上private 也就意味着age只能在这个类的内部及其伴生类中可以修改
    3. */
    4. class Student3 private(){
    5. private var name:String=_
    6. // 伴生类可以访问
    7. private var age:Int=_
    8. // private [this]关键字标识给属性只能在类内部访问,伴生类不能访问
    9. private [this] var gender:String="man"
    10. }
    11. // 伴生类
    12. object Student3 {
    13. def main(args: Array[String]): Unit = {
    14. val student3 = new Student3()
    15. // 伴生对象可以访问
    16. student3.name = "jack"
    17. student3.age = 20
    18. println(s"name=${student3.name},age=${student3.age}")
    19. // 伴生类不能访问
    20. //println(student.gender)
    21. }
    22. }
  3. 类包的访问权限

    1. /*
    2. * private [this] class放在类声明最前面,是修饰类的访问权限,也就是说类在某些包下可见或不能访问
    3. * private [sheep] class代表该类在sheep包及其子包下可见,同级包不能访问
    4. */
    5. private [this] class Student4 (val name:String,private var age:Int){
    6. var gender :String=_
    7. // error : age is already defined in the scope
    8. // var age:Int = _ ;
    9. }
    10. // 伴生类
    11. object Student4{
    12. def main(args: Array[String]): Unit = {
    13. val s = new Student4("JackMa",18)
    14. print(s.age)
    15. }
    16. }

伴生类 | apply方法

在scala 中,是没有static这个东西的,但我们也可以使用关键字object去定义单例对象。

在 Scala 中,当单例对象与某个类共享同一个名称时,他被称作是这个类的伴生对象。必须 在同一个源文件里定义类和它的伴生对象。类被称为是这个单例对象的伴生类。类和它的伴生对象可以互相访问其私有成员。

scala中的object相当于java中的public static class,意思是object中成员都是静态的,不需要创建实例对象就可以被虚拟机直接调用。所以scala中的main方法都是写在object类中的。

  1. // 私有构造方法
  2. class Marker private(val color:String) {
  3. println("创建" + this)
  4. override def toString(): String = "颜色标记:"+ color
  5. }
  6. // 伴生对象,与类名字相同,可以访问类的私有属性和方法
  7. object Marker{
  8. private val markers: Map[String, Marker] = Map(
  9. "red" -> new Marker("red"),
  10. "blue" -> new Marker("blue"),
  11. "green" -> new Marker("green")
  12. )
  13. def apply(color:String) = {
  14. if(markers.contains(color)) markers(color) else null
  15. }
  16. def getMarker(color:String) = {
  17. if(markers.contains(color)) markers(color) else null
  18. }
  19. def main(args: Array[String]) {
  20. println(Marker("red"))
  21. // 单例函数调用,省略了.(点)符号
  22. println(Marker getMarker "blue")
  23. }
  24. }
  25. <div class="md-section-divider"></div>

Scala 继承

Scala继承跟Java很相似,但我们需要注意以下几点:

  1. 重写一个非抽象方法必须使用override修饰符。
  2. 只有主构造函数才可以往基类的构造函数里写参数。
  3. 在子类中重写超类的抽象方法时,你不需要使用override关键字。
  1. class Person {
  2. var name = ""
  3. override def toString = getClass.getName + "[name=" + name + "]"
  4. def say () :Unit = {
  5. println("I am person")
  6. }
  7. }
  8. class Employee extends Person {
  9. var salary = 0.0
  10. override def toString = super.toString + "[salary=" + salary + "]"
  11. override def say(xc: String) :Unit = {
  12. println("My name is ${name} , i am employer");
  13. }
  14. }
  15. object TestOverride extends App {
  16. val fred = new Employee
  17. fred.name = "Fred"
  18. fred.salary = 50000
  19. println(fred)
  20. fred.say() ;
  21. }
  22. <div class="md-section-divider"></div>

Scala Trait

ScalaTrait 相当于 Java 的接口,实际上它比接口还功能强大。
与接口不同的是,它还可以定义属性和方法的实现,并且还是通过extend关键字实现Trait。
一般情况下Scala的类只能够继承单一父类,但是如果是Trait(特质)的话就可以继承多个,实现了多重继承。
Trait定义的方式与类定义相似,但它使用的关键字是trait。

  1. trait ScalaTrail {
  2. // 定义了一个属性
  3. var pro:Int=666
  4. // 定义一个没有实现的方法
  5. def sayHello(name:String)
  6. // 定义了一个带具体实现的方法
  7. def small(name:String): Unit ={
  8. println(s"太阳对${name}笑")
  9. }
  10. }
  11. object ScalaTrailImpl extends ScalaTrail {
  12. // 实现方法时可以有override关键字,也可以没有
  13. def sayHello(name: String): Unit = {
  14. println(s"hello $name")
  15. }
  16. // 重写方法时必须得有override关键字
  17. override def small(name: String): Unit = {
  18. println(s"$name like small")
  19. }
  20. }
  21. object TestTrait extends App {
  22. ScalaTrailImpl.sayHello("Oliver")
  23. // 如果ScalaTrailImpl没有重写small方法,则调用ScalaTrail中已经实现了的方法
  24. // 如果ScalaTrailImpl重写了small方法,则调用的是ScalaTrailImpl中的方法
  25. ScalaTrailImpl.small("wang")
  26. // output:
  27. // hello Oliver
  28. // wang like small
  29. }
  30. <div class="md-section-divider"></div>

抽象类

在 Scala 中,使用 abstract 修饰的类称为抽象类. 在抽象类中可以定义属性、未实现的方法和具体实现的方法。

  1. abstract class Animal{
  2. // 定义了一个属性
  3. var name:String="animal"
  4. // 定义一个未实现方法
  5. def sleep()
  6. // 定义一个带具体实现方法
  7. def eat(f:String): Unit ={
  8. println(s"eating $f")
  9. }
  10. }
  11. <div class="md-section-divider"></div>

type关键字

Scala里的类型,除了在定义 class,trait,object时会产生类型,还可以通过 type 关键字来声明 类型。
type 相当于声明一个类型别名:

  1. object test extends App {
  2. // 把String类型用S代替
  3. type S = String
  4. var name : S= "Oliver"
  5. println(name)
  6. }
  7. <div class="md-section-divider"></div>

样例类/样例对象

  1. /*
  2. * 样例类,使用case关键字修饰的类,其重要的就是支持模式匹配
  3. * 样例类:case class 类名(属性)
  4. * 类名定义必须是驼峰式,属性名称第一个字母小写
  5. */
  6. case class Message(sender:String,massageContent:String)
  7. /*
  8. * 样例对象不能封装数据
  9. */
  10. case object CheckHeartBeat
  11. <div class="md-section-divider"></div>

枚举类

Scala中的枚举类继承自Enumeration

  1. object EnumTest {
  2. /***
  3. * 定义一个星期的枚举
  4. */
  5. object WeekDay extends Enumeration{
  6. type WeekDay = Value //声明枚举对外暴露的变量类型
  7. val Mon = Value("1")
  8. val Tue = Value("2")
  9. val Wed = Value("3")
  10. val Thu = Value("4")
  11. val Fri = Value("5")
  12. val Sat = Value("6")
  13. val Sun = Value("7")
  14. def checkExists(day:String) = this.values.exists(_.toString==day) //检测是否存在此枚举值
  15. def isWorkingDay(day:WeekDay) = ! ( day==Sat || day == Sun) //判断是否是工作日
  16. def showAll = this.values.foreach(println) // 打印所有的枚举值
  17. }
  18. def main(args: Array[String]): Unit = {
  19. println(WeekDay.checkExists("8"))//检测是否存在
  20. println(WeekDay.Sun==WeekDay.withName("7"))//正确的使用方法
  21. println(WeekDay.Sun=="7")//错误的使用方法
  22. WeekDay.showAll //打印所有的枚举值
  23. println(WeekDay.isWorkingDay(WeekDay.Sun)) //是否是工作日
  24. }
  25. }
  26. <div class="md-section-divider"></div>

模式匹配 match case

一个模式匹配包含了一系列备选项,每个都开始于关键字 case。每个备选项都包含了一个模式及一到多个表达式。箭头符号 => 隔开了模式和表达式。match 对应 Java 里的 switch,但是写在选择器表达式之后。即:选择器 match {备选项}

所以,scala中的match case 类似于Java中的swtich case break ; default

match 表达式通过以代码编写的先后次序尝试每个模式来完成计算,只要发现有一个匹配的case,剩下的case不会继续匹配。

值匹配/类型匹配

  1. object TestMatchCase extends App {
  2. /*
  3. * 字符串等值匹配
  4. */
  5. def contentMatch(str:String)=str match {
  6. case "dog"=>println("小狗")
  7. case "cat"=>println("小猫")
  8. case "1"=>println("数字1")
  9. case _ => println("匹配失败")
  10. }
  11. contentMatch("cat")
  12. contentMatch("1")
  13. contentMatch("2")
  14. // output:
  15. // 小猫
  16. // 数字1
  17. // 匹配失败
  18. /*
  19. * 匹配类型
  20. */
  21. def typeMatch(ele:Any)=ele match {
  22. case x:Int=>println(s"Int:${x}")
  23. case y:Double=>println(s"Double:${y}")
  24. case z:String=>println(s"String:${z}")
  25. case _ =>println("match failure")
  26. }
  27. typeMatch("hello")
  28. typeMatch(2)
  29. typeMatch(2d)
  30. }
  31. <div class="md-section-divider"></div>

数组匹配

  1. object TestMatchCase extends App {
  2. /*
  3. * 匹配数组
  4. */
  5. def arrayMatch(arr:Any)=arr match {
  6. case Array(0)=>println("只有一个0元素的数组")
  7. case Array(0,_)=>println("以0开头,拥有两个元素的数组")
  8. case Array(1,_,3)=>println("以1开头,3结尾的任意三个元素的数组")
  9. case Array(_*)=>println("N个元素的数组")
  10. }
  11. arrayMatch(Array(0))
  12. arrayMatch(Array(0,2))
  13. arrayMatch(Array(1,true,3))
  14. arrayMatch(Array(1,3,5,7,9))
  15. // output:
  16. // 只有一个0元素的数组
  17. // 以0开头,拥有两个元素的数组
  18. // 以1开头,3结尾的任意三个元素的数组
  19. // N个元素的数组
  20. }
  21. <div class="md-section-divider"></div>

集合匹配

  1. object TestMatchCase extends App {
  2. /*
  3. * 匹配集合
  4. * Nil表示一个空的list,与list中的元素类型无关,他可以同时表示List[任意类型]的空集合。
  5. */
  6. def listMatch(list:Any)=list match {
  7. case 0::Nil=>println("只有0元素的集合")
  8. case 7::9::Nil=>println("只有7和9两个元素的集合")
  9. case x::y::z::Nil=>println(s"只有三个元素集合${x},${y},${z}")
  10. case m::n=>println(s"拥有head和tail的集合。head:${m},tail:${n}")
  11. }
  12. listMatch(List(0))
  13. listMatch(List(7,9))
  14. listMatch(List(1,2,3))
  15. listMatch(List(8,7,6,5,4))
  16. // output:
  17. // 只有0元素的集合
  18. // 只有7和9两个元素的集合
  19. // 只有三个元素集合1,2,3
  20. // 拥有head和tail的集合。head:8,tail:List(7, 6, 5, 4)
  21. }
  22. <div class="md-section-divider"></div>

元组匹配

  1. object TestMatchCase extends App {
  2. /*
  3. * 匹配元组
  4. */
  5. def tupMatch(tup:Any)=tup match {
  6. case (3,x,y)=>println("第一个元素为3的元组")
  7. case (_,2)=>println("第二个元素为2,拥有两个元素的数组")
  8. case (x,y,z)=>println("拥有三个元素的任意元组")
  9. }
  10. tupMatch((3,2,1))
  11. tupMatch((3,2))
  12. tupMatch((4,2,1))
  13. // output:
  14. // 第一个元素为3的元组
  15. // 第二个元素为2,拥有两个元素的数组
  16. // 拥有三个元素的任意元组
  17. }
  18. <div class="md-section-divider"></div>

样例类

使用了case关键字的类定义就是样例类(case class),样例类是种特殊的类,经过优化以用于模式匹配。

  1. case object CheckTimeOutTask
  2. case class SubmitTask(id:String,name:String)
  3. case class HeartBeat(time:Long)
  4. object test extends App{
  5. /*
  6. * 匹配样例类,样例对象
  7. */
  8. def coMatch(ele:Any)=ele match {
  9. case SubmitTask(id,name)=>println(s"submit task-id:${id},task-name:${name}")
  10. case CheckTimeOutTask=>println("checking.....")
  11. case HeartBeat(time)=>println(s"time is ${time}")
  12. }
  13. coMatch(SubmitTask("001","node1"))
  14. coMatch(CheckTimeOutTask)
  15. coMatch(HeartBeat(8888888L))
  16. coMatch(HeartBeat(6666))
  17. // output:
  18. // submit task-id:001,task-name:node1
  19. // checking.....
  20. // time is 8888888
  21. // time is 6666
  22. }
  23. <div class="md-section-divider"></div>

正则表达式

  1. import scala.util.matching.Regex
  2. object ScalaTest extends App {
  3. val pattern = "Scala".r // String 类的 r() 方法构造了一个Regex对象。
  4. val str = "Scala is Scalable and cool"
  5. println(pattern findFirstIn str) // 使用 findFirstIn 方法找到首个匹配项
  6. println((pattern findAllIn str).mkString(",")) // 使用 findAllIn 方法获得全部的匹配项。 mkString方法来连接正则表达式匹配结果的字符串
  7. val pattern2 = new Regex("(S|s)cala") // 首字母可以是大写 S 或小写 s
  8. val str2 = "Scala is scalable and cool"
  9. println((pattern2 findAllIn str2).mkString(",")) // 使用 findAllIn 方法获得全部的匹配项。 mkString方法来连接正则表达式匹配结果的字符串
  10. val pattern3 = "(S|s)cala".r
  11. val str3 = "Scala is scalable and cool"
  12. println(pattern3 replaceFirstIn(str3, "Java")) // 使用 replaceFirstIn 方法来替换第一个匹配项
  13. println(pattern3 replaceAllIn(str3, "Java")) // 使用 replaceAllIn 方法来替换全部匹配项
  14. }
  15. <div class="md-section-divider"></div>

异常处理

Scala中的异常和Java中的异常基本相似;只有捕捉异常的catch子句,语法与其他语言中不太一样。在Scala里,借用了模式匹配的思想来做异常的匹配。因此,在catch的代码里,是一系列case字句。

  1. import java.io.FileReader
  2. import java.io.FileNotFoundException
  3. import java.io.IOException
  4. object Test {
  5. def main(args: Array[String]) {
  6. try {
  7. val f = new FileReader("input.txt")
  8. } catch {
  9. case ex: FileNotFoundException => {
  10. println("Missing file exception")
  11. }
  12. case ex: IOException => {
  13. println("IO Exception")
  14. }
  15. } finally {
  16. println("Exiting finally...")
  17. }
  18. }
  19. }
  20. <div class="md-section-divider"></div>

泛型

  1. /*
  2. * 定义了一个泛型类
  3. */
  4. class Massage[T]{
  5. def getMassage(s:T): Unit ={
  6. println(s)
  7. }
  8. }
  9. /*
  10. * 子类继承指明类型
  11. */
  12. class strMassage[String] extends Massage{
  13. }
  14. object TestT extends App {
  15. val msg = new Massage[String]
  16. msg.getMassage("有内鬼,终止交易")
  17. }
  1. [T]定义泛型
  2. 上界:<T extends Test><? extends Test>
  3. 下界:[T <: Test][_ <: Test]
添加新批注
在作者公开此批注前,只有你和作者可见。
回复批注