如何使用Kleisli实现缓存

Yan*_*san 5 functional-programming scala scalaz kleisli

我遵循了功能和反应建模一书中的设计原则.

所以所有的服务方法都返回Kleisli.

问题是如何在这些服务上添加可更新缓存.

这是我目前的实现,有更好的方法(现有组合器,更多功能方法,......)?

import scala.concurrent.duration.Duration
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.{Await, Future}
import scalaz.Kleisli

trait Repository {
  def all : Future[Seq[String]]
  def replaceAll(l: Seq[String]) : Future[Unit]
}

trait Service {
  def all = Kleisli[Future, Repository, Seq[String]] { _.all }
  def replaceAll(l: Seq[String]) = Kleisli[Future, Repository, Unit] { _.replaceAll(l) }
}

trait CacheService extends Service {
  var cache : Seq[String] = Seq.empty[String]

  override def all = Kleisli[Future, Repository, Seq[String]] { repo: Repository =>
    if (cache.isEmpty) {
      val fcache = repo.all
      fcache.foreach(cache = _)
      fcache
    }
      else
      Future.successful(cache)
  }

  override def replaceAll(l: Seq[String]) = Kleisli[Future, Repository, Unit] { repo: Repository =>
    cache = l
    repo.replaceAll(l)
  }
}

object CacheTest extends App {
  val repo = new Repository {
    override def replaceAll(l: Seq[String]): Future[Unit] = Future.successful()
    override def all: Future[Seq[String]] = Future.successful(Seq("1","2","3"))
  }
  val service = new CacheService {}

  println(Await.result(service.all(repo), Duration.Inf))
  Await.result(service.replaceAll(List("a"))(repo), Duration.Inf)
  println(Await.result(service.all(repo), Duration.Inf))
}
Run Code Online (Sandbox Code Playgroud)

[更新]关于@timotyperigo的评论,我在存储库级别实现了缓存

class CachedTipRepository(val self:TipRepository) extends TipRepository {
  var cache: Seq[Tip] = Seq.empty[Tip]

  override def all: Future[Seq[Tip]] = …

  override def replace(tips: String): Unit = …
}
Run Code Online (Sandbox Code Playgroud)

我仍然对改进设计的反馈感兴趣.

Edm*_*984 1

Timothy 是完全正确的:缓存是存储库(而不是服务)的实现功能。实施功能/细节不应在合同中公开,此时您的设计做得很好(但不是您的实施!)

深入挖掘你的设计问题,看看如何 在 Scala 中完成依赖注入是很有趣的:

  1. 构造函数注入
  2. 蛋糕图案
  3. 读者单子

蛋糕模式和构造函数注入有一个相似之处:依赖关系在创建时绑定。使用 Reader monad(Kleisli 只是在其之上提供了一个附加层),您可以延迟绑定,从而获得更多的可组合性(由于组合器)、更多的可测试性和更大的灵活性

如果通过TipRepository添加缓存功能来装饰现有的代码,则可能不需要 Kleisli 的好处,它们甚至可能使代码更难以阅读。使用构造函数注入似乎很合适,因为它是让您“做得好”的最简单的模式