io.github.dddplus.runtime

类 BaseRouter<Ext extends IDomainExtension,Identity extends IIdentity>

java.lang.Object

io.github.dddplus.runtime.BaseRouter<Ext,Identity>

类型参数:

Ext - 扩展点

Identity - 业务身份

所有已实现的接口:

IDomainService

直接已知子类:

BaseDecideStepsRouter

public abstract class BaseRouter<Ext extends IDomainExtension,Identity extends IIdentity>
extends Object
implements IDomainService

扩展点路由器的基础抽象类.

BaseRouter是最小粒度的IDomainService，只负责一个扩展点的编排

构造器概要

构造器

构造器和说明
BaseRouter()

方法概要

限定符和类型	方法和说明
abstract Ext	defaultExtension(Identity identity) 默认扩展点实现.
protected Ext	firstExtension(Identity identity) 找到第一个符合条件的扩展点实例.
protected Ext	firstExtension(Identity identity, int timeoutInMs) 找到第一个符合条件的扩展点实例，并指定扩展点最大执行时长，超时抛出TimeoutException.
protected Ext	forEachExtension(Identity identity) 不关心扩展点返回值，逐一执行所有符合业务身份的扩展点.
protected <R> Ext	forEachExtension(Identity identity, @NonNull IReducer<R> reducer) 遍历满足条件的所有扩展点实例.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

BaseRouter

public BaseRouter()

方法详细资料

forEachExtension

protected Ext forEachExtension(@NonNull
                               Identity identity)

不关心扩展点返回值，逐一执行所有符合业务身份的扩展点.

参数:

identity - 业务身份

返回:

扩展点，返回的是扩展点动态代理类，保证非null

forEachExtension

protected <R> Ext forEachExtension(@NonNull
                                   Identity identity,
                                   @NonNull
                                   @NonNull IReducer<R> reducer)

遍历满足条件的所有扩展点实例.

通过IReducer控制何时退出遍历.

类型参数:

R - 扩展点方法的返回值类型

参数:

identity - 业务身份

reducer - 收敛逻辑

返回:

扩展点，返回的是扩展点动态代理类，保证非null

firstExtension

protected Ext firstExtension(@NonNull
                             Identity identity)

找到第一个符合条件的扩展点实例.

这表示：扩展点实例之间是互斥的，无法叠加的

如果需要根据扩展点执行结果来找第一个匹配的扩展点实例，请使用#forEachExtension(Identity, IReducer)

参数:

identity - 业务身份

返回:

扩展点，返回的是扩展点动态代理类，保证非null

firstExtension

protected Ext firstExtension(@NonNull
                             Identity identity,
                             int timeoutInMs)

找到第一个符合条件的扩展点实例，并指定扩展点最大执行时长，超时抛出TimeoutException.

这表示：扩展点实例之间是互斥的，无法叠加的

如果需要根据扩展点执行结果来找第一个匹配的扩展点实例，请使用#forEachExtension(Identity, IReducer)

参数:

identity - 业务身份

timeoutInMs - 执行扩展点的超时时间，in ms；如果超时，会强行终止扩展点的执行

返回:

扩展点，返回的是扩展点动态代理类，保证非null

defaultExtension

public abstract Ext defaultExtension(@NonNull
                                     Identity identity)

默认扩展点实现.

运行时，只有没有找到任何1个扩展点实现时，才会执行默认扩展点实现

参数:

identity - 业务身份

返回:

如果为null，而且触发了默认扩展点执行，扩展点方法永远返回null。这要求我们：扩展点方法的返回值不能是int/boolean等，否则会抛出NPE!