Question

我正在寻找一个 Java 模式, 用来进行嵌套式的无阻截方法呼叫。在我的例子中, 某些客户代码需要不同步地援引一个服务来进行某种使用案例, 而该使用案例的每一个步骤本身都必须不同步地进行( 原因不属于本问题范围 ) 。想象一下我现有的接口如下:

public interface Request {} 

public interface Response {} 

public interface Callback<R extends Response> {
    void onSuccess(R response);
    void onError(Exception e);
}

request 和 Response 界面有各种对称执行,即 requestA + ResponseA (客户端提供), requestB + ResponseB (服务内部使用),等等。

处理流程看起来是这样的:

"https://i.sstatic.net/egQJX.png" alt="序列图,显示嵌套回拨。"/ >

从收到每份答复到发出下一份请求之间,还需要进行一些额外的处理(例如,根据以前任何要求或答复中的数值)。

到目前为止,我尝试了两种方法来在爪哇的编码:

anonymous classes: gets ugly quickly because of the required nesting
inner classes: neater than the above, but still hard for another developer to comprehend the flow of execution

是否有某种模式可以让该代码更容易读取? 例如,我能否将服务方法表达为一份由某个负责筑巢的框架类别按顺序执行的自足操作清单?

Answer 1

由于执行(不仅是接口)不能阻拦,我喜欢你的列表想法。

设置一个“ 操作” 列表( 也许是 < code > Future ? ), 设置应该非常清楚, 可以读读。收到每次回复后, 下一个操作应该被引用。

这听起来像。

public void setup() {
    this.operations.add(new Operation(new RequestA(), new CallbackA()));
    this.operations.add(new Operation(new RequestB(), new CallbackB()));
    this.operations.add(new Operation(new RequestC(), new CallbackC()));
    this.operations.add(new Operation(new RequestD(), new CallbackD()));
    startNextOperation();
}
private void startNextOperation() {
    if ( this.operations.isEmpty() ) { reportAllOperationsComplete(); }
    Operation op = this.operations.remove(0);
    op.request.go( op.callback );
}
private class CallbackA implements Callback<Boolean> {
    public void onSuccess(Boolean response) {
        // store response? etc?
        startNextOperation();
    }
}
...

Answer 2

我认为,最自然的模拟这类问题的方法是 Futre<V>。

所以不使用回调, 只需返回一个“ tunk ” : a Futre<Response> , 表示未来某个时候会提供的答复。

然后您可以将后续步骤建模为 Future< reponseB> reponseB> step2( Futre<Response<ResponseA>) ,或者使用

如果以这种方式使用, Futre<V> 就会像一个monad (事实上,我想它可以算成一个,虽然我头顶上不确定), 因此整个过程感觉有点像哈斯凯尔的 IO, 就像通过 IO monad 所表现的 IO。

Answer 3

您可以使用演员计算模型。在您的情况中,客户、服务和回调[B-D]都可以作为演员代表。

有许多用于 Java 的演员图书馆, 但大部分是重量级的, 所以我写了一个缩略语, 并且可以扩展 : < a href="https://github.com/rfqu/df4j" rel=“nofollow” 标题 ="df4j" >df4j 。它把演员模型视为更一般的数据流计算模型的一个具体案例, 并因此允许用户创建新型演员, 以最符合用户要求。

Answer 4

我不确定我是否正确理解您的问题。如果您想要援引一个服务及其完成结果, 需要将它传递给其他可以继续使用结果处理的对象。您可以查看使用 Compite and pervision 来完成它。

友情链接