Scala進階之路-I/O流操作之文件處理

　　　　　　　　　　　　　Scala進階之路-I/O流操作之文件處理

　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　作者：尹正傑

版權聲明：原創作品，謝絕轉載！否則將追究法律責任。

 

 

 

　　說起Scala語言操作文件對象其實是很簡單的，大部分代碼和Java相同。

 

一.使用Scala拷貝文件實現

/*
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/Scala%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/
package cn.org.yinzhengjie.file

import java.io._

object FileDemo {
    /**
      * 定義讀取文件的方法
      */
    def readFile(filePath:String): Unit ={
        val f = new File(filePath)
        val fis = new FileInputStream(f)
        val buf = new BufferedReader(new InputStreamReader(fis))
        var line = "";
        /**
          *     我這里定義一個標志位，判斷文件是否讀取完畢，不建議使用break，不僅僅是因為它需要導報，而是因為它是以拋異常的
          * 方式結束了整個程序！這一點我真的想吐槽Scala啦！比起Python，Java,Golang，Scala是沒有continue和break關鍵字的！
          */
        var flag:Boolean= true
        while (flag){
            line = buf.readLine()
            //注意，Scala在讀取文件時，如果讀到最后會返回一個null值，因此，此時我們將標志位改為false，以便下一次結束while循環
            if (line == null){
                flag = false
            }else{
                println(line)
            }
        }
        buf.close()
        fis.close()
    }

    /**
      * 拷貝文本文件
      */
    def copyFile(Input:String)(OutPut:String): Unit ={
        val input = new File(Input)
        val output = new File(OutPut)
        val fis = new FileInputStream(input)
        val fos = new FileOutputStream(output)
        val buf = new BufferedReader(new InputStreamReader(fis))
        val cache = new BufferedWriter(new OutputStreamWriter(fos))
        var line = "";
        var flag:Boolean= true
        while (flag){
            line = buf.readLine()
            if (line == null){
                flag = false
            }else{
                cache.write(line)
                cache.write("\r\n")
                cache.flush()
            }
        }
        cache.close()
        fos.close()
        fis.close()
        println("拷貝完畢")
    }


    /**
      * 拷貝任意類型文件，包括二進制文件
      */
    def copyFile2(Input:String)(OutPut:String): Unit ={
        val fis = new FileInputStream(Input)
        val fos = new FileOutputStream(OutPut)
        //定義緩沖區
        val buf = new Array[Byte](1024)
        var len = 0

        /**
          * 注意：len = fis.read(buf)是一個賦值操作，這個賦值操作是沒有任何的返回值的喲！因此我們需要返回len的值。
          */
        while ({len = fis.read(buf);len} != -1){
            fos.write(buf,0,len)
        }
        fos.close()
        fis.close()
        println("拷貝完畢")
    }

    def main(args: Array[String]): Unit = {
        var input = "D:\\BigData\\JavaSE\\yinzhengjieData\\1.java"
        var output = "D:\\BigData\\JavaSE\\yinzhengjieData\\2.java"
//        readFile(input)
        copyFile2(input)(output)
    }
}




/*
以上代碼輸出結果如下 :
拷貝完畢
 */

 

二.讀取用戶的輸出

/*
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/Scala%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/
package cn.org.yinzhengjie.file

import scala.io.StdIn

object ConsoleDemo {
    def main(args: Array[String]): Unit = {
        //控制台交互--老API
        print("請輸入內容:")
        val consoleLine1 = Console.readLine()
        println("老API輸入的內容是:" + consoleLine1)

        //控制台交互--新API
        print("請輸入內容(新API):")
        val consoleLine2 = StdIn.readLine()
        println("新API輸入的內容是:" + consoleLine2)
    }
}

　　以上代碼執行結果如下:

 

三.Scala文件處理常用方法

/*
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/Scala%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/
package cn.org.yinzhengjie.file

object SourceDemo {
    def main(args: Array[String]): Unit = {
        var input = "D:\\BigData\\JavaSE\\yinzhengjieData\\1.java"
        val f = scala.io.Source.fromFile(input)
        println(f)

        /**
          *  迭代打印文件中的每行內容
          */
//        val it = f.getLines()
//        for(x <- it){
//            println(x)
//        }

        /**
          * 讀取整個文件串
          */
        println(f.mkString)

        /**
          * 迭代每個字符
          */
//        for(c <- f){
//            print(c)
//        }

        /**
          * 使用正則 s:空白符 S:非空白符
          *     所謂的空白符就是指：空格，制表符，換行符等等
          */
//        val arr = f.mkString.split("\\s+")
//        for(a <- arr){
//            println(a)
//        }

    }
}

　　使用Scala爬取網頁，在網上找了一些寫的都長篇大論，屬實懶得看，爬蟲的話建議還是用Java或者Python去寫，Java爬取網頁的筆記可參考：https://www.cnblogs.com/yinzhengjie/p/9366013.html。

/*
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/Scala%E8%BF%9B%E9%98%B6%E4%B9%8B%E8%B7%AF/
EMAIL:[e-mail]
*/
package cn.org.yinzhengjie.file

import java.io.FileOutputStream

object ReptilianDemo {

    def copyFile(Input:String)(OutPut:String): Unit ={
        val fos = new FileOutputStream(OutPut)
        fos.write(Input.getBytes())
        println("拷貝完畢")
    }

    def main(args: Array[String]): Unit = {
        /**
          * Scala的fromURL方法我是不推薦使用的，因為爬去的內容不完全，需要設置相應的參數，建議用java代碼或者Python去爬取
          *     可參考：https://www.cnblogs.com/yinzhengjie/p/9366013.html
          */
        val res = scala.io.Source.fromURL("https://www.cnblogs.com/yinzhengjie")
        val html = res.mkString
        println(html)
        var output = "D:\\BigData\\JavaSE\\yinzhengjieData\\尹正傑.html"
        copyFile(html)(output)

    }
}

　　訪問成功的話，在控制端會打印如下信息: