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是什么這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！