gitbook/朱涛 · Kotlin编程第一课/docs/477295.md

654 lines
28 KiB
Markdown
Raw Permalink Normal View History

2022-09-03 22:05:03 +08:00
# 08 | 实战用Kotlin写一个英语词频统计程序
你好,我是朱涛。
前面几节课我们学了一些Kotlin独有的特性包括扩展、高阶函数等等。虽然我在前面的几节课当中都分别介绍了这些特性的实际应用场景但那终归不够过瘾。因此这节课我们来尝试将这些知识点串联起来一起来写一个“单词词频统计程序”。
英语单词的频率统计,有很多实际应用场景,比如高考、研究生考试、雅思考试,都有对应的“高频词清单”,考生优先突破这些高频词,可以大大提升备考效率。那么这个高频词是如何统计出来的呢?当然是通过计算机统计出来的。只是,我们的操作系统并没有提供这样的程序,想要用这样的功能,我们必须自己动手写。
而这节课我将带你用Kotlin写一个单词频率统计程序。为了让你更容易理解我们的程序同样会分为三个版本。
* **1.0 版本**:实现频率统计基本功能,使用“命令式风格”的代码。
* **2.0 版本**:利用扩展函数、高阶函数来优化代码,实现“函数式风格”的代码。
* **3.0 版本**使用inline进一步提升软件的性能并分析高阶函数的实现原理以及inline到底能带来多大的性能提升。
在正式开始学习之前我也建议你去clone我GitHub上面的TextProcessor工程[https://github.com/chaxiu/TextProcessor.git](https://github.com/chaxiu/TextProcessor.git)然后用IntelliJ打开并切换到 **start** 分支跟着课程一步步敲代码。
## 1.0版本:命令式风格
在正式开始写代码之前,我们先看看程序运行之后是什么样的,一起来分析一下整体的编程思路:
![图片](https://static001.geekbang.org/resource/image/57/66/5757bb50b199c4e3faafd8ba8791e866.gif?wh=2182x1362)
首先我们的词频统计程序是一个类“TextProcessorV1”这是第一个版本的类名称。text是需要被统计的一段测试文本。
所以,我们很容易就能写出这样的代码结构:
```plain
class TextProcessorV1 {
fun processText(text: String): List<WordFreq> {
}
}
data class WordFreq(val word: String, val frequency: Int)
```
这段代码中我们定义了一个方法processText它接收的参数类型是String返回值类型是List。与此同时我们还定义了一个数据类WordFreq它里面有两个属性分别是word和对应的频率frequency。
所以,这个程序最关键的逻辑都在 **processText** 这个方法当中。
接下来我们以一段简短的英语作为例子,看看整体的统计步骤是怎样的。我用一张图来表示:
![](https://static001.geekbang.org/resource/image/95/0c/950672a2d7629a47b313aa77636afd0c.jpg?wh=900x1212)
上面的流程图一共分为4个步骤
* 步骤1**文本清洗**。正常的英语文本当中是会有很多标点符号的,比如“.”“!”,而标点符号是不需要被统计进来的。所以,在进行词频统计之前,我们还需要对文本数据进行清洗。这里的做法是将标点符号替换成空格。
* 步骤2**文本分割**。有了步骤1作为基础我们的英语文本当中除了单词之外就都是空格了。所以为了分割出一个个单词我们只需要以空格作为分隔符对整个文本进行分割即可。在这个过程中我们的文本数据就会变成一个个单词组成的列表也就是**List类型**。
* 步骤3**统计单词频率**。在上个步骤中我们已经得到了单词组成的List但这个数据结构并不适合做频率统计。为了统计单词频率我们要借助Map这个数据结构。我们可以通过遍历List的方式将所有单词都统计一遍并将“单词”与“频率”以成对的方式存储在Map当中。
* 步骤4**词频排序**。在步骤3中我们得到的词频数据是无序的但实际场景中频率越高的单词越重要因此我们希望高频词可以放在前面低频词则放在后面。
经过以上分析我们就能进一步完善processText()方法当中的结构了。
```plain
class TextProcessorV1 {
fun processText(text: String): List<WordFreq> {
// 步骤1
val cleaned = clean(text)
// 步骤2
val words = cleaned.split(" ")
// 步骤3
val map = getWordCount(words)
// 步骤4
val list = sortByFrequency(map)
return list
}
}
```
其中步骤2的逻辑很简单我们直接使用Kotlin标准库提供的 **split()** 就可以实现空格分割。其余的几个步骤1、3、4则是由单独的函数来实现。所以下面我们就来分析下clean()、getWordCount()、sortByFrequency()这几个方法该如何实现。
### 文本清洗
首先是文本清洗的方法clean()方法。
经过分析,现在我们知道针对一段文本数据,我们需要将其中的标点符号替换成空格:
```plain
// 标点 标点
// 清洗前 ↓ ↓
"Kotlin is my favorite language. I love Kotlin!"
// 空格 空格
// 清洗后 ↓ ↓
"Kotlin is my favorite language I love Kotlin "
```
那么对于这样的逻辑,我们很容易就能写出以下代码:
```plain
fun clean(text: String): String {
return text.replace(".", " ")
.replace("!", " ")
.trim()
}
```
这样的代码对于前面这种简单文本是没问题的,但这样的方式存在几个明显的问题。
第一个问题是**普适性差**。在复杂的文本当中,标点符号的类型很多,比如“,”“?”等标点符号。为了应对这样的问题,我们不得不尝试去枚举所有的标点符号:
```plain
fun clean(text: String): String {
return text.replace(".", " ")
.replace("!", " ")
.replace(",", " ")
.replace("?", " ")
.replace("'", " ")
.replace("*", " ")
.replace("#", " ")
.replace("@", " ")
.trim()
}
```
那么随之而来的第二个问题,就是**很容易出错**,因为我们可能会遗漏枚举的标点符号。第三个问题则是**性能差**随着枚举情况的增加replace执行的次数也会增多。
因此这个时候,我们必须要换一种思路,[正则表达式](https://time.geekbang.org/column/intro/100053301)就是一个不错的选择:
```plain
fun clean(text: String): String {
return text.replace("[^A-Za-z]".toRegex(), " ")
.trim()
}
```
上面的正则表达式的含义就是,**将所有不是英文字母的字符都统一替换成空格**(为了不偏离主题,这里我们不去深究正则表达式的细节)。
这样数据清洗的功能完成以后我们就可以对文本进行切割了这个步骤通过split()就能实现。在经过分割以后我们就得到了单词的列表。接下来我们就需要进行词频统计getWordCount()了。
### 词频统计
在getWordCount()这个方法当中我们需要用到Map这个数据结构。如果你不了解这个数据结构也不必紧张我制作了一张动图描述getWordCount()的工作流程。
![图片](https://static001.geekbang.org/resource/image/43/46/43598fd9f2d476f9ffa717dba38cd846.gif?wh=720x405)
看过上面的Gif动图以后相信你对词频统计的实现流程已经心中有数了。其实它就是跟我们生活中做统计一样遇到一个单词就把这个单词的频率加一就行。只是我们生活中是用本子和笔来统计而这里我们用程序来做统计。
那么根据这个流程我们就可以写出以下这样的频率统计的代码了这里面主要用了一个Map来存储单词和它对应频率
```plain
fun getWordCount(list: List<String>): Map<String, Int> {
val map = hashMapOf<String, Int>()
for (word in list) {
// ①
if (word == "") continue
val trim = word.trim()
// ②
val count = map.getOrDefault(trim, 0)
map[trim] = count + 1
}
return map
}
```
上面的代码一共有两处需要注意,我们一个个看:
* 注释①,当我们将标点符号替换成空格以后,两个连续的空格进行分割后会出现空字符"",这是脏数据,我们需要将其过滤掉。
* 注释②map.getOrDefault是Map提供的一个方法如果当前map中没有对应的Key则返回一个默认值。这里我们设置的默认值为0方便后面的代码计数。
这样通过Map这个数据结构我们的词频统计就实现了。而因为Map是无序的所以我们还需要对统计结果进行排序。
### 词频排序
那么到这里我们就又要将无序的数据结构换成有序的。这里我们选择List因为List是有序的集合。但由于List每次只能存储单个元素为了同时存储“单词”与“频率”这两个数据我们需要用上前面定义的**数据类WordFreq**
```plain
fun sortByFrequency(map: Map<String, Int>): MutableList<WordFreq> {
val list = mutableListOf<WordFreq>()
for (entry in map) {
if (entry.key == "") continue
val freq = WordFreq(entry.key, entry.value)
// ①
list.add(freq)
}
// ②
list.sortByDescending {
it.frequency
}
return list
}
```
这部分的排序代码其实思路很简单:
* 注释①处我们将Map当中的词频数据封装到WordFreq数据类当中并且添加到了List当中这样就将所有的信息都放到了一个有序的集合当中来了
* 注释②处我们调用了Kotlin标准库提供的排序方法“sortByDescending”它代表了以词频降序排序。
到这里我们的1.0版本就算是完成了,按照惯例,我们可以写一个单元测试来看看代码运行结果是否符合预期。
![图片](https://static001.geekbang.org/resource/image/a4/yy/a4d2e9c146517e984bf17a6dfbc403yy.gif?wh=2182x1362)
由于我们的测试文本很简单我们一眼就能分析出正确的结果。其中单词“Kotlin”出现的频率最高是2次它会排在result的第一位。所以我们可以通过断言来编写以上的测试代码。最终单元测试的结果也显示我们的代码运行结果符合预期。
这时候,你也许会想:测试的文本数据太短了,**如果数据量再大一些,程序是否还能正常运行呢?**
其实,我们可以让程序支持统计文件当中的单词词频,要实现这个功能也非常简单,就是利用我们在[第6讲](https://time.geekbang.org/column/article/475684)学过的扩展方法:
```plain
fun processFile(file: File): List<WordFreq> {
val text = file.readText(Charsets.UTF_8)
return processText(text)
}
```
从代码中我们可以看到readText()就是Kotlin标准库里提供的一个扩展函数它可以让我们非常方便地从文件里读取文本。增加这样一行代码我们的程序就能够统计文件当中的单词频率了。
## 2.0版本:函数式风格
下面我们就一起来实现下第二个版本的词频统计程序。这里我想先带你回过头来看看咱们1.0版本当中的代码:
```plain
class TextProcessorV1 {
fun processText(text: String): List<WordFreq> {
val cleaned = clean(text)
val words = cleaned.split(" ")
val map = getWordCount(words)
val list = sortByFrequency(map)
return list
}
}
```
是不是觉得咱们的代码实在太整齐了甚至整齐得有点怪怪的而且我们定义的临时变量cleaned、words、map、list都只会被用到一次。
其实上面的代码就是很明显地在用Java思维写Kotlin代码。这种情况下我们甚至可以省略掉中间所有的临时变量将代码缩减成这样
```plain
fun processText(text: String): List<WordFreq> {
return sortByFrequency(getWordCount(clean(text).split(" ")))
}
```
不过,很明显的是,以上代码的可读性并不好。在[开篇词](https://time.geekbang.org/column/article/472129)当中我曾提到过Kotlin既有**命令式**的一面,也有**函数式**的一面,它们有着各自擅长的领域。而在这里,我们就完全可以借助[函数式编程](https://zh.wikipedia.org/zh/%E5%87%BD%E6%95%B0%E5%BC%8F%E7%BC%96%E7%A8%8B)的思想来优化代码,就像下面这样:
```plain
fun processText(text: String): List<WordFreq> {
return text
.clean()
.split(" ")
.getWordCount()
.sortByFrequency { WordFreq(it.key, it.value) }
}
```
可以发现这段代码从上读到下可读性非常高它也非常接近我们说话的习惯我们拿到参数text接着对它进行清洗clean(),然后对单词频率进行统计,最后根据词频进行排序。
那么我们要如何修改1.0版本的代码,才能实现这样的代码风格呢?**问题的关键还是在于clean()、getWordCount()、sortByFrequency()这几个方法。**
我们一个个来分析。首先是text.clean()为了让String能够直接调用clean()方法我们必须将clean()定义成**扩展函数**
```plain
// 原函数
fun clean(text: String): String {
return text.replace("[^A-Za-z]".toRegex(), " ")
.trim()
}
// 转换成扩展函数
fun String.clean(): String {
return this.replace("[^A-Za-z]".toRegex(), " ")
.trim()
}
```
从上面的代码中,我们可以清晰地看到普通函数转换为扩展函数之间的差异:
* 原本的参数类型String在转换成扩展函数后就变成了“接收者类型”
* 原本的参数text变成了扩展函数的this。
![图片](https://static001.geekbang.org/resource/image/d2/59/d27f98fe4234c10a14bd18c7770b8f59.gif?wh=720x405)
对应的我们的getWordCount()方法也同样可以修改成扩展函数的形式。
```plain
private fun List<String>.getWordCount(): Map<String, Int> {
val map = HashMap<String, Int>()
for (element in this) {
if (element == "") continue
val trim = element.trim()
val count = map.getOrDefault(trim, 0)
map[trim] = count + 1
}
return map
}
```
你能看到原本是作为参数的List现在同样变成了接收者类型原本的参数list集合变成了this。
最后是sortByFrequency(),我们很容易就能写出类似下面的代码:
```plain
private fun Map<String, Int>.sortByFrequency(): MutableList<WordFreq> {
val list = mutableListOf<WordFreq>()
for (entry in this) {
val freq = WordFreq(entry.key, entry.value)
list.add(freq)
}
list.sortByDescending {
it.frequency
}
return list
}
```
同样的步骤将参数类型变成“接收者类型”将参数变成this。不过这里的做法并不符合函数式编程的习惯因为这个方法明显包含两个功能
* 功能1将Map转换成List
* 功能2使用sort对List进行排序。
因此针对这样的情况,我们应该再对这个方法进行拆分:
```plain
private fun <T> Map<String, Int>.mapToList(transform: (Map.Entry<String, Int>) -> T): MutableList<T> {
val list = mutableListOf<T>()
for (entry in this) {
val freq = transform(entry)
list.add(freq)
}
return list
}
```
在上面的代码当中为了让Map到List的转换更加得灵活我们引入了高阶函数它的参数transform是函数类型的参数。那么相应的我们的调用处代码也需要做出改变也就是传入一个Lambda表达式
```plain
fun processText(text: String): List<WordFreq> {
return text
.clean()
.split(" ")
.getWordCount()
.mapToList { WordFreq(it.key, it.value) }
.sortedByDescending { it.frequency }
}
```
看着上面的代码我们几乎可以像读普通的英语文本一般地阅读上面的代码首先是对text进行清理然后使用split以空格形式进行分割接着计算出单词的频率然后再将无序的Map转换成List最后对List进行排序排序的依据就是词频降序。
至此我们的2.0版本就算完成了。让我们再次执行一次单元测试,看看我们的代码逻辑是否正确:
![图片](https://static001.geekbang.org/resource/image/7c/y3/7cb66e38089f63b82a136316233a3yy3.gif?wh=2182x1362)
单元测试的结果告诉我们代码运行结果符合预期。接下来我们就可以进行3.0版本的开发工作了。
## 3.0版本inline优化
在上一个版本当中我们的mapToList被改造成了一个高阶函数。那到了这个版本我们实际的代码量其实很少只需要为mapToList这个高阶函数增加一个inline关键字即可。
```plain
// 增加inline关键字
// ↓
private inline fun <T> Map<String, Int>.mapToList(transform: (Map.Entry<String, Int>) -> T): MutableList<T> {
val list = mutableListOf<T>()
for (entry in this) {
val freq = transform(entry)
list.add(freq)
}
return list
}
```
到这里我们3.0版本的开发工作其实就完成了。
但是你要清楚虽然我们只花几秒钟就能增加这个inline关键字可我们这么做的原因却比较复杂。这涉及到 **inline关键字的实现原理**
不过在正式研究inline之前我们要先来了解下高阶函数的实现原理。由于Kotlin兼容Java 1.6因此JVM是不懂什么是高阶函数的我们的高阶函数最终一定会被编译器转换成JVM能够理解的格式。
而又因为,我们的词频统计代码略微有些复杂,所以为了更好地研究高阶函数的原理,这里我们可以先写一个简单的高阶函数,然后看看它反编译后的代码长什么样。
```plain
// HigherOrderExample.kt
fun foo(block: () -> Unit) {
block()
}
fun main() {
var i = 0
foo{
i++
}
}
```
以上代码经过反编译成Java后会变成这样
```java
public final class HigherOrderExampleKt {
public static final void foo(Function0 block) {
block.invoke();
}
public static final void main() {
int i = 0
foo((Function0)(new Function0() {
public final void invoke() {
i++;
}
}));
}
}
```
可以看到Kotlin高阶函数当中的函数类型参数变成了Function0而main()函数当中的高阶函数调用也变成了“匿名内部类”的调用方式。那么Function0又是个什么东西
```plain
public interface Function0<out R> : Function<R> {
public operator fun invoke(): R
}
```
Function0其实是Kotlin标准库当中定义的接口它代表没有参数的函数类型。在[Functions.kt](https://github.com/JetBrains/kotlin/blob/master/libraries/stdlib/jvm/runtime/kotlin/jvm/functions/Functions.kt)这个文件当中Kotlin一共定义了23个类似的接口从Function0一直到Function22分别代表了“无参数的函数类型”到“22个参数的函数类型”。
现在我们已经知道Kotlin高阶函数是如何实现的了接下来我们看看使用inline优化过的高阶函数会是什么样的
```plain
// HigherOrderInlineExample.kt
/*
多了一个关键字
↓ */
inline fun fooInline(block: () -> Unit) {
block()
}
fun main() {
var i = 0
fooInline{
i++
}
}
```
和前面的例子唯一的不同点在于我们在foo()函数的定义处增加了一个inline关键字同时为了区分我们也改了一下函数的名称。这个时候我们再来看看它反编译后的Java长什么样
```java
public final class HigherOrderInlineExampleKt {
// 没有变化
public static final void fooInline(Function0 block) {
block.invoke();
}
public static final void main() {
// 差别在这里
int i = 0;
int i = i + 1;
}
}
```
为了看得更加清晰我们将有无inline的main()放到一起来对比下:
![图片](https://static001.geekbang.org/resource/image/de/c8/de4c7c3ee9b93c60ca93ab4074db78c8.png?wh=1920x1080)
所以你能发现,**inline的作用其实就是将inline函数当中的代码拷贝到调用处。**
而是否使用inlinemain()函数会有以下两个区别:
* 在不使用inline的情况下我们的main()方法当中需要调用foo()这个函数,这里多了一次函数调用的开销。
* 在不使用inline的情况下调用foo()函数时还创建了“Function0”的匿名内部类对象这也是额外的开销。
为了验证这一猜测,我们可以使用[JMH](https://github.com/openjdk/jmh)Java Microbenchmark Harness对这两组代码进行性能测试。JMH这个框架可以最大程度地排除外界因素的干扰比如内存抖动、虚拟机预热从而判断出我们这两组代码执行效率的差异。它的结果不一定非常精确但足以说明一些问题。
不过为了不偏离本节课的主题在这里我们不去深究JMH的使用技巧而是只以两组测试代码为例来探究下inline到底能为我们带来多少性能上的提升
```plain
// 不用inline的高阶函数
fun foo(block: () -> Unit) {
block()
}
// 使用inline的高阶函数
inline fun fooInline(block: () -> Unit) {
block()
}
// 测试无inline的代码
@Benchmark
fun testNonInlined() {
var i = 0
foo {
i++
}
}
// 测试无inline的代码
@Benchmark
fun testInlined() {
var i = 0
fooInline {
i++
}
}
```
最终的测试结果如下,分数越高性能越好:
```plain
Benchmark Mode Score Error Units
testInlined thrpt 3272062.466 ± 67403.033 ops/ms
testNonInlined thrpt 355450.945 ± 12647.220 ops/ms
```
从上面的测试结果我们能看出来是否使用inline它们之间的效率几乎相差10倍。而这还仅仅只是最简单的情况如果在一些复杂的代码场景下多个高阶函数嵌套执行它们之间的执行效率会相差上百倍。
为了模拟复杂的代码结构我们可以简单地将这两个函数分别嵌套10个层级然后看看它们之间的性能差异
```plain
// 模拟复杂的代码结构,这是错误示范,请不要在其他地方写这样的代码。
@Benchmark
fun testNonInlined() {
var i = 0
foo {
foo {
foo {
foo {
foo {
foo {
foo {
foo {
foo {
foo {
i++
}
}
}
}
}
}
}
}
}
}
}
@Benchmark
fun testInlined() {
var i = 0
fooInline {
fooInline {
fooInline {
fooInline {
fooInline {
fooInline {
fooInline {
fooInline {
fooInline {
fooInline {
i++
}
}
}
}
}
}
}
}
}
}
}
```
**注意:以上的代码仅仅只是为了做测试,请不要在其他地方写类似这样的代码。**
```plain
Benchmark Mode Score Error Units
testInlined thrpt 3266143.092 ± 85861.453 ops/ms
testNonInlined thrpt 31404.262 ± 804.615 ops/ms
```
从上面的性能测试数据我们可以看到在嵌套了10个层级以后我们testInlined的性能几乎没有什么变化而当testNonInlined嵌套了10层以后性能也比1层嵌套差了10倍。
在这种情况下testInlined()与testNonInlined()之间的性能差异就达到了100倍那么随着代码复杂度的进一步上升它们之间的性能差异会更大。
我在下面这张Gif动图里展示了它们反编译成Java的代码
![](https://static001.geekbang.org/resource/image/f7/a1/f7b342a7ecf56c100ec6b2bb488yyaa1.gif?wh=480x253)
我们能看到对于testNonInlined()由于foo()嵌套了10层它反编译后的代码也嵌套了10层函数调用中间还伴随了10次匿名内部类的创建。而testInlined()则只有简单的两行代码完全没有任何嵌套的痕迹。难怪它们之间的性能相差100倍
### inline的局限性
看到这,你也许会有这样的想法:**既然inline这么神奇那我们是不是可以将“词频统计程序”里的所有函数都用inline来修饰**
答案当然是**否定**的。事实上Kotlin官方只建议我们将inline用于**修饰高阶函数**。对于普通的Kotlin函数如果我们用inline去修饰它IntelliJ会对我们发出警告。而且也不是所有高阶函数都可以用inline它在使用上有一些局限性。
举个例子如果我们在processText()的前面增加inline关键字IntelliJ会提示一个警告
![图片](https://static001.geekbang.org/resource/image/ba/ff/ba3175a460470887c852cfd14778f0ff.png?wh=1624x672)
这个警告的意思是“对于普通的函数inline带来的性能提升并不显著inline用在高阶函数上的时候才会有显著的性能提升”。
另外在processText()方法的内部getWordCount()和mapToList()这两个方法还会报错:
![图片](https://static001.geekbang.org/resource/image/31/4c/3113667bb87e2fe9929a704a0a14a24c.png?wh=1708x736)
出现这个报错的原因是getWordCount()和mapToList()这两个函数是私有的无法inline。为什么呢
前面我们提到过:**inline的作用其实就是将inline函数当中的代码拷贝到调用处。**由于processText()是公开的因此它会从外部被调用这意味着它的代码会被拷贝到外部去执行而getWordCount()和mapToList()这两个函数却无法在外部被访问。这就是导致编译器报错的原因。
所以inline虽然可以为我们带来极大的性能提升但我们不能滥用。在使用inline的时候我们还需要时刻注意它的实现机制有时候稍有不慎就会引发问题。
除此之外在第3讲中我们曾提到Kotlin编译器一直在幕后帮忙做着翻译的好事那它有没有可能“好心办坏事”
这个问题,现在我们就能够回答了:**Kotlin编译器是有可能好心办坏事的。如果我们不够了解Kotlin的底层细节不够了解Kotlin的语法实现原理我们就可能会用错某些Kotlin语法比如inline当我们用错这些语法后Kotlin在背后做的这些好事就可能变成一件坏事。**
## 小结
最后,让我们来做个简单的总结。
* 通过1.0版本的开发,我们初步实现了单词频率统计的功能,同时也使用了面向对象的思想,也使用了单元测试;
* 在2.0版本的开发中,我们初步尝试了函数式编程的风格,在这个过程中,我们灵活运用了我们前面学习的扩展、高阶函数知识。
* 在3.0版本中我们使用inline优化了高阶函数。随后我们着重研究了高阶函数的原理以及inline背后的细节。在这个过程中我们发现inline可以为高阶函数带来超过100倍的性能提升同时我们也了解到inline并不是万能的它也存在一定的局限性。
经过这节课的实战演练之后相信你一定感受到了Kotlin函数式风格的魅力。在日后不断地学习、实操中我也希望你可以把Kotlin函数式的代码应用到自己的开发工作当中并且充分发挥出Kotlin简洁、优雅、可读性强的优势。
## 思考题
咱们的词频统计程序其实还有很多可以优化和提升的地方,请问你能想到哪些改进之处?欢迎你在评论区分享你的思路,我们下节课再见。