squbs-14. Actor注册表

2017-01-30 本文已影响34人吕亦行

actor注册表

概览

actor注册表提供了squbs应用一个简单的方式发送/接收消息至squbs well-known actor，尤其在跨cube方面。它提供了一个附加的抽象层来跨cube，在不需要了解其他actor太多的情况下，允许actor发现其他actor。actor注册表同时扮演一个蒙面来管理访问控制、安全、跨模块超时甚至模拟外部actor的non-actor系统。

概念

Well-known actor是通过 squbs-meta.conf定义注册的actor，在Unicomplex & Cube Bootstrapping有描述
*ActorLookup API（Scala）和 japi.ActorLookup API（Java）用在发送接收消息至well-known actor
ActorRegistry是通用的门面actor来保持所有的well-known actor的信息。

Well-Known Actor

Squbs well-known actor定义在Unicomplex & Cube Bootstrapping文档中的 META-INF/squbs-meta.conf 配置文件中的squbs-actors部分。actor 注册表扩展诸恶并提供更多关于消息元数据类型，这个消息可能消费和返回：

class-name: actor的类名
name: 已注册的actor的名称
message-class: 请求/响应消息类型

通过扩展类型信息注册的例子：

cube-name = org.squbs.TestCube
cube-version = "0.0.5"
squbs-actors = [
    {
      class-name = org.squbs.testcube.TestActor
      name = TestActor
      message-class = [
        {
          request = org.squbs.testcube.TestRequest
          response= org.squbs.testcube.TestResponse
        }
        {
          request = org.squbs.testcube.TestRequest1
          response= org.squbs.testcube.TestResponse1
        }
      ]
    }
]

Scala API & Samples

发送消息 (!/?/tell/ask)至注册消息类型为"TestRequest"的actor

implicit val refFactory : ActorRefFactory = ...
ActorLookup ! TestRequest(...)

发送消息至注册请求类型为 "TestRequest"的actor，并且返回类型为"TestResponse"。
```
implicit val refFactory : ActorRefFactory = ...
ActorLookup[TestResponse] ! TestRequest(...)
```
发送消息 (!/?/tell/ask)至注册名为"TestActor"的actor，并且请求消息类型为"TestRequest"
```
implicit val refFactory : ActorRefFactory = ...
ActorLookup("TestActor") ! TestRequest(...)
```
发送消息(!/?/tell/ask)至注册名为 "TestActor"，请求类型为"TestRequest"，响应类型为"TestResponse"的消息
```
implicit val refFactory : ActorRefFactory = ...
ActorLookup[TestResponse]("TestActor") ! TestRequest(...)  
```

处理注册请求消息类型为"TestResponse"的actorRef

implicit val refFactory : ActorRefFactory = ...
implicit val timeout : Timeout = ...
ActorLookup[TestResponse].resolveOne

处理注册请求消息名为"TestActor"，响应类型为"TestResponse"的actorRef

implicit val refFactory : ActorRefFactory = ...
implicit val timeout : Timeout = ...
ActorLookup[TestReponse]("TestActor").resolveOne

处理注册请求消息名为"TestActor"，请求类型为"TestResponse"的TestRequest

implicit val refFactory : ActorRefFactory = ...
implicit val timeout : Timeout = ...
val al= new ActorLookup(requestClass=Some(classOf[TestRequest]))
al.resolveOne

Java API和例子

创建你的ActorLookup

// Pass in context() from and Actor or the ActorSystem

private ActorLookup<?> lookup = ActorLookup.create(context());

发送消息（tell/ask）至请求类型为"TestRequest"的actor
```
lookup.tell(new TestRequest(...), self());
```
发送消息 (tell/ask) 至请求类型为"TestRequest"的消息，类型为"TestResponse"的响应消息的actor。
```
lookup.lookup(TestResponse.class).tell(new TestRequest(...), self())
```
发送消息 (tell/ask) 至注册名为"TestActor"的actor，请求消息类型为"TestRequest"
```
lookup.lookup("TestActor").tell(new TestRequest(...), self())
```
发送消息 (tell/ask) 至注册名为"TestActor"的actor，请求消息类型为"TestRequest"，响应消息类型为"TestResponse"
```
lookup.lookup("TestActor", TestResponse.class).tell(new TestRequest(...), self())
```

处理响应类型为"TestResponse"的actorRef

lookup.lookup(TestResponse.class).resolveOne(timeout)

处理名称为"TestActor" 的actorRef

lookup.lookup("TestActor").resolveOne(timeout)

处理名称为"TestActor" 的actorRef ，且响应类型为"TestReponse"
```
lookup.lookup("TestActor", TestResponse.class).resolveOne(timeout)
```
处理名称为"TestActor" 的actorRef ，且请求消息类型为"TestRequest" 。这使用optional字段类型 Optional<T>全查找标记。所以名称和请求类需要包裹为Optional 或传递 Optional.empty() 如果不是查询额一部分。响应请求类型始终需要。如果接受任意类型，设置响应类型设置 Object.class使得任何继承于java.lang.Object的子类是有效的。
```
lookup.lookup(Optional.of("TestActor"), Optional.of(TestRequest.class), Object.class)
```

响应类型

actor的响应类型被ActorLookup发现，响应类型发现保持跨结果lookup（当响应类型提供时）。编程响应类型在 tell或 !不太重要，然而他在ask 或 ?很重要。 ask的返回类型通常是Future[Any]（Scala）或Future<Object> （Java）。然而在查找时，基于ActorLookup上的ask 或?的返回类型提供响应类型。所以，你将获得 Future[T] 或 Future<T>如果你通过响应类型T查找，可以在下面的演示中展现。不需要更多的映射：

Scala

// In this example, we show full type annotation. The Scala compiler is able
// to infer the type if you just pass one side, i.e. the type parameter at
// ActorLookup, or the type annotation on the val f declaration.

val f: Future[TestResponse] = ActorLookup[TestResponse] ? TestRequest(...)

Java

Future<TestResponse> f = lookup.lookup(TestResponse.class).ask(new TestRequest(...), timeout)

错误处理

不像actorSelection会发送消息至死信，如果我们想要的actor不在系统中或者未注册，ActorLookup会返回ActorNotFound响应。

Monitoring

每个well-known actor创建了 JMX Bean。它名叫org.squbs.unicomplex:type=ActorRegistry,name=${actorPath}

依赖

使用actor注册表，添加以下的依赖至你的build.sbt或scala构建文件

"org.squbs" %% "squbs-actorregistry" % squbsVersion