squbs-23. 资源解决方案

原文地址:Resource Resolution

鉴于很少-如果存在-真实的生活应用可以不依赖外部资源工作,环境识别资源解决方案成为应用基础设施的一个关键部分。squbs通过ResolverRegistry提供资源解决方案,并允许任何类型的资源通过名称解决,环境指的是在开发环境、测试环境、研发环境下使用不同的资源。

依赖

这个解析器在 squbs-ext。在你的build.sbt或scala构建文件中加入以下依赖:

"org.squbs" %% "squbs-ext" % squbsVersion

用法

Resolver的基础用法来发现资源。类型由注册表生产,可以拥有多种类型的资源。在我们的例子中,我们使用 URI类型在本篇文档中。查找调用如下所示:

Scala
//在指定的环境下处理资源
val resource: Option[URI] = ResolverRegistry(system).resolve[URI]("myservice", QA)

Java
//在指定的环境下处理资源
val resource: Optional<URI> = ResolverRegistry.get(system).resolve(URI.class, "myservice", QA.value());

ResolverRegistry

ResolverRegistry是一个Akka的扩展,并在Scala和Java中遵循Akka扩展使用模式。它可以托管各种类型的资源解释器,因此通过将它传递给register调用在注册时提供资源类型。同类型或不同类型的多个解释器可以被注册。

发现链

资源发现遵循后进后出模型。最近注册的解释器优先于先前注册的。ResolverRegistry逐一走链直到有一个解释器兼容该类型并生产资源,或者将链走完。在那种情况下,这个注册表将返回None在Scala API中,在Java API中返回Optional.empty()

类型兼容

在调用 resolve 时, ResolverRegistry 检查请求类型。如果这个注册的解释器的类型与请求类型是同类型或自类型,这个解释器(resolver )将被用于尝试通过名称解释该资源。

由于JVM类型擦除,注册类型参数或请求类型不计算在内。举个例子,一个注册类型 java.util.ArrayList<String>可能被resolve调用匹配上java.util.List<Int>,因为StringInt 类型在运行时被擦除了。因为这个限制,使用参数类型来注册和查找通常不建议使用。结果是未定义的-你可能获得一个错误的资源。

简单的来说,这里不建议使用类型的层次结构。所有注册的类型应该是唯一类型。

注册解释器

这里有两套解释器注册的API风格。一个是一个快捷的API通过传递一个闭包/lambda作为解释器。这个闭包 /lambda返回 Option[T]类型在Scala中,Optional<T>在Java中。另一个,完全的API使用 Resolver[T]在Scala中,AbstractResolver<T>在Java中。T为资源类型。参见如下:

Scala
// To register a new resolver for type URI using a closure. Note the return
// type of the closure must be `Option[T]` or in this case `Option[URI]`
ResolverRegistry(system).register[URI]("MyResolver") { (svc, env) =>
  (svc, env) match {
    case ("myservice", QA) => Some(URI.create("http://myservice.qa.mydomain.com"))
    case ("myservice", Default) => Some(URI.create("http://myservice.mydomain.com"))
    case ("myservice2", QA) => Some(URI.create("http://myservice2.qa.mydomain.com"))
    case ("myservice2", Default) => Some(URI.create("http://myservice2.mydomain.com"))
    case _ => None
  }
}

// To register a new resolver for type URI by extending the `Resolver` trait
class MyResolver extends Resolver[URI] {
  def name: String = "MyResolver"
  
  def resolve(svc: String, env: Environment = Default): Option[URI] = {
    (svc, env) match {
      case ("myservice", QA) => Some(URI.create("http://myservice.qa.mydomain.com"))
      case ("myservice", Default) => Some(URI.create("http://myservice.mydomain.com"))
      case ("myservice2", QA) => Some(URI.create("http://myservice2.qa.mydomain.com"))
      case ("myservice2", Default) => Some(URI.create("http://myservice2.mydomain.com"))
      case _ => None
    }
  }
}

//然后只需要注册解释器
ResolverRegistry(system).register[URI](new MyResolver)
Java
// To register a new resolver for type URI using a lambda. Note the return
// type of the lambda must be `Optional<T>` or in this case `Optional<URI>`
ResolverRegistry.get(system).register("MyResolver", (svc, env) -> {
    if ("myservice".equals(svc)) {
        if (QA.value().equals(env)) {
          return Optional.of(URI.create("http://myservice.qa.mydomain.com"));
        } else {
          return Optional.of(URI.create("http://myservice.mydomain.com"));
        }
    } else if ("myservice2".equals(svc)) {
        if (QA.value().equals(env)) {
          return Optional.of(URI.create("http://myservice2.qa.mydomain.com"));
        } else {
          return Optional.of(URI.create("http://myservice2.mydomain.com"));
        }    
    } else {
        return Optional.empty();
    }
});

// To register a new resolver for type URI by extending an abstract class
public class MyResolver extends AbstractResolver<URI> {
    @Override
    public String name() {
        return "MyResolver";
    }
    
    @Override
    public Optional<URI> resolve(String svc, Environment env) {
        if ("myservice".equals(svc)) {
            if (QA.value().equals(env)) {
                return Optional.of(URI.create("http://myservice.qa.mydomain.com"));
            } else {
                return Optional.of(URI.create("http://myservice.mydomain.com"));
            }
        } else if ("myservice2".equals(svc)) {
            if (QA.value().equals(env)) {
                return Optional.of(URI.create("http://myservice2.qa.mydomain.com"));
            } else {
                return Optional.of(URI.create("http://myservice2.mydomain.com"));
            }    
        } else {
            return Optional.empty();
        }
    }
}

// Then register MyResolver.
ResolverRegistry.get(system).register(URI.class, new MyResolver());

解释资源(Resolving for a Resource)

类似于注册,解决方案需要一个类型兼容注册类型;注册类型必须相同或为解决类型的子类。

Scala
// To resolve a resource with `Default` environment.
val resource: Option[URI] = ResolverRegistry(system).resolve[URI]("myservice")

// To resolve a resource for a specific environment.
val resource: Option[URI] = ResolverRegistry(system).resolve[URI]("myservice", QA)
Java
val resource: Optional<URI> = ResolverRegistry.get(system).resolve(URI.class, "myservice", QA.value());

取消注册解析器

取消注册解析器通过名称使用以下API完成

Scala
ResolverRegistry(system).unregister("MyResolver")
Java
ResolverRegistry.get(system).unregister("MyResolver");

并发考虑

注册解析器和取消注册解析器以非并发方式完成,在初始化时间。这里没有对并发注册进行保护,因此并发注册的结果是未定义的。你的解释器可能,亦或是不可能在一个并发注册解析器上注册或取消注册。

然而,在ResolverRegistry级别上,Resolve调用是线程安全的并且可以无限次的并发访问。每个注册解释器需要线程安全。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,684评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,143评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,214评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,788评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,796评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,665评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,027评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,679评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 41,346评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,664评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,766评论 1 331
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,412评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,015评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,974评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,073评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,501评论 2 343

推荐阅读更多精彩内容