Kestrel.scala中的PersistentQueue是什么

这篇文章主要讲解了“Kestrel.scala中的PersistentQueue是什么”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“Kestrel.scala中的PersistentQueue是什么”吧！

继续走读QueueCollection.scala的代码，因为后面封装的大量方法，都是对queues和fanout_queues的操作，根据定义，这两个变量都是mutable.HashMap[String, XXXX]类型的，所以我们先介绍一下mutable.HashMap的几个在Java中陌生的方法：( scala 的 apidoc 在 http://www.scala-lang.org/docu/files/api/index.html 可以查到）

◆apply (key : A) : B

◆Retrieve the value which is associated with the given key. This method throws an exception if there is no mapping from the given key to a value.

◆get (key : A) : Option[B]

◆Check if this map maps key to a value and return the value if it exists.

◆getOrElse [B2 >: B](key : A, default : => B2) : B2

◆Check if this map maps key to a value. Return that value if it exists, otherwise return default.

◆getOrElseUpdate (key : A, default : => B) : B

◆Check if this map maps key to a value. Return that value if it exists, otherwise put default as that key’s value and return it.

我们发现get和apply在Scala中，是完全相同的功能，但是在get返回值里面的Option究竟是什么意思呢？这个问题从刚开始阅读Scala代码的时候就已经困惑我们很久了。其实查询一下Scala的手册，我们不难发现，这是一个对于NULL的改造，因为在Java里面，有些是面向对象的变量，而有些不是，如果需要在Scala的语言内，保证所有对空的判断是一致的，那么就需要做一点什么。所以Scala设计了Option这个抽象类，以及两个子类Some和None。Option的实例，要么是Some类型，要么是None类型。所以把Option[类型]作为参数传递，也就是把这种类型的空值一并处理了，如果不存在，返回的是None[类型]，不需要象apply一样抛出一个异常。

让我们重新读下面这段代码：

private[kestrel] def queue(name: String): Option[PersistentQueue] = synchronized {      ……        Some(queues.get(name) getOrElse {          // only happens when creating a queue for the first time.          val q = if (name contains '+') {            val master = name.split('+')(0)            fanout_queues.getOrElseUpdate(master, new mutable.HashSet[String]) += name            log.info("Fanout queue %s added to %s", name, master)            new PersistentQueue(path.getPath, name, queueConfigs.configMap(master))          } else {            new PersistentQueue(path.getPath, name, queueConfigs.configMap(name))          }          q.setup          queues(name) = q          q        })    ……    }

先不要晕，根据之前对Option的理解，我们知道这是一个被Option封装了的PersistentQueue类。我们也知道了所有的Scala方法都不需要return，***一条执行命令的返回值就是这个方法的返回值，所以，在这里，Some(……)就是整个方法的返回值，很高兴，因为方法对返回值的定义是PersistentQueue，所以我们知道Some括号里面的一定也是PersistentQueue。

Some(queues.get(name) ……)，很好，因为queues的定义是mutable.HashMap[String, PersistentQueue]，所以get返回的就是Option[PersistentQueue]。这个方法貌似已经写完了，后面的到底是在做什么呢？getOrElse，按照定义，就是如果值不存在，那么就做后面{}里面的事情，这样的写法，其实就是对空值的处理。用QueueCollection角度来看，就是当查询queues的时候，这个队列如果不存在，那么就做{}里面的处理，创建一个队列。这里需要注意的是——这个getOrElse不是HashMap的getOrElse，而是Option的getOrElse。

然后读起来就比较顺利了，创建一个q，是PersistentQueue类型的，把它赋值给queues(name)中，加入HashMap表中。***不要忘记把q作为整个函数的返回，也就是Some()的返回。和get(name)存在的时候一样。

有了queue这个函数作为基础，后面读起来就容易很多了，我们就重点介绍一下match和case的用法，在add方法里面有这么一段代码：

queue(key) match {    case None => false   case Some(q) =>      ……      val result = q.add(item, normalizedExpiry)      if (result) totalAdded.incr()      result  }

之前我们知道 queue(key)返回的是Option[PersistentQueue]，match就是做匹配，根据不同的匹配来执行不同的操作，None，如果这个queue没有查询到，那么就返回false。Some(q)，如果queue返回的是一个Some类型，也就是Option有值的时候的返回，那么这个q就是返回的PersistentQueue类型的那个实例！就像函数的参数一样，可以直接使用。

很惊奇吧，刚接触Scala的时候，我几乎无法相信case可以这样做判断。后来我们发现，之所以能够做这种判断，是因为所有的Scala都是被类封装的，并且基于Scala的基类，实现了一个所谓的case class和case object的抽象类，并且实现了基于类的统一的==操作符。这一连串的改变造就了异常强大的Scala的case语法。

感谢各位的阅读，以上就是“Kestrel.scala中的PersistentQueue是什么”的内容了，经过本文的学习后，相信大家对Kestrel.scala中的PersistentQueue是什么这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是亿速云，小编将为大家推送更多相关知识点的文章，欢迎关注！