如何编写 Hazelcast Jet 作业来处理 Http 请求并发出结果作为响应



我有一个http端点,客户端在其中使用返回计算响应的数据发出请求。计算有几个阶段 -data lookupcalculations和很少transformations。最终结果将写入为对请求的响应。

我可以编写一个 Hazelcast Jet 作业来接收 http 中接收的数据,上面定义的所有计算是否将结果响应到请求?

我没有看到直接的方法,但是,我看到的一种方法是,有一个反应式 http 服务器,以反应式方式读取请求,将请求写入RingbufferIQueue并在另一个Ringbuffer中等待结果(借助回调(。

Hazelcast作业可以从源Ringbuffer读取,计算和转换,最终将结果写入另一个Ringbuffer(接收器(。

Hazelcast Jet是否使用了这种方式?您的想法可以帮助您更好地了解 Jet。

我建议添加一个 Web 层:由于您需要编写一个 HTTP 端点来启动 Jet 作业,因此它可以在作业完成后发送响应。

你可以阻止/反应/随便什么,但逻辑是一样的。

最新更新